ingestnotification

Documentation

Index

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

Constants

const (
	EventSubsystem = ingestnotification.EventSubsystem
)

Event types

Functions

func NewHandler

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

Ingest notification handler

Types

type IngestEvent

type IngestEvent = ingestnotification.EventIngested