state

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

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

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

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

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

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

type Config struct {
	StatsScrapeInterval time.Duration `json:"statsScrapeInterval"`

	NetflowExportInterval time.Duration `validate:"required" json:"netflowExportInterval"`

	EventsBatchSize     int           `validate:"required" json:"eventsBatchSize"`
	EventsFlushInterval time.Duration `validate:"required" json:"eventsFlushInterval"`
}

type ContainerEventsExporter interface {
	DataExporter
	Enqueue(e *castpb.ContainerEventsBatch)
}

type ContainerEventsSender interface {
	Send(ctx context.Context, batch *castpb.ContainerEventsBatch) error
}

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 {
	ContainerEventsSender ContainerEventsSender
	Stats                 []StatsExporter
	Netflow               []NetflowExporter
	ProcessTree           []ProcessTreeExporter
	// contains filtered or unexported fields
}

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

type ProcessTreeExporter interface {
	DataExporter
	Enqueue(e processtree.ProcessTreeEvent)
}

type StatsExporter interface {
	DataExporter
	Enqueue(e *castpb.StatsBatch)
}

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