NoError fails the test if err is not nil.

WriteString appends the provided string to the query and extracts any parameters from it.

Equal fails the test if expected is not equal to actual.

QuoteIdentifier quotes an "identifier" (e.g. a table or a column name) to be used as part of an SQL statement. For example: tblname := "my_table"

Run consumes messages until the context isn't cancelled.

GenerateDropTableQuery returns a postgres query for dropping the queue table

NewPublisher initializes the publisher with given *sql.DB client.

NewConsumer creates Consumer with proper settings

Next returns next parameter.

TODO: This was recovered from the consumer_test.go file. We can make a common testing package and add all these common functionalities will be include

ErrorIs fails the test if err is nil or does not match target.

GenerateCreateTableQuery returns the query for creating the queue table

WithInvalidMessageCallback sets callback for invalid messages.

WithLockDuration sets the maximal duration for how long the message remains locked for other consumers.

WithLogger sets logger. Default is no logging.

WithMaxParallelMessages sets how many jobs can single consumer process simultaneously.

WithMetrics sets metrics meter. Default is noop.Meter{}.

WithPollingInterval sets how frequently consumer checks the queue for new messages.

acquireMaxFromSemaphore acquires maximum possible weight. It blocks until resources are available or ctx is done. On success, returns acquired weight.

Error fails the test if err is nil.

SetDeadline sets the message deadline. If the deadline is after the message deadline, it returns ErrInvalidDeadline. The timeout also affects the queu

ValidateFields checks if required fields exist

ValidateIndexes checks if required indexes exist

WithHistoryLimit sets how long in history you want to search for unprocessed messages (default is no limit). If not set, it will look for message in t

StaticMetaInjector returns a Metadata injector that injects given Metadata.

WithMetaInjectors adds Metadata injectors to the publisher. Injectors are run in the order they are given.

var ( _ pgError = (*pgconn.PgError)(nil) _ pgError = (*pq.Error)(nil) _ legacyPGError = (*pq.Error)(nil) )

HasParam checks whether the Builder has a parameter of the given name.

getParams extracts tags formatted as :tagName from the provided line, ignoring type casting patterns like ::interval.

Build returns the query string with the parameters replaced by the values from the provided map.

LastAttempt returns true if the message is consumed for the last time according to maxConsumedCount settings. If the Consumer is not configured to lim

NewConsumer creates Consumer with proper settings, using sqlx.DB (until refactored to use pgx directly)

NewPublisher initializes the publisher with given *sqlx.DB client

WithAckTimeout sets the timeout for updating the message status when message is processed.

WithMaxConsumeCount sets the maximal number of times a message can be consumed before it is ignored. Unhandled SIGKILL or uncaught panic, OOM error et

WithMessageProcessingReserveDuration sets the duration for which the message is reserved for handling result state.

ack positively acknowledges the message, and the message is marked as processed.

buildColumnListFromTags dynamically constructs a list of column names based on the `db` struct tags of any given struct. It returns a slice of strings

discard removes the message from the queue completely. It's like ack, but it also records the reason why the message was discarded.

nack does not the negative acknowledge of the message. The message is returned to the queue after nack and may be processed again.

HandleMessage calls self. It also implements MessageHandler interface.

NewMessage creates new message that satisfies Message interface.

Publish publishes the message.

SetTimeout sets the message timeout. If the timeout is after the message deadline, it returns ErrInvalidDeadline. The timeout also affects the queue l