buffer

Jun 2, 2022

Changes in this version

+ var ErrFlushTimeout = errors.New("async-buffer: flush timeout")

+ var ErrWriteTimeout = errors.New("async-buffer: write timeout")

+ func DefaultErrHandler(err error, flat []T)

type Buffer

+ func (b *Buffer[T]) WriteWithContext(ctx context.Context, elements ...T) (int, error)

+ type Option struct

+ ErrHandler func(error, []T)

+ FlushInterval time.Duration

+ FlushTimeout time.Duration

+ Threshold uint32

+ WriteTimeout time.Duration

May 5, 2022

Changes in this version

+ type FlushFunc func(elements ...T) error

+ func (f FlushFunc[T]) Flush(elements ...T) error

Apr 25, 2022

Changes in this version

+ const DefaultDataBackupSize

+ var ErrClosed = errors.New("async-buffer: buffer is closed")

+ func NewErrFlush(err error, elements []T) error

+ type Buffer struct

+ func New(threshold uint32, flushInterval time.Duration, flusher Flusher[T]) (*Buffer[T], <-chan error)

+ func (b *Buffer[T]) Close() error

+ func (b *Buffer[T]) Flush()

+ func (b *Buffer[T]) Write(elements ...T) (int, error)

+ type ErrFlush struct

+ Backup []T

+ func (e ErrFlush[T]) Error() string

+ type Flusher interface

+ Flush func(elements ...T) error