mqlite

package module

Go to main page

Versions in this module

v0

v0.1.1

Jun 22, 2026

Changes in this version

+ const TokenPrefix

+ func GenerateToken() string

type Client

+ func (c *Client) CompleteBatch(ctx context.Context, queue string, msgs ...*Message) ([]SettleResult, error)

type Embedded

+ func (e *Embedded) Compact(ctx context.Context, full bool) error

+ func (e *Embedded) CompleteBatch(ctx context.Context, queue string, msgs ...*Message) ([]SettleResult, error)

type EmbeddedOption

+ func WithDLQRetention(maxAge time.Duration, maxCount int, maxBytes int64) EmbeddedOption

type QueueConfig

+ DLQMaxAge time.Duration

+ DLQMaxBytes int64

+ DLQMaxCount int

type ServeOption

+ func WithVersion(v string) ServeOption

+ type SettleResult struct

+ Ok bool

+ SequenceNumber int64

v0.1.0

Jun 20, 2026

Changes in this version

+ const Active

+ const DeadLettered

+ const Deferred

+ const Locked

+ const OrderGroupFIFO

+ const OrderStandard

+ const OrderStrictFIFO

+ const Scheduled

+ var ErrDBLocked = engine.ErrDBLocked

+ var ErrDedupConflict = engine.ErrDedupConflict

+ var ErrGroupRequired = engine.ErrGroupRequired

+ var ErrLockLost = engine.ErrLockLost

+ var ErrMessageTooLarge = engine.ErrMessageTooLarge

+ var ErrNameConflict = engine.ErrNameConflict

+ var ErrNotFound = engine.ErrNotFound

+ var ErrQueueNotFound = engine.ErrQueueNotFound

+ type AbandonOpts struct

+ Delay time.Duration

+ type Client struct

+ func Open(ctx context.Context, dsn string, opts ...Option) (*Client, error)

+ func (c *Client) Cancel(ctx context.Context, queue string, seq int64) error

+ func (c *Client) Close() error

+ func (c *Client) CreateQueue(ctx context.Context, name string, cfg QueueConfig) error

+ func (c *Client) ListQueues(ctx context.Context) ([]QueueInfo, error)

+ func (c *Client) Peek(ctx context.Context, queue string, opts ...PeekOpts) ([]*PeekedMessage, error)

+ func (c *Client) Purge(ctx context.Context, queue string, opts ...PurgeOpts) (int, error)

+ func (c *Client) Receive(ctx context.Context, queue string, opts ...RecvOpts) ([]*Message, error)

+ func (c *Client) Receiver(queue string, opts ...ReceiverOption) *Receiver

+ func (c *Client) Redrive(ctx context.Context, dlqQueue string, opts ...RedriveOpts) (int, error)

+ func (c *Client) Send(ctx context.Context, queue string, msgs ...OutMessage) ([]int64, error)

+ func (c *Client) SendOne(ctx context.Context, queue string, m OutMessage, opts ...SendOpts) (int64, error)

+ func (c *Client) Stats(ctx context.Context, queue string) (Metrics, error)

+ func (c *Client) Subscribe(ctx context.Context, topic, name string, f *Filter) error

+ type Embedded struct

+ func OpenEmbedded(ctx context.Context, dbDSN string, opts ...EmbeddedOption) (*Embedded, error)

+ func (e *Embedded) Cancel(ctx context.Context, queue string, seq int64) error

+ func (e *Embedded) Close() error

+ func (e *Embedded) CreateQueue(ctx context.Context, name string, cfg QueueConfig) error

+ func (e *Embedded) Engine() *engine.Engine

+ func (e *Embedded) ListQueues(ctx context.Context) ([]QueueInfo, error)

+ func (e *Embedded) Peek(ctx context.Context, queue string, opts ...PeekOpts) ([]*PeekedMessage, error)

+ func (e *Embedded) Purge(ctx context.Context, queue string, opts ...PurgeOpts) (int, error)

+ func (e *Embedded) Receive(ctx context.Context, queue string, opts ...RecvOpts) ([]*Message, error)

+ func (e *Embedded) Receiver(queue string, opts ...ReceiverOption) *Receiver

+ func (e *Embedded) Redrive(ctx context.Context, dlqQueue string, opts ...RedriveOpts) (int, error)

+ func (e *Embedded) Send(ctx context.Context, queue string, msgs ...OutMessage) ([]int64, error)

+ func (e *Embedded) SendOne(ctx context.Context, queue string, m OutMessage, opts ...SendOpts) (int64, error)

+ func (e *Embedded) Serve(ctx context.Context, addr string, opts ...ServeOption) error

+ func (e *Embedded) Stats(ctx context.Context, queue string) (Metrics, error)

+ func (e *Embedded) Subscribe(ctx context.Context, topic, name string, f *Filter) error

+ func (e *Embedded) Tx(ctx context.Context, fn func(*engine.EngineTx) error) error

+ type EmbeddedOption func(*embeddedConfig)

+ func WithClock(now func() int64) EmbeddedOption

+ func WithDBAuthToken(tok string) EmbeddedOption

+ func WithLogger(lg *slog.Logger) EmbeddedOption

+ func WithMaxMessageBytes(n int64) EmbeddedOption

+ func WithSynchronous(mode string) EmbeddedOption

+ func WithoutBackground() EmbeddedOption

+ type Filter = engine.Filter

+ type Message struct

+ Body []byte

+ ContentType string

+ CorrelationID string

+ DeliveryCount int

+ EnqueuedAt time.Time

+ GroupID string

+ LockedUntil time.Time

+ MessageID string

+ Properties map[string]string

+ ReplyTo string

+ SequenceNumber int64

+ Subject string

+ func (m *Message) Abandon(ctx context.Context, opts ...AbandonOpts) error

+ func (m *Message) Complete(ctx context.Context) error

+ func (m *Message) Defer(ctx context.Context) error

+ func (m *Message) Reject(ctx context.Context, opts ...RejectOpts) error

+ func (m *Message) Renew(ctx context.Context) error

+ type Metrics = engine.Metrics

+ type Option func(*config)

+ func WithHTTPClient(h *http.Client) Option

+ func WithToken(tok string) Option

+ type OrderingMode = engine.OrderingMode

+ type OutMessage struct

+ Body []byte

+ ContentType string

+ CorrelationID string

+ GroupID string

+ MessageID string

+ Properties map[string]string

+ ReplyTo string

+ Subject string

+ TTL time.Duration

+ type PeekOpts struct

+ From int64

+ Max int

+ State State

+ type PeekedMessage struct

+ Body []byte

+ ContentType string

+ CorrelationID string

+ DeliveryCount int

+ EnqueuedAt time.Time

+ GroupID string

+ LockedUntil time.Time

+ MessageID string

+ Properties map[string]string

+ ReplyTo string

+ SequenceNumber int64

+ State State

+ Subject string

+ VisibleAt time.Time

+ type PurgeOpts struct

+ Max int

+ OlderThan time.Duration

+ type QueueConfig struct

+ DeadLetterOnExpire *bool

+ DedupWindow time.Duration

+ DefaultTTL time.Duration

+ LockDuration time.Duration

+ MaxDeliveryCount int

+ Ordering OrderingMode

+ type QueueInfo = engine.QueueInfo

+ type Receiver struct

+ func (r *Receiver) Close() error

+ func (r *Receiver) Run(ctx context.Context, handler func(context.Context, *Message) error) error

+ type ReceiverOption func(*receiverConfig)

+ func WithAutoRenew() ReceiverOption

+ func WithConcurrency(n int) ReceiverOption

+ func WithPrefetch(n int) ReceiverOption

+ type RecvOpts struct

+ AtMostOnce bool

+ Attempt string

+ Max int

+ Pick []int64

+ Wait time.Duration

+ type RedriveOpts struct

+ Max int

+ OlderThan time.Duration

+ Rate int

+ To string

+ type RejectOpts struct

+ Detail string

+ Reason string

+ type SendOpts struct

+ At time.Time

+ type ServeOption func(*serveConfig)

+ func WithTokenCSV(csv string) ServeOption

+ func WithTokens(tokens ...string) ServeOption

+ type State = engine.State

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL