linuxmonitor

Documentation

Index

• func ComputeMd5(filePath string) ([]byte, error)
• func DefaultHostMetadataExtractor(event *rpcmonitor.EventInfo) (*policy.PURuntime, error)
• func SystemdRPCMetadataExtractor(event *rpcmonitor.EventInfo) (*policy.PURuntime, error)
• type LinuxProcessor
  • func NewCustomLinuxProcessor(storePath string, collector collector.EventCollector, ...) *LinuxProcessor
  • func NewLinuxProcessor(collector collector.EventCollector, puHandler monitor.ProcessingUnitsHandler, ...) *LinuxProcessor
  • func (s *LinuxProcessor) Create(eventInfo *rpcmonitor.EventInfo) error
  • func (s *LinuxProcessor) Destroy(eventInfo *rpcmonitor.EventInfo) error
  • func (s *LinuxProcessor) Pause(eventInfo *rpcmonitor.EventInfo) error
  • func (s *LinuxProcessor) ReSync(e *rpcmonitor.EventInfo) error
  • func (s *LinuxProcessor) Start(eventInfo *rpcmonitor.EventInfo) error
  • func (s *LinuxProcessor) Stop(eventInfo *rpcmonitor.EventInfo) error

Functions

func ComputeMd5

func ComputeMd5(filePath string) ([]byte, error)

ComputeMd5 computes the Md5 of a file

func DefaultHostMetadataExtractor

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

DefaultHostMetadataExtractor is a host specific metadata extractor

func SystemdRPCMetadataExtractor

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

SystemdRPCMetadataExtractor is a systemd based metadata extractor

Types

type LinuxProcessor

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

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

func NewCustomLinuxProcessor

func NewCustomLinuxProcessor(storePath string, collector collector.EventCollector, puHandler monitor.ProcessingUnitsHandler, metadataExtractor rpcmonitor.RPCMetadataExtractor, releasePath string) *LinuxProcessor

NewCustomLinuxProcessor initializes a processor with a custom path

func NewLinuxProcessor

func NewLinuxProcessor(collector collector.EventCollector, puHandler monitor.ProcessingUnitsHandler, metadataExtractor rpcmonitor.RPCMetadataExtractor, releasePath string) *LinuxProcessor

NewLinuxProcessor creates a default Linux processor with the standard trireme path

func (*LinuxProcessor) Create

func (s *LinuxProcessor) Create(eventInfo *rpcmonitor.EventInfo) error

Create handles create events

func (*LinuxProcessor) Destroy

func (s *LinuxProcessor) Destroy(eventInfo *rpcmonitor.EventInfo) error

Destroy handles a destroy event

func (*LinuxProcessor) Pause

func (s *LinuxProcessor) Pause(eventInfo *rpcmonitor.EventInfo) error

Pause handles a pause event

func (*LinuxProcessor) ReSync

func (s *LinuxProcessor) ReSync(e *rpcmonitor.EventInfo) error

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

func (*LinuxProcessor) Start

func (s *LinuxProcessor) Start(eventInfo *rpcmonitor.EventInfo) error

Start handles start events

func (*LinuxProcessor) Stop

func (s *LinuxProcessor) Stop(eventInfo *rpcmonitor.EventInfo) error

Stop handles a stop event