Documentation
¶
Index ¶
- func GetRequiredEventsFromRules(rules []rule.Rule) []tracing.EventType
- type ClientSetInterface
- type Engine
- func (e *Engine) Delete()
- func (engine *Engine) GetApiServerIpAddress() (string, error)
- func (engine *Engine) GetPodSpec(podName, namespace, containerID string) (*corev1.PodSpec, error)
- func (engine *Engine) GetRulesForEvent(event *tracing.GeneralEvent) []rule.Rule
- func (engine *Engine) GetWorkloadOwnerKindAndName(event *tracing.GeneralEvent) (string, string, error)
- func (engine *Engine) IsContainerIDInCache(containerID string) bool
- func (engine *Engine) OnContainerActivityEvent(event *tracing.ContainerActivityEvent)
- func (engine *Engine) OnRuleBindingChanged(ruleBinding rulebindingstore.RuntimeAlertRuleBinding)
- func (engine *Engine) Poll()
- func (engine *Engine) ProcessEvent(eventType tracing.EventType, event interface{}, ...)
- func (engine *Engine) ReportError(eventType tracing.EventType, err error)
- func (engine *Engine) SendCapabilitiesEvent(event *tracing.CapabilitiesEvent)
- func (engine *Engine) SendDnsEvent(event *tracing.DnsEvent)
- func (engine *Engine) SendExecveEvent(event *tracing.ExecveEvent)
- func (engine *Engine) SendNetworkEvent(event *tracing.NetworkEvent)
- func (engine *Engine) SendOpenEvent(event *tracing.OpenEvent)
- func (engine *Engine) SendRandomXEvent(event *tracing.RandomXEvent)
- func (e *Engine) SetGetRulesForPodFunc(...)
- func (engine *Engine) StartPullComponent()
- func (engine *Engine) StopPullComponent()
- type EngineStatePrinter
- type EngineStats
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type ClientSetInterface ¶
type ClientSetInterface interface {
CoreV1() corev1.CoreV1Interface
Discovery() discovery.DiscoveryInterface
AppsV1() appsv1.AppsV1Interface
BatchV1() batchv1.BatchV1Interface
}
type Engine ¶
type Engine struct {
// contains filtered or unexported fields
}
func NewEngine ¶
func NewEngine(k8sClientset ClientSetInterface, appProfileCache approfilecache.ApplicationProfileCache, tracer *tracing.Tracer, exporter exporters.Exporter, workerPoolWidth int, nodeName string) *Engine
func (*Engine) GetApiServerIpAddress ¶ added in v0.0.5
func (*Engine) GetPodSpec ¶ added in v0.0.3
func (*Engine) GetRulesForEvent ¶
func (engine *Engine) GetRulesForEvent(event *tracing.GeneralEvent) []rule.Rule
func (*Engine) GetWorkloadOwnerKindAndName ¶
func (*Engine) IsContainerIDInCache ¶
func (*Engine) OnContainerActivityEvent ¶
func (engine *Engine) OnContainerActivityEvent(event *tracing.ContainerActivityEvent)
func (*Engine) OnRuleBindingChanged ¶
func (engine *Engine) OnRuleBindingChanged(ruleBinding rulebindingstore.RuntimeAlertRuleBinding)
func (*Engine) ProcessEvent ¶
func (engine *Engine) ProcessEvent(eventType tracing.EventType, event interface{}, appProfile approfilecache.SingleApplicationProfileAccess, boundRules []rule.Rule)
func (*Engine) ReportError ¶ added in v0.0.19
func (*Engine) SendCapabilitiesEvent ¶
func (engine *Engine) SendCapabilitiesEvent(event *tracing.CapabilitiesEvent)
func (*Engine) SendDnsEvent ¶
func (*Engine) SendExecveEvent ¶
func (engine *Engine) SendExecveEvent(event *tracing.ExecveEvent)
func (*Engine) SendNetworkEvent ¶
func (engine *Engine) SendNetworkEvent(event *tracing.NetworkEvent)
func (*Engine) SendOpenEvent ¶
func (*Engine) SendRandomXEvent ¶ added in v0.0.33
func (engine *Engine) SendRandomXEvent(event *tracing.RandomXEvent)
func (*Engine) SetGetRulesForPodFunc ¶
func (e *Engine) SetGetRulesForPodFunc(getRulesForPodFunc func(podName, namespace string) ([]rulebindingstore.RuntimeAlertRuleBindingRule, error))
func (*Engine) StartPullComponent ¶
func (engine *Engine) StartPullComponent()
Function to start pull componet from tracer
func (*Engine) StopPullComponent ¶
func (engine *Engine) StopPullComponent()
Function to stop pull componet from tracer
type EngineStatePrinter ¶
type EngineStatePrinter interface {
Print(v ...any)
}
type EngineStats ¶
type EngineStats struct {
// contains filtered or unexported fields
}
func CreateStatComponent ¶
func CreateStatComponent(printer EngineStatePrinter, collectionInterval time.Duration) *EngineStats
func (*EngineStats) DestroyStatComponent ¶
func (e *EngineStats) DestroyStatComponent()
func (*EngineStats) ReportEbpfEvent ¶
func (e *EngineStats) ReportEbpfEvent(eventType tracing.EventType)
func (*EngineStats) ReportRuleAlereted ¶
func (e *EngineStats) ReportRuleAlereted(ruleID string)
func (*EngineStats) ReportRuleProcessed ¶
func (e *EngineStats) ReportRuleProcessed(ruleID string)
func (*EngineStats) StatProcessing ¶
func (e *EngineStats) StatProcessing()
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.