Versions in this module Expand all Collapse all v0 v0.1.1 Mar 28, 2023 Changes in this version type Config + ChanBufSize int + DisableAutoFlush bool + FlushInterval time.Duration + LogLevel int + Logger *logr.Logger + SyncAutoFlush bool + func (config *Config) Validate() (err error) v0.1.0 Mar 28, 2023 Changes in this version + var ErrClosed = errors.New("buffer is closed") + type Buffer struct + func NewBuffer(container container.Container[T], config Config) (buffer *Buffer[T], errChan <-chan error, err error) + func (buffer *Buffer[T]) Close() error + func (buffer *Buffer[T]) Flush(async bool) error + func (buffer *Buffer[T]) Put(data T) error + type Config struct + ID string + func (config *Config) Check() (err error)