rulemanager

Documentation

Index

• type RuleManager
  • func CreateRuleManager(ctx context.Context, cfg config.Config, k8sClient k8sclient.K8sClientInterface, ...) (*RuleManager, error)
  • func (rm *RuleManager) ContainerCallback(notif containercollection.PubSubEvent)
  • func (rm *RuleManager) EvaluateRulesForEvent(eventType utils.EventType, event utils.K8sEvent) []string
  • func (rm *RuleManager) HasApplicableRuleBindings(namespace, name string) bool
  • func (rm *RuleManager) HasFinalApplicationProfile(pod *corev1.Pod) bool
  • func (rm *RuleManager) IsContainerMonitored(k8sContainerID string) bool
  • func (rm *RuleManager) IsPodMonitored(namespace, pod string) bool
  • func (rm *RuleManager) RegisterPeekFunc(peek func(mntns uint64) ([]string, error))
  • func (rm *RuleManager) ReportEvent(eventType utils.EventType, event utils.K8sEvent)

Types

type RuleManager

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

func CreateRuleManager

func CreateRuleManager(ctx context.Context, cfg config.Config, k8sClient k8sclient.K8sClientInterface, ruleBindingCache bindingcache.RuleBindingCache, objectCache objectcache.ObjectCache, exporter exporters.Exporter, metrics metricsmanager.MetricsManager, nodeName string, clusterName string, processManager processmanager.ProcessManagerClient, dnsManager dnsmanager.DNSResolver, enricher ruleenginetypes.Enricher) (*RuleManager, error)

func (*RuleManager) ContainerCallback

func (rm *RuleManager) ContainerCallback(notif containercollection.PubSubEvent)

func (*RuleManager) EvaluateRulesForEvent

func (rm *RuleManager) EvaluateRulesForEvent(eventType utils.EventType, event utils.K8sEvent) []string

func (*RuleManager) HasApplicableRuleBindings

func (rm *RuleManager) HasApplicableRuleBindings(namespace, name string) bool

func (*RuleManager) HasFinalApplicationProfile

func (rm *RuleManager) HasFinalApplicationProfile(pod *corev1.Pod) bool

func (*RuleManager) IsContainerMonitored

func (rm *RuleManager) IsContainerMonitored(k8sContainerID string) bool

func (*RuleManager) IsPodMonitored

func (rm *RuleManager) IsPodMonitored(namespace, pod string) bool

func (*RuleManager) RegisterPeekFunc

func (rm *RuleManager) RegisterPeekFunc(peek func(mntns uint64) ([]string, error))

func (*RuleManager) ReportEvent

func (rm *RuleManager) ReportEvent(eventType utils.EventType, event utils.K8sEvent)