Versions in this module Expand all Collapse all v1 v1.2.1 Aug 2, 2026 Changes in this version + var DefaultFlushInterval = time.Second * 30 + var DefaultFlushTimeout = time.Second * 15 + var DefaultMaxEntries = 250 + var DefaultMaxRetries = 3 + type Buffer struct + func New(options ...Option) *Buffer + func (b *Buffer) Close() + func (b *Buffer) Flush() + func (b *Buffer) FlushSync() + func (b *Buffer) Push(value interface{}) + type ErrorFunc func(error) + type FlushFunc func(context.Context, []interface{}) error + type Option func(*Buffer) + func WithErrorHandler(fn ErrorFunc) Option + func WithFlushHandler(fn FlushFunc) Option + func WithFlushInterval(d time.Duration) Option + func WithFlushTimeout(d time.Duration) Option + func WithMaxEntries(n int) Option + func WithMaxRetries(n int) Option
Go to main page