ingestnotification

Documentation

Index

• Constants
• func NewHandler(logger *slog.Logger, metricMeter metric.Meter, ...) (flushhandler.FlushEventHandler, error)
• type EventBatchedIngest
• type HandlerConfig
• type IngestEventData

Constants

const (
	EventSubsystem = ingestnotification.EventSubsystem
)

Event types

Functions

func NewHandler

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

Ingest notification handler

Types

type EventBatchedIngest

type EventBatchedIngest = ingestnotification.EventBatchedIngest

type HandlerConfig

type HandlerConfig = ingestnotification.HandlerConfig

type IngestEventData

type IngestEventData = ingestnotification.IngestEventData