grpc

Documentation

Index

• type ProcessManager
  • func NewProcessManager(ctx context.Context, wg *sync.WaitGroup, ciliumState *cilium.State, ...) (*ProcessManager, error)
  • func (pm *ProcessManager) AddListener(listener server.Listener)
  • func (pm *ProcessManager) Close() error
  • func (pm *ProcessManager) Notify(event notify.Message) error
  • func (pm *ProcessManager) NotifyListener(original interface{}, processed *tetragon.GetEventsResponse)
  • func (pm *ProcessManager) RemoveListener(listener server.Listener)

Types

type ProcessManager

type ProcessManager struct {
	Server *server.Server
	// contains filtered or unexported fields
}

ProcessManager maintains a cache of processes from tetragon exec events.

func NewProcessManager

func NewProcessManager(
	ctx context.Context,
	wg *sync.WaitGroup,
	ciliumState *cilium.State,
	manager *sensors.Manager,
	hookRunner *rthooks.Runner,
) (*ProcessManager, error)

NewProcessManager returns a pointer to an initialized ProcessManager struct.

func (*ProcessManager) AddListener

func (pm *ProcessManager) AddListener(listener server.Listener)

func (*ProcessManager) Close

func (pm *ProcessManager) Close() error

Close implements Listener.Close.

func (*ProcessManager) Notify

func (pm *ProcessManager) Notify(event notify.Message) error

Notify implements Listener.Notify.

func (*ProcessManager) NotifyListener

func (pm *ProcessManager) NotifyListener(original interface{}, processed *tetragon.GetEventsResponse)

func (*ProcessManager) RemoveListener

func (pm *ProcessManager) RemoveListener(listener server.Listener)