eventmonitor

Documentation

Overview

Package eventmonitor holds eventmonitor related files

Package eventmonitor holds eventmonitor related files

Index

• type EventConsumer
• type EventConsumerInterface
• type EventConsumerPostProbeStartHandler
• type EventMonitor
  • func NewEventMonitor(config *config.Config, secconfig *secconfig.Config, opts Opts, ...) (*EventMonitor, error)
  • func (m *EventMonitor) AddEventConsumer(consumer EventConsumer) 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 EventConsumerInterface)
  • func (m *EventMonitor) SendStats()
  • func (m *EventMonitor) Start() error
• type Opts

Types

type EventConsumer

type EventConsumer interface {
	probe.EventConsumerInterface
}

EventConsumer event consumer

type EventConsumerInterface

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

EventConsumerInterface 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 workloadmeta.Component, telemetry telemetry.Component) (*EventMonitor, error)

NewEventMonitor instantiates an event monitoring system-probe module

func (*EventMonitor) AddEventConsumer

func (m *EventMonitor) AddEventConsumer(consumer EventConsumer) error

AddEventConsumer 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 EventConsumerInterface)

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 Opts

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

Opts defines options that can be used for the eventmonitor