New returns a postgres store initialised with the given connection instance and config.

WithJSONPayload creates payload column as JSONB.

WithSchema setups schema name.

WithTableName setups schema name.

WithTransformer applies sets a custom message transformer.

DefaultMessagesTable is the table name that will be used if no other table name provided.

errors.

Storer is the implementation of messages store for postgres.

Executor knows how to run a sql query.

Instance defines the postgres interface to be used by the store.

Row knows how to scan an query row.

Rows knows how to scan multiple query rows.

Option is a function to set options to Publisher.