cnimonitor

Documentation

Index

• func DockerCNIMetadataExtractor(event *rpcmonitor.EventInfo) (*policy.PURuntime, error)
• func KubernetesCNIMetadataExtractor(event *rpcmonitor.EventInfo) (*policy.PURuntime, error)
• type CNIMetadataExtractor
• type CniProcessor
  • func NewCniProcessor(collector collector.EventCollector, puHandler monitor.ProcessingUnitsHandler, ...) *CniProcessor
  • func (p *CniProcessor) Create(eventInfo *rpcmonitor.EventInfo) error
  • func (p *CniProcessor) Destroy(eventInfo *rpcmonitor.EventInfo) error
  • func (p *CniProcessor) Pause(eventInfo *rpcmonitor.EventInfo) error
  • func (p *CniProcessor) ReSync(e *rpcmonitor.EventInfo) error
  • func (p *CniProcessor) Start(eventInfo *rpcmonitor.EventInfo) error
  • func (p *CniProcessor) Stop(eventInfo *rpcmonitor.EventInfo) error

Functions

func DockerCNIMetadataExtractor

func DockerCNIMetadataExtractor(event *rpcmonitor.EventInfo) (*policy.PURuntime, error)

DockerCNIMetadataExtractor is a systemd based metadata extractor

func KubernetesCNIMetadataExtractor

func KubernetesCNIMetadataExtractor(event *rpcmonitor.EventInfo) (*policy.PURuntime, error)

KubernetesCNIMetadataExtractor is a systemd based metadata extractor

Types

type CNIMetadataExtractor

type CNIMetadataExtractor func(event *rpcmonitor.EventInfo) (*policy.PURuntime, error)

A CNIMetadataExtractor is a function used to extract a *policy.PURuntime from an event generated by CNI

type CniProcessor

type CniProcessor struct {
	// contains filtered or unexported fields
}

CniProcessor captures all the monitor processor information It implements the MonitorProcessor interface of the rpc monitor

func NewCniProcessor

func NewCniProcessor(collector collector.EventCollector, puHandler monitor.ProcessingUnitsHandler, metadataExtractor rpcmonitor.RPCMetadataExtractor) *CniProcessor

NewCniProcessor initializes a processor

func (*CniProcessor) Create

func (p *CniProcessor) Create(eventInfo *rpcmonitor.EventInfo) error

Create handles create events

func (*CniProcessor) Destroy

func (p *CniProcessor) Destroy(eventInfo *rpcmonitor.EventInfo) error

Destroy handles a destroy event

func (*CniProcessor) Pause

func (p *CniProcessor) Pause(eventInfo *rpcmonitor.EventInfo) error

Pause handles a pause event

func (*CniProcessor) ReSync

func (p *CniProcessor) ReSync(e *rpcmonitor.EventInfo) error

ReSync resyncs with all the existing services that were there before we start

func (*CniProcessor) Start

func (p *CniProcessor) Start(eventInfo *rpcmonitor.EventInfo) error

Start handles start events

func (*CniProcessor) Stop

func (p *CniProcessor) Stop(eventInfo *rpcmonitor.EventInfo) error

Stop handles a stop event