buffer

Jun 24, 2020

Changes in this version

+ var ErrTimeout = errors.New("operation timed-out")

+ type Flusher interface

+ Write func(items []interface{})

+ type FlusherFunc func(items []interface{})

+ func (fn FlusherFunc) Write(items []interface{})

type Option

+ func WithFlushInterval(interval time.Duration) Option

+ func WithFlusher(flusher Flusher) Option

+ func WithSize(size uint) Option

type Options

+ FlushInterval time.Duration

+ Flusher Flusher

+ Size uint

Jun 18, 2020

Changes in this version

+ var ErrFull = errors.New("buffer is full")

+ var ErrOperationTimeout = errors.New("operation timed-out")

+ type Buffer struct

+ func New(size uint, flusher func([]interface{}), opts ...Option) (*Buffer, error)

+ func (buffer *Buffer) Close() error

+ func (buffer *Buffer) Flush() error

+ func (buffer *Buffer) Push(item interface{}) error

+ type Option func(*Options)

+ func WithAutoFlush(interval time.Duration) Option

+ func WithCloseTimeout(timeout time.Duration) Option

+ func WithFlushTimeout(timeout time.Duration) Option

+ func WithPushTimeout(timeout time.Duration) Option

+ type Options struct

+ AutoFlush bool

+ AutoFlushInterval time.Duration

+ CloseTimeout time.Duration

+ FlushTimeout time.Duration

+ PushTimeout time.Duration

Jun 16, 2020

Changes in this version

+ func OnEach(item interface{}) error

+ func OnEnd() error