containerwatcher

Documentation

Index

• type ContainerReceiver
• type ContainerWatcher
• type ContainerWatcherMock
  • func (c ContainerWatcherMock) GetContainerCollection() *containercollection.ContainerCollection
  • func (c ContainerWatcherMock) GetContainerSelector() *containercollection.ContainerSelector
  • func (c ContainerWatcherMock) GetSocketEnricher() *socketenricher.SocketEnricher
  • func (c ContainerWatcherMock) GetTracerCollection() *tracercollection.TracerCollection
  • func (c ContainerWatcherMock) Ready() bool
  • func (c ContainerWatcherMock) RegisterContainerReceiver(_ ContainerReceiver)
  • func (c ContainerWatcherMock) RegisterCustomTracer(_ CustomTracer) error
  • func (c ContainerWatcherMock) Start(_ context.Context) error
  • func (c ContainerWatcherMock) Stop()
  • func (c ContainerWatcherMock) UnregisterContainerReceiver(_ ContainerReceiver)
  • func (c ContainerWatcherMock) UnregisterCustomTracer(_ CustomTracer) error
• type CustomTracer
• type CustomTracerMock
  • func (c CustomTracerMock) Name() string
  • func (c CustomTracerMock) Start() error
  • func (c CustomTracerMock) Stop() error
• type EventReceiver
• type ResultCallback
• type TaskBasedEnricher

Types

type ContainerReceiver

type ContainerReceiver interface {
	ContainerCallback(notif containercollection.PubSubEvent)
}

type ContainerWatcher

type ContainerWatcher interface {
	Ready() bool
	Start(ctx context.Context) error
	Stop()
	GetTracerCollection() *tracercollection.TracerCollection
	GetContainerCollection() *containercollection.ContainerCollection
	GetSocketEnricher() *socketenricher.SocketEnricher
	GetContainerSelector() *containercollection.ContainerSelector
	RegisterCustomTracer(tracer CustomTracer) error
	UnregisterCustomTracer(tracer CustomTracer) error
	RegisterContainerReceiver(receiver ContainerReceiver)
	UnregisterContainerReceiver(receiver ContainerReceiver)
}

type ContainerWatcherMock

type ContainerWatcherMock struct{}

func (ContainerWatcherMock) GetContainerCollection

func (c ContainerWatcherMock) GetContainerCollection() *containercollection.ContainerCollection

func (ContainerWatcherMock) GetContainerSelector

func (c ContainerWatcherMock) GetContainerSelector() *containercollection.ContainerSelector

func (ContainerWatcherMock) GetSocketEnricher

func (c ContainerWatcherMock) GetSocketEnricher() *socketenricher.SocketEnricher

func (ContainerWatcherMock) GetTracerCollection

func (c ContainerWatcherMock) GetTracerCollection() *tracercollection.TracerCollection

func (ContainerWatcherMock) Ready

func (c ContainerWatcherMock) Ready() bool

func (ContainerWatcherMock) RegisterContainerReceiver

func (c ContainerWatcherMock) RegisterContainerReceiver(_ ContainerReceiver)

func (ContainerWatcherMock) RegisterCustomTracer

func (c ContainerWatcherMock) RegisterCustomTracer(_ CustomTracer) error

func (ContainerWatcherMock) Start

func (c ContainerWatcherMock) Start(_ context.Context) error

func (ContainerWatcherMock) Stop

func (c ContainerWatcherMock) Stop()

func (ContainerWatcherMock) UnregisterContainerReceiver

func (c ContainerWatcherMock) UnregisterContainerReceiver(_ ContainerReceiver)

func (ContainerWatcherMock) UnregisterCustomTracer

func (c ContainerWatcherMock) UnregisterCustomTracer(_ CustomTracer) error

type CustomTracer

type CustomTracer interface {
	Start() error
	Stop() error
	Name() string
}

type CustomTracerMock

type CustomTracerMock struct{}

func (CustomTracerMock) Name

func (c CustomTracerMock) Name() string

func (CustomTracerMock) Start

func (c CustomTracerMock) Start() error

func (CustomTracerMock) Stop

func (c CustomTracerMock) Stop() error

type EventReceiver

type EventReceiver interface {
	ReportEvent(eventType utils.EventType, event utils.K8sEvent)
}

type ResultCallback

type ResultCallback func(utils.EnrichEvent)

type TaskBasedEnricher

type TaskBasedEnricher interface {
	SubmitEnrichmentTask(event utils.EnrichEvent, syscalls []uint64, callback ResultCallback)
}