events

Jun 28, 2021

Changes in this version

type Events

+ func (e *Events) CreateEventWithContext(ctx context.Context, accountID int, event interface{}) error

Aug 3, 2020

Changes in this version

+ const DefaultBatchSize

+ const DefaultBatchTimeout

+ const DefaultBatchWorkers

+ type BatchConfigOption func(*Events) error

+ func BatchConfigQueueSize(size int) BatchConfigOption

+ func BatchConfigTimeout(seconds int) BatchConfigOption

+ func BatchConfigWorkers(count int) BatchConfigOption

type Events

+ func (e *Events) BatchMode(ctx context.Context, accountID int, opts ...BatchConfigOption) (err error)

+ func (e *Events) EnqueueEvent(ctx context.Context, event interface{}) (err error)

+ func (e *Events) Flush() error

Jul 24, 2020

Changes in this version

+ type Events struct

+ func New(cfg config.Config) Events

+ func (e *Events) CreateEvent(accountID int, event interface{}) error