Versions in this module Expand all Collapse all v0 v0.0.4 Sep 13, 2025 Changes in this version type DSQueue + func (q *DSQueue) GetN(n int) ([][]byte, error) + func (q *DSQueue) Out() <-chan []byte + func (q *DSQueue) Put(item []byte) (err error) v0.0.1 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
Go to main page