dsqueue

Sep 12, 2025

Changes in this version

type DSQueue

+ func (q *DSQueue) GetN(n int) ([][]byte, error)

Sep 11, 2025

Changes in this version

type DSQueue

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

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

Sep 11, 2025

Changes in this version

+ const DefaultBufferSize

+ const DefaultCloseTimeout

+ const DefaultDedupCacheSize

+ const DefaultIdleWriteTime

+ type DSQueue struct

+ func New(ds datastore.Batching, name string, options ...Option) *DSQueue

+ func (q *DSQueue) Clear() int

+ func (q *DSQueue) Close() error

+ func (q *DSQueue) Dequeue() <-chan []byte

+ func (q *DSQueue) Enqueue(item []byte) (err error)

+ func (q *DSQueue) Name() string

+ type Option func(*config)

+ func WithBufferSize(n int) Option

+ func WithCloseTimeout(d time.Duration) Option

+ func WithDedupCacheSize(n int) Option

+ func WithIdleWriteTime(d time.Duration) Option