loop

Nov 24, 2025

Changes in this version

+ type Factory struct

+ func (f *Factory[T]) CacheLoop(l Interface[T])

+ func (f *Factory[T]) NewLoop(h Handler[T]) Interface[T]

Jun 10, 2025

Changes in this version

+ type Handler interface

+ Handle func(ctx context.Context, t T) error

+ type Interface interface

+ Close func(t T)

+ Enqueue func(t T)

+ Reset func(h Handler[T], size uint64) Interface[T]

+ Run func(ctx context.Context) error

+ func Empty[T any]() Interface[T]

Apr 23, 2025

Changes in this version

+ type HandlerFunc func(context.Context, T) error

+ type Loop struct

+ func New[T any](opts Options[T]) *Loop[T]

+ func (l *Loop[T]) Enqueue(req T)

+ func (l *Loop[T]) Run(ctx context.Context) error

+ type Options struct

+ BufferSize *uint64

+ Handler HandlerFunc[T]