pgmq4s
0.15.0
DocsAPI
Generated with
Copyright Matej Cerny
Copyright Matej Cerny
pgmq4s/pgmq4s/PgmqAdminBackend

PgmqAdminBackend

pgmq4s.PgmqAdminBackend
trait PgmqAdminBackend[F[_]]

SPI trait for database backends. Implement this to provide a PGMQ admin backend.

All operations work at the raw (String-level) representation. The higher-level PgmqAdmin[F] API wraps a backend instance and handles domain type conversions.

Attributes

Source
PgmqAdminBackend.scala
Graph
Supertypes
class Object
trait Matchable
class Any

Members list

Value members

Abstract methods

def bindTopic(pattern: String, queue: String): F[Unit]

Attributes

Source
PgmqAdminBackend.scala
def convertArchivePartitioned(queue: String, partitionInterval: String, retentionInterval: String, leadingPartition: Int): F[Unit]

Attributes

Source
PgmqAdminBackend.scala
def createPartitionedQueue(queue: String, partitionInterval: String, retentionInterval: String): F[Unit]

Attributes

Source
PgmqAdminBackend.scala
def createQueue(queue: String): F[Unit]

Attributes

Source
PgmqAdminBackend.scala
def createUnloggedQueue(queue: String): F[Unit]

Attributes

Source
PgmqAdminBackend.scala
def detachArchive(queue: String): F[Unit]

Attributes

Source
PgmqAdminBackend.scala
def disableNotifyInsert(queue: String): F[Unit]

Attributes

Source
PgmqAdminBackend.scala
def dropOldArchive(queue: String): F[Unit]

Attributes

Source
PgmqAdminBackend.scala
def dropQueue(queue: String): F[Boolean]

Attributes

Source
PgmqAdminBackend.scala
def enableNotifyInsert(queue: String, throttleIntervalMs: Int): F[Unit]

Attributes

Source
PgmqAdminBackend.scala
def listNotifyInsertThrottles: F[List[(String, Int, OffsetDateTime)]]

Attributes

Source
PgmqAdminBackend.scala
def listQueues: F[List[QueueInfo]]

Attributes

Source
PgmqAdminBackend.scala
def metrics(queue: String): F[Option[QueueMetrics]]

Attributes

Source
PgmqAdminBackend.scala
def metricsAll: F[List[QueueMetrics]]

Attributes

Source
PgmqAdminBackend.scala
def purgeQueue(queue: String): F[Long]

Attributes

Source
PgmqAdminBackend.scala
def testRouting(routingKey: String): F[List[(String, String, String)]]

Attributes

Source
PgmqAdminBackend.scala
def unbindTopic(pattern: String, queue: String): F[Boolean]

Attributes

Source
PgmqAdminBackend.scala
def updateNotifyInsert(queue: String, throttleIntervalMs: Int): F[Unit]

Attributes

Source
PgmqAdminBackend.scala
Generated with
Copyright Matej Cerny
Copyright Matej Cerny