eventmonitor

Documentation

Overview

Package eventmonitor holds eventmonitor related files

Index

• type EventConsumer
• type EventConsumerPostProbeStartHandler
• type EventMonitor
  • func NewEventMonitor(config *config.Config, secconfig *secconfig.Config, opts Opts, ...) (*EventMonitor, error)
  • func (m *EventMonitor) AddEventTypeHandler(eventType model.EventType, handler EventTypeHandler) error
  • func (m *EventMonitor) Close()
  • func (m *EventMonitor) GetStats() map[string]interface{}
  • func (m *EventMonitor) Init() error
  • func (m *EventMonitor) Register(_ *module.Router) error
  • func (m *EventMonitor) RegisterEventConsumer(consumer EventConsumer)
  • func (m *EventMonitor) SendStats()
  • func (m *EventMonitor) Start() error
• type EventTypeHandler
• type Opts

Types

type EventConsumer

type EventConsumer interface {
	// ID returns the ID of the event consumer
	ID() string
	// Start starts the event consumer
	Start() error
	// Stop stops the event consumer
	Stop()
}

EventConsumer defines an event consumer

type EventConsumerPostProbeStartHandler

type EventConsumerPostProbeStartHandler interface {
	// PostProbeStart is called after the event stream (the probe) is started
	PostProbeStart() error
}

EventConsumerPostProbeStartHandler defines an event consumer that can respond to PostProbeStart events

type EventMonitor

type EventMonitor struct {
	sync.RWMutex
	Probe *probe.Probe

	Config       *config.Config
	StatsdClient statsd.ClientInterface
	GRPCServer   *grpc.Server
	// contains filtered or unexported fields
}

EventMonitor represents the system-probe module for kernel event monitoring

func NewEventMonitor

func NewEventMonitor(config *config.Config, secconfig *secconfig.Config, opts Opts, wmeta optional.Option[workloadmeta.Component]) (*EventMonitor, error)

NewEventMonitor instantiates an event monitoring system-probe module

func (*EventMonitor) AddEventTypeHandler

func (m *EventMonitor) AddEventTypeHandler(eventType model.EventType, handler EventTypeHandler) error

AddEventTypeHandler registers an event handler

func (*EventMonitor) Close

func (m *EventMonitor) Close()

Close the module

func (*EventMonitor) GetStats

func (m *EventMonitor) GetStats() map[string]interface{}

GetStats returns statistics about the module

func (*EventMonitor) Init

func (m *EventMonitor) Init() error

Init initializes the module

func (*EventMonitor) Register

func (m *EventMonitor) Register(_ *module.Router) error

Register the event monitoring module

func (*EventMonitor) RegisterEventConsumer

func (m *EventMonitor) RegisterEventConsumer(consumer EventConsumer)

RegisterEventConsumer registers an event consumer

func (*EventMonitor) SendStats

func (m *EventMonitor) SendStats()

SendStats send stats

func (*EventMonitor) Start

func (m *EventMonitor) Start() error

Start the module

type EventTypeHandler

type EventTypeHandler interface {
	probe.EventHandler
}

EventTypeHandler event type based handler

type Opts

type Opts struct {
	ProbeOpts    probe.Opts
	StatsdClient statsd.ClientInterface
}

Opts defines options that can be used for the eventmonitor