store

Sep 23, 2025

Changes in this version

type Config

+ FlushTimeout time.Duration

type Option

+ func WithFlushTimeout(t time.Duration) Option

+ type Queue interface

+ Dequeue func() (T, bool)

+ Enqueue func(v T)

+ Peek func() (T, bool)

+ Size func() int

+ func NewRingQueue[T any](size int) Queue[T]

Sep 17, 2025

Changes in this version

+ type Config struct

+ BatchSize int

+ Capacity int

+ Interval time.Duration

+ type ErrorHandler interface

+ OnError func(err error)

+ type Flusher interface

+ Flush func(ctx context.Context, entries []T) error

+ type Option func(cfg *Config)

+ func WithBatchSize(s int) Option

+ func WithCapacity(c int) Option

+ func WithClock(c quartz.Clock) Option

+ func WithInterval(i time.Duration) Option

+ func WithOnError(onError ErrorHandler) Option

+ type Store interface

+ Run func(ctx context.Context)

+ Write func(entries ...T)

+ func NewMemory[T any](flusher Flusher[T], options ...Option) Store[T]