IsQueueCorrupt checks if the error value indicates a corrupted queue, which can not be used anymore.

MakeRoot prepares the queue header (empty queue).

New creates a new Queue.

NewStandaloneDelegate creates a standaonle Delegate from an txfile.File instance.

invalid ack on empty queue.

too many events acked.

no active transaction.

failed to initialize queue.

invalid queue config.

invalid page size.

invalid parameter.

queue root is invalid.

no error.

no queue root.

queue is already closed.

unsupported queue version.

reader is already closed.

failed to read page.

failed to seek to next page.

SzRoot is the size of the queue header in bytes.

unexpected active transaction.

writer is already closed.

ACKStats reports stats on the most recent ACK transaction.

Error is the actual error type returned by all functions/methods within the pq package.

FlushStats reports internal stats on the most recent flush operation.

Queue implements the on-disk queue data structure.

Reader is used to iterate events stored in the queue.

ReadStats reports stats on the most recent transaction for reading events.

Settings configures a queue when being instantiated with `New`.

Writer is used to push new events onto the queue.

Delegate is used by the persistent queue to query common parameters and start transactions when required.

Observer defines common callbacks to observe operations, outcomes and stats on queues.

ErrKind provides the pq related error kinds.