applicationprofilemanager

Documentation

Index

• func CalculateHTTPEndpointHash(endpoint *v1beta1.HTTPEndpoint) string
• func GetEndpointIdentifier(request *tracerhttptype.Event) (string, error)
• func GetInitOperations(containerType string, containerIndex int) []utils.PatchOperation
• func GetNewEndpoint(event *tracerhttptype.Event, identifier string) (*v1beta1.HTTPEndpoint, error)
• func IsPolicyIncluded(existingPolicy, newPolicy *v1beta1.RulePolicy) bool
• type ApplicationProfileManager
  • func CreateApplicationProfileManager(ctx context.Context, cfg config.Config, clusterName string, ...) (*ApplicationProfileManager, error)
  • func (am *ApplicationProfileManager) ContainerCallback(notif containercollection.PubSubEvent)
  • func (am *ApplicationProfileManager) ContainerReachedMaxTime(containerID string)
  • func (am *ApplicationProfileManager) RegisterPeekFunc(peek func(mntns uint64) ([]string, error))
  • func (am *ApplicationProfileManager) ReportCapability(k8sContainerID, capability string)
  • func (am *ApplicationProfileManager) ReportDroppedEvent(k8sContainerID string)
  • func (am *ApplicationProfileManager) ReportFileExec(k8sContainerID, path string, args []string)
  • func (am *ApplicationProfileManager) ReportFileOpen(k8sContainerID, path string, flags []string)
  • func (am *ApplicationProfileManager) ReportHTTPEvent(k8sContainerID string, event *tracerhttptype.Event)
  • func (am *ApplicationProfileManager) ReportRulePolicy(k8sContainerID, ruleId, allowedProcess string, allowedContainer bool)

Functions

func CalculateHTTPEndpointHash

func CalculateHTTPEndpointHash(endpoint *v1beta1.HTTPEndpoint) string

func GetEndpointIdentifier

func GetEndpointIdentifier(request *tracerhttptype.Event) (string, error)

func GetInitOperations

func GetInitOperations(containerType string, containerIndex int) []utils.PatchOperation

func GetNewEndpoint

func GetNewEndpoint(event *tracerhttptype.Event, identifier string) (*v1beta1.HTTPEndpoint, error)

func IsPolicyIncluded

func IsPolicyIncluded(existingPolicy, newPolicy *v1beta1.RulePolicy) bool

Types

type ApplicationProfileManager

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

func CreateApplicationProfileManager

func CreateApplicationProfileManager(ctx context.Context, cfg config.Config, clusterName string, k8sClient k8sclient.K8sClientInterface, storageClient storage.StorageClient, preRunningContainerIDs mapset.Set[string], k8sObjectCache objectcache.K8sObjectCache, seccompManager seccompmanager.SeccompManagerClient) (*ApplicationProfileManager, error)

func (*ApplicationProfileManager) ContainerCallback

func (am *ApplicationProfileManager) ContainerCallback(notif containercollection.PubSubEvent)

func (*ApplicationProfileManager) ContainerReachedMaxTime

func (am *ApplicationProfileManager) ContainerReachedMaxTime(containerID string)

func (*ApplicationProfileManager) RegisterPeekFunc

func (am *ApplicationProfileManager) RegisterPeekFunc(peek func(mntns uint64) ([]string, error))

func (*ApplicationProfileManager) ReportCapability

func (am *ApplicationProfileManager) ReportCapability(k8sContainerID, capability string)

func (*ApplicationProfileManager) ReportDroppedEvent

func (am *ApplicationProfileManager) ReportDroppedEvent(k8sContainerID string)

func (*ApplicationProfileManager) ReportFileExec

func (am *ApplicationProfileManager) ReportFileExec(k8sContainerID, path string, args []string)

func (*ApplicationProfileManager) ReportFileOpen

func (am *ApplicationProfileManager) ReportFileOpen(k8sContainerID, path string, flags []string)

func (*ApplicationProfileManager) ReportHTTPEvent

func (am *ApplicationProfileManager) ReportHTTPEvent(k8sContainerID string, event *tracerhttptype.Event)

func (*ApplicationProfileManager) ReportRulePolicy

func (am *ApplicationProfileManager) ReportRulePolicy(k8sContainerID, ruleId, allowedProcess string, allowedContainer bool)