NewDelayedPostgreSQLPublisher creates a new Publisher that stores messages in PostgreSQL with a delay.

NewDelayedPostgreSQLSubscriber creates a new Subscriber that reads messages from PostgreSQL with a delay.

NewPostgreSQLDelayedRequeuer creates a new DelayedRequeuer that uses PostgreSQL as a storage.

TxFromContext returns the transaction used by the subscriber to consume the message.

DefaultMySQLOffsetsAdapter is adapter for storing offsets for MySQL (or MariaDB) databases.

DefaultMySQLSchema is a default implementation of SchemaAdapter based on MySQL.

DefaultPostgreSQLOffsetsAdapter is adapter for storing offsets in PostgreSQL database.

DefaultPostgreSQLSchema is a default implementation of SchemaAdapter based on PostgreSQL.

DelayedRequeuer is a requeuer that uses a delayed publisher and subscriber to requeue messages.

DelayedRequeuerConfig is a configuration for DelayedRequeuer.

PostgreSQLQueueOffsetsAdapter is an OffsetsAdapter for the PostgreSQLQueueSchema.

PostgreSQLQueueSchema is a schema adapter for PostgreSQL that allows filtering messages by some condition.

Publisher inserts the Messages as rows into a SQL table..

Subscriber makes SELECT queries on the chosen table with the interval defined in the config.

BackoffManager handles errors or empty result sets and computes the backoff time.

Beginner begins transactions.

ContextExecutor can perform SQL queries with context.

A Result summarizes an executed SQL command.

SchemaAdapter produces the SQL queries and arguments appropriately for a specific schema and dialect It also transforms sql.Rows into Watermill messages.

SQLBeginner matches the standard library sql.DB and sql.Tx interfaces.

Deprecated: Use DefaultMySQLSchema instead.