Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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
}
func (HandlerConfig) Validate ¶
func (c HandlerConfig) Validate() error
Click to show internal directories.
Click to hide internal directories.