containerwatcher

Documentation

Index

• Constants
• type IGContainerWatcher
  • func CreateIGContainerWatcher(cfg config.Config, ...) (*IGContainerWatcher, error)
  • func (ch *IGContainerWatcher) GetContainerCollection() *containercollection.ContainerCollection
  • func (ch *IGContainerWatcher) GetContainerSelector() *containercollection.ContainerSelector
  • func (ch *IGContainerWatcher) GetSocketEnricher() *socketenricher.SocketEnricher
  • func (ch *IGContainerWatcher) GetTracerCollection() *tracercollection.TracerCollection
  • func (ch *IGContainerWatcher) Ready() bool
  • func (ch *IGContainerWatcher) RegisterContainerReceiver(receiver containerwatcher.ContainerReceiver)
  • func (ch *IGContainerWatcher) RegisterCustomTracer(tracer containerwatcher.CustomTracer) error
  • func (ch *IGContainerWatcher) Start(ctx context.Context) error
  • func (ch *IGContainerWatcher) Stop()
  • func (ch *IGContainerWatcher) UnregisterContainerReceiver(receiver containerwatcher.ContainerReceiver)
  • func (ch *IGContainerWatcher) UnregisterCustomTracer(tracer containerwatcher.CustomTracer) error
• type IGK8sClient
• type IGK8sClientMock
  • func NewIGK8sClientMock() *IGK8sClientMock
  • func (k *IGK8sClientMock) GetNonRunningContainers(pod *corev1.Pod) []string
  • func (k *IGK8sClientMock) GetRunningContainers(pod *corev1.Pod) []containercollection.Container
  • func (k *IGK8sClientMock) ListContainers() (arr []containercollection.Container, err error)

Constants

const (
	MaxSniffingTimeLabel = "kubescape.io/max-sniffing-time"
)

Types

type IGContainerWatcher

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

func CreateIGContainerWatcher

func CreateIGContainerWatcher(cfg config.Config, applicationProfileManager applicationprofilemanager.ApplicationProfileManagerClient, k8sClient *k8sinterface.KubernetesApi, relevancyManager relevancymanager.RelevancyManagerClient, networkManagerClient networkmanager.NetworkManagerClient, dnsManagerClient dnsmanager.DNSManagerClient, metrics metricsmanager.MetricsManager, ruleManager rulemanager.RuleManagerClient, malwareManager malwaremanager.MalwareManagerClient, preRunningContainers mapset.Set[string], ruleBindingPodNotify *chan rulebinding.RuleBindingNotify, runtime *containerutilsTypes.RuntimeConfig, thirdPartyEventReceivers *maps.SafeMap[utils.EventType, mapset.Set[containerwatcher.EventReceiver]]) (*IGContainerWatcher, error)

func (*IGContainerWatcher) GetContainerCollection

func (ch *IGContainerWatcher) GetContainerCollection() *containercollection.ContainerCollection

func (*IGContainerWatcher) GetContainerSelector

func (ch *IGContainerWatcher) GetContainerSelector() *containercollection.ContainerSelector

func (*IGContainerWatcher) GetSocketEnricher

func (ch *IGContainerWatcher) GetSocketEnricher() *socketenricher.SocketEnricher

func (*IGContainerWatcher) GetTracerCollection

func (ch *IGContainerWatcher) GetTracerCollection() *tracercollection.TracerCollection

func (*IGContainerWatcher) Ready

func (ch *IGContainerWatcher) Ready() bool

func (*IGContainerWatcher) RegisterContainerReceiver

func (ch *IGContainerWatcher) RegisterContainerReceiver(receiver containerwatcher.ContainerReceiver)

func (*IGContainerWatcher) RegisterCustomTracer

func (ch *IGContainerWatcher) RegisterCustomTracer(tracer containerwatcher.CustomTracer) error

func (*IGContainerWatcher) Start

func (ch *IGContainerWatcher) Start(ctx context.Context) error

func (*IGContainerWatcher) Stop

func (ch *IGContainerWatcher) Stop()

func (*IGContainerWatcher) UnregisterContainerReceiver

func (ch *IGContainerWatcher) UnregisterContainerReceiver(receiver containerwatcher.ContainerReceiver)

func (*IGContainerWatcher) UnregisterCustomTracer

func (ch *IGContainerWatcher) UnregisterCustomTracer(tracer containerwatcher.CustomTracer) error

type IGK8sClient

type IGK8sClient interface {
	GetNonRunningContainers(pod *corev1.Pod) []string
	GetRunningContainers(pod *corev1.Pod) []containercollection.Container
	ListContainers() (arr []containercollection.Container, err error)
}

type IGK8sClientMock

type IGK8sClientMock struct {
}

func NewIGK8sClientMock

func NewIGK8sClientMock() *IGK8sClientMock

func (*IGK8sClientMock) GetNonRunningContainers

func (k *IGK8sClientMock) GetNonRunningContainers(pod *corev1.Pod) []string

GetNonRunningContainers returns the list of containers IDs that are not running.

func (*IGK8sClientMock) GetRunningContainers

func (k *IGK8sClientMock) GetRunningContainers(pod *corev1.Pod) []containercollection.Container

GetRunningContainers returns a list of the containers of a given Pod that are running.

func (*IGK8sClientMock) ListContainers

func (k *IGK8sClientMock) ListContainers() (arr []containercollection.Container, err error)

ListContainers return a list of the current containers that are running in the node.