Versions in this module Expand all Collapse all v0 v0.7.1 Jul 25, 2023 v0.7.0 Jul 20, 2023 Changes in this version + type Event interface + Bytes func() ([]byte, error) + type EventHandler struct + func NewEventHandler(messageChan chan<- []byte, logger log.Logger) *EventHandler + func (e EventHandler) HandleEvent(event Event) + type Handler interface + HandleEvent func(e Event) + type NoOpHandler struct + func (NoOpHandler) HandleEvent(_ Event) + type Worker struct + func NewWorker(messageChan <-chan []byte, writer Writer, batchInterval time.Duration, ...) *Worker + func (w *Worker) Close() error + func (w *Worker) Flush() + func (w *Worker) Run(ctx context.Context) + type Writer interface + Close func() error + Write func(messages [][]byte) error
Go to main page