state

package
v1.30.1 Latest Latest
Warning

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

 Go to latest Published: Dec 12, 2024 License: Apache-2.0 Imports: 35 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

func ClickhouseProcessTreeSchema added in v1.15.0 

func ClickhouseProcessTreeSchema() 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 CastaiProcessTreeExporter added in v1.15.0 

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

func NewCastaiProcessTreeExporter added in v1.15.0 

func NewCastaiProcessTreeExporter(log *logging.Logger, apiClient *castai.Client, queueSize int) *CastaiProcessTreeExporter

func (*CastaiProcessTreeExporter) Enqueue added in v1.15.0 

func (c *CastaiProcessTreeExporter) Enqueue(e processtree.ProcessTreeEvent)

func (*CastaiProcessTreeExporter) Run added in v1.15.0 

func (c *CastaiProcessTreeExporter) 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 ClickhouseProcessTreeExporter added in v1.15.0 

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

func NewClickhouseProcessTreeExporter added in v1.15.0 

func NewClickhouseProcessTreeExporter(log *logging.Logger, conn clickhouse.Conn, queueSize int) *ClickhouseProcessTreeExporter

func (*ClickhouseProcessTreeExporter) Enqueue added in v1.15.0 

func (c *ClickhouseProcessTreeExporter) Enqueue(e processtree.ProcessTreeEvent)

func (*ClickhouseProcessTreeExporter) Run added in v1.15.0 

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

type Config 

type Config struct {
	ContainerStatsScrapeInterval time.Duration `json:"containerStatsScrapeInterval"`

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

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,
	processTreeCollector processTreeCollector,
) *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
	ProcessTree    []ProcessTreeExporter
	// 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 ProcessTreeExporter added in v1.15.0 

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

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.