state

package
v1.13.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 17, 2024 License: Apache-2.0 Imports: 33 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ClickhouseNetflowSchema added in v1.7.0 

func ClickhouseNetflowSchema() string

Types

type CastaiContainerStatsExporter added in v1.7.0 

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

func NewCastaiContainerStatsExporter added in v1.7.0 

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

func (*CastaiContainerStatsExporter) Enqueue added in v1.7.0 

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

func (*CastaiContainerStatsExporter) Run added in v1.7.0 

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

type CastaiEventsExporter added in v1.7.0 

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

func NewCastaiEventsExporter added in v1.7.0 

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

func (*CastaiEventsExporter) Enqueue added in v1.7.0 

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

func (*CastaiEventsExporter) Run added in v1.7.0 

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

type CastaiNetflowExporter added in v1.9.0 

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

func NewCastaiNetflowExporter added in v1.9.0 

func NewCastaiNetflowExporter(log *logging.Logger, apiClient *castai.Client, queueSize int) *CastaiNetflowExporter

func (*CastaiNetflowExporter) Enqueue added in v1.9.0 

func (c *CastaiNetflowExporter) Enqueue(e *castpb.Netflow)

func (*CastaiNetflowExporter) Run added in v1.9.0 

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

type ClickHouseNetflowExporter added in v1.7.0 

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

func NewClickhouseNetflowExporter added in v1.7.0 

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

func (*ClickHouseNetflowExporter) Enqueue added in v1.7.0 

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

func (*ClickHouseNetflowExporter) Run added in v1.7.0 

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

type Config 

type Config struct {
	ContainerStatsScrapeInterval time.Duration

	NetflowExportInterval  time.Duration `validate:"required"`
	NetflowCleanupInterval time.Duration `validate:"required"`
	NetflowGrouping        NetflowGrouping
}

type ContainerStatsExporter added in v1.7.0 

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 added in v1.7.0 

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

type EventsExporter added in v1.7.0 

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

type Exporters added in v1.7.0 

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

func NewExporters added in v1.7.0 

func NewExporters(log *logging.Logger) *Exporters

func (*Exporters) Empty added in v1.7.0 

func (e *Exporters) Empty() bool

func (*Exporters) Run added in v1.7.0 

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

type NetflowExporter added in v1.7.0 

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

type NetflowGrouping added in v1.9.0 

type NetflowGrouping int64
const (
	NetflowGroupingSrcAddr NetflowGrouping = (1 << iota)
	NetflowGroupingDstAddr
)

func (*NetflowGrouping) Set added in v1.9.0 

func (n *NetflowGrouping) Set(s string) error

func (*NetflowGrouping) String added in v1.9.0 

func (n *NetflowGrouping) String() string

func (*NetflowGrouping) Type added in v1.9.0 

func (n *NetflowGrouping) Type() string

type StdioEventsExporter added in v1.7.0 

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

func NewStdioEventsExporter added in v1.7.0 

func NewStdioEventsExporter(log *logging.Logger) *StdioEventsExporter

func (*StdioEventsExporter) Enqueue added in v1.7.0 

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

func (*StdioEventsExporter) Run added in v1.7.0 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.