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.

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.

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

Deprecated: Use DefaultMySQLSchema instead.