state

Documentation

Index

• type Config
• type Controller
  • func NewController(log *logging.Logger, cfg Config, apiClient *castai.Client, ...) *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

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