state

Documentation

Index

• func ClickhouseNetflowSchema() string
• type CastaiContainerStatsExporter
  • func NewCastaiContainerStatsExporter(log *logging.Logger, apiClient *castai.Client, queueSize int) *CastaiContainerStatsExporter
  • func (c *CastaiContainerStatsExporter) Enqueue(e *castpb.ContainerStatsBatch)
  • func (c *CastaiContainerStatsExporter) Run(ctx context.Context) error
• type CastaiEventsExporter
  • func NewCastaiEventsExporter(log *logging.Logger, apiClient *castai.Client, queueSize int) *CastaiEventsExporter
  • func (c *CastaiEventsExporter) Enqueue(e *castpb.Event)
  • func (c *CastaiEventsExporter) Run(ctx context.Context) error
• type ClickHouseNetflowExporter
  • func NewClickhouseNetflowExporter(log *logging.Logger, conn clickhouse.Conn, queueSize int) *ClickHouseNetflowExporter
  • func (c *ClickHouseNetflowExporter) Enqueue(e *castaipb.Netflow)
  • func (c *ClickHouseNetflowExporter) Run(ctx context.Context) error
• type Config
• type ContainerStatsExporter
• type Controller
  • func NewController(log *logging.Logger, cfg Config, exporters *Exporters, ...) *Controller
  • func (c *Controller) IsMutedNamespace(namespace string) bool
  • func (c *Controller) MuteNamespace(namespace string) error
  • func (c *Controller) Run(ctx context.Context) error
  • func (c *Controller) UnmuteNamespace(namespace string) error
• type DataExporter
• type EventsExporter
• type Exporters
  • func NewExporters(log *logging.Logger) *Exporters
  • func (e *Exporters) Empty() bool
  • func (e *Exporters) Run(ctx context.Context) error
• type NetflowExporter
• type StdioEventsExporter
  • func NewStdioEventsExporter(log *logging.Logger) *StdioEventsExporter
  • func (c *StdioEventsExporter) Enqueue(e *castpb.Event)
  • func (c *StdioEventsExporter) Run(ctx context.Context) error

Functions

func ClickhouseNetflowSchema

func ClickhouseNetflowSchema() string

Types

type CastaiContainerStatsExporter

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

func NewCastaiContainerStatsExporter

func NewCastaiContainerStatsExporter(log *logging.Logger, apiClient *castai.Client, queueSize int) *CastaiContainerStatsExporter

func (*CastaiContainerStatsExporter) Enqueue

func (c *CastaiContainerStatsExporter) Enqueue(e *castpb.ContainerStatsBatch)

func (*CastaiContainerStatsExporter) Run

func (c *CastaiContainerStatsExporter) Run(ctx context.Context) error

type CastaiEventsExporter

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

func NewCastaiEventsExporter

func NewCastaiEventsExporter(log *logging.Logger, apiClient *castai.Client, queueSize int) *CastaiEventsExporter

func (*CastaiEventsExporter) Enqueue

func (c *CastaiEventsExporter) Enqueue(e *castpb.Event)

func (*CastaiEventsExporter) Run

func (c *CastaiEventsExporter) Run(ctx context.Context) error

type ClickHouseNetflowExporter

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

func NewClickhouseNetflowExporter

func NewClickhouseNetflowExporter(log *logging.Logger, conn clickhouse.Conn, queueSize int) *ClickHouseNetflowExporter

func (*ClickHouseNetflowExporter) Enqueue

func (c *ClickHouseNetflowExporter) Enqueue(e *castaipb.Netflow)

func (*ClickHouseNetflowExporter) Run

func (c *ClickHouseNetflowExporter) Run(ctx context.Context) error

type Config

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

type ContainerStatsExporter

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

type Controller

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

func NewController

func NewController(
	log *logging.Logger,
	cfg Config,
	exporters *Exporters,
	containersClient containersClient,
	netStatsReader netStatsReader,
	ct conntrackClient,
	tracer ebpfTracer,
	signatureEngine signatureEngine,
	enrichmentService enrichmentService,
	kubeClient kubepb.KubeAPIClient,
) *Controller

func (*Controller) IsMutedNamespace

func (c *Controller) IsMutedNamespace(namespace string) bool

func (*Controller) MuteNamespace

func (c *Controller) MuteNamespace(namespace string) error

func (*Controller) Run

func (c *Controller) Run(ctx context.Context) error

func (*Controller) UnmuteNamespace

func (c *Controller) UnmuteNamespace(namespace string) error

type DataExporter

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

type EventsExporter

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

type Exporters

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

func NewExporters

func NewExporters(log *logging.Logger) *Exporters

func (*Exporters) Empty

func (e *Exporters) Empty() bool

func (*Exporters) Run

func (e *Exporters) Run(ctx context.Context) error

type NetflowExporter

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

type StdioEventsExporter

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

func NewStdioEventsExporter

func NewStdioEventsExporter(log *logging.Logger) *StdioEventsExporter

func (*StdioEventsExporter) Enqueue

func (c *StdioEventsExporter) Enqueue(e *castpb.Event)

func (*StdioEventsExporter) Run

func (c *StdioEventsExporter) Run(ctx context.Context) error