state

package
v1.5.2 Latest Latest
Warning

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

 Go to latest Published: Apr 25, 2024 License: Apache-2.0 Imports: 27 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config 

type Config struct {
	EventsSinkQueueSize          int           `validate:"required"`
	ContainerStatsScrapeInterval time.Duration `validate:"required"`
}

type Controller 

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

func NewController 

func NewController(
	log *logging.Logger,
	cfg Config,
	apiClient *castai.Client,
	containersClient *containers.Client,
	netStatsReader *netstats.Reader,
	ct conntrack.Client,
	tracer *ebpftracer.Tracer,
	signatureEngine *signature.SignatureEngine,
	enrichmentService *enrichment.Service,
	kubeClient *kube.Client,
) *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

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.