cascadeq

Jun 10, 2026

Changes in this version

+ var ErrIsDirectory = errors.New("queue file is a directory")

Jun 5, 2026

Changes in this version

type Queue

+ func (q *Queue) Drain(dst [][]byte) int

+ func (q *Queue) PutBatch(items [][]byte) error

Jun 2, 2026

Changes in this version

+ func WithLogger(logger *slog.Logger) func(*Queue)

Jun 1, 2026

Changes in this version

+ const BadFileExt

+ const DefaultMaxItemSize

+ const DefaultMaxMemItems

+ const DefaultMaxMemory

+ var ErrClosed = errors.New("closed")

+ func WithGzip(enable bool) func(*Queue)

+ func WithMaxItemSize(maxSize int) func(*Queue)

+ func WithMaxMemItems(maxItems int) func(*Queue)

+ func WithMaxMemory(maxBytes int) func(*Queue)

+ func WithMinItemSize(minSize int) func(*Queue)

+ func WithSnapshotInterval(d time.Duration) func(*Queue)

+ type Queue struct

+ func New(name, dir string, options ...func(*Queue)) (*Queue, error)

+ func (q *Queue) Clear() error

+ func (q *Queue) Close() error

+ func (q *Queue) Dir() string

+ func (q *Queue) Done() <-chan struct{}

+ func (q *Queue) Empty() <-chan struct{}

+ func (q *Queue) Name() string

+ func (q *Queue) Out() <-chan []byte

+ func (q *Queue) Put(item []byte) (err error)

+ func (q *Queue) Stats() Stats

+ type Stats struct

+ Closed bool

+ Files []string

+ HeadQBytes int

+ HeadQLen int

+ MaxQBytes int

+ MaxQLen int

+ TailQBytes int

+ TailQLen int