consumer

package
v0.0.0-...-45a9bcf Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 3, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

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()

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL