ingestnotification

Documentation

Index

• func NewHandler(logger *slog.Logger, metricMeter metric.Meter, publisher eventbus.Publisher, ...) (flushhandler.FlushEventHandler, error)
• type HandlerConfig

Functions

func NewHandler

func NewHandler(logger *slog.Logger, metricMeter metric.Meter, publisher eventbus.Publisher, config HandlerConfig) (flushhandler.FlushEventHandler, error)

Types

type HandlerConfig

type HandlerConfig struct {
	MaxEventsInBatch int
}