state

type CastaiContainerStatsExporter struct {
	// contains filtered or unexported fields
}

type CastaiEventsExporter struct {
	// contains filtered or unexported fields
}

type ClickHouseNetflowExporter struct {
	// contains filtered or unexported fields
}

type Config struct {
	ContainerStatsScrapeInterval time.Duration `validate:"required"`
	NetflowExportInterval        time.Duration `validate:"required"`
	NetflowCleanupInterval       time.Duration `validate:"required"`
}

type ContainerStatsExporter interface {
	DataExporter
	Enqueue(e *castpb.ContainerStatsBatch)
}

type Controller struct {
	// contains filtered or unexported fields
}

type DataExporter interface {
	Run(ctx context.Context) error
}

type EventsExporter interface {
	DataExporter
	Enqueue(e *castpb.Event)
}

type Exporters struct {
	Events         []EventsExporter
	ContainerStats []ContainerStatsExporter
	Netflow        []NetflowExporter
	// contains filtered or unexported fields
}

type NetflowExporter interface {
	DataExporter
	Enqueue(e *castpb.Netflow)
}

type StdioEventsExporter struct {
	// contains filtered or unexported fields
}