consumer

Documentation

Index

• type ProcessConsumer
  • func NewProcessConsumer(evm *eventmonitor.EventMonitor) (*ProcessConsumer, error)
  • func (p *ProcessConsumer) ChanSize() int
  • func (p *ProcessConsumer) Copy(event *smodel.Event) any
  • func (p *ProcessConsumer) EventTypes() []smodel.EventType
  • func (p *ProcessConsumer) GetProcessEvents(params *api.GetProcessEventParams, ...) error
  • func (p *ProcessConsumer) HandleEvent(event any)
  • func (p *ProcessConsumer) ID() string
  • func (p *ProcessConsumer) SendStats()
  • func (p *ProcessConsumer) Start() error
  • func (p *ProcessConsumer) Stop()

Types

type ProcessConsumer

type ProcessConsumer struct {
	api.EventMonitoringModuleServer
	// contains filtered or unexported fields
}

ProcessConsumer is part of the event monitoring module of the system-probe. It receives events, batches them in the messages channel and serves the messages to the process-agent over GRPC when requested

func NewProcessConsumer

func NewProcessConsumer(evm *eventmonitor.EventMonitor) (*ProcessConsumer, error)

NewProcessConsumer returns a new ProcessConsumer instance

func (*ProcessConsumer) ChanSize

func (p *ProcessConsumer) ChanSize() int

ChanSize returns the chan size used by this consumer

func (*ProcessConsumer) Copy

func (p *ProcessConsumer) Copy(event *smodel.Event) any

func (*ProcessConsumer) EventTypes

func (p *ProcessConsumer) EventTypes() []smodel.EventType

EventTypes returns the event types handled by this consumer

func (*ProcessConsumer) GetProcessEvents

func (p *ProcessConsumer) GetProcessEvents(params *api.GetProcessEventParams, stream api.EventMonitoringModule_GetProcessEventsServer) error

GetProcessEvents sends process events through a gRPC stream

func (*ProcessConsumer) HandleEvent

func (p *ProcessConsumer) HandleEvent(event any)

HandleEvent implement the event monitor EventHandler interface

func (*ProcessConsumer) ID

func (p *ProcessConsumer) ID() string

ID returns id for process monitor

func (*ProcessConsumer) SendStats

func (p *ProcessConsumer) SendStats()

func (*ProcessConsumer) Start

func (p *ProcessConsumer) Start() error

func (*ProcessConsumer) Stop

func (p *ProcessConsumer) Stop()