Builder is a helper for building SQL queries with named parameters (jmoiron/sqlx and psql style for the moment)

Consumer is the preconfigured subscriber of the write input messages

ConsumerOption applies option to consumerConfig.

InvalidMessage is definition of invalid message used as argument for InvalidMessageCallback by Consumer.

InvalidMessageCallback defines what should happen to messages which are identified as invalid. Such messages usually have missing or malformed require

MessageHandler handles message received from queue. Returning false means message wasn't processed correctly and shouldn't be acknowledged. Error cont

MessageHandlerFunc is MessageHandler implementation by simple function.

MessageIncoming is a record retrieved from table queue in Postgres

MessageOutgoing is a record to be inserted into table queue in Postgres

Metadata is message Metadata definition.

MetadataFilter is a filter for metadata. Right now support only direct matching of key/value

MetadataFilter is a filter for metadata. Right now support only direct matching of key/value

Publisher publishes messages to Postgres queue.

PublisherOption configures the publisher. Multiple options can be passed to NewPublisher. Options are applied in the order they are given. The last op

StmtParams is a helper for generating prepared statement parameters, i.e. $1, $2, $3, ...

consumerConfig contains consumer configuration.

legacyPGError is an interface used by previous versions of github.com/lib/pq. It is provided only to support legacy code. New code should use the pgEr