cpudetector

Documentation

Index

• Constants
• func NewCpuDetector(cfg any, consumers []consumer.Consumer) detector.Detector
• type Config
  • func NewConfig() *Config
• type CpuDetector
  • func (c *CpuDetector) ConsumeChanEvents()
  • func (c *CpuDetector) ConsumeCommEvent(e *model.SpyEvent) error
  • func (c *CpuDetector) ConsumeEvent(e *model.SpyEvent) error
  • func (c *CpuDetector) Init(cfg any) error
  • func (c *CpuDetector) Name() string
  • func (c *CpuDetector) OwnedEvents() []string
  • func (c *CpuDetector) ProcessEvent(e *model.SpyEvent) error
  • func (c *CpuDetector) Start() error
  • func (c *CpuDetector) Stop() error
  • func (c *CpuDetector) UploadTries(endTimeTruncated time.Time)
  • func (c *CpuDetector) UploadWithTicker()
• type SubSession

Constants

const (
	DetectorCpuType string = "detector_cpu"
)

Functions

func NewCpuDetector

func NewCpuDetector(cfg any, consumers []consumer.Consumer) detector.Detector

Types

type Config

type Config struct {
	EventName     string
	SessionInfos  []SubSession `mapstructure:"sessioninfo"`
	EventChanSize int
	SegmentSize   int `mapstrucrure:"segmentSize"`
}

func NewConfig

func NewConfig() *Config

type CpuDetector

type CpuDetector struct {
	Server string
	// contains filtered or unexported fields
}

func (*CpuDetector) ConsumeChanEvents

func (c *CpuDetector) ConsumeChanEvents()

func (*CpuDetector) ConsumeCommEvent

func (c *CpuDetector) ConsumeCommEvent(e *model.SpyEvent) error

func (*CpuDetector) ConsumeEvent

func (c *CpuDetector) ConsumeEvent(e *model.SpyEvent) error

called by receiver

func (*CpuDetector) Init

func (c *CpuDetector) Init(cfg any) error

all cpu tool config will init here, config.ONCPU, config.ONCPU, config.FutexSnoop, etc

func (*CpuDetector) Name

func (c *CpuDetector) Name() string

func (*CpuDetector) OwnedEvents

func (c *CpuDetector) OwnedEvents() []string

Notice: hard code, new tool added update this function

func (*CpuDetector) ProcessEvent

func (c *CpuDetector) ProcessEvent(e *model.SpyEvent) error

send to next consumer

func (*CpuDetector) Start

func (c *CpuDetector) Start() error

func (*CpuDetector) Stop

func (c *CpuDetector) Stop() error

func (*CpuDetector) UploadTries

func (c *CpuDetector) UploadTries(endTimeTruncated time.Time)

func (*CpuDetector) UploadWithTicker

func (c *CpuDetector) UploadWithTicker()

type SubSession

type SubSession struct {
	Class  string            `mapstructure:"class"`
	Name   string            `mapstructure:"name"`
	Params map[string]string `mapstructure:"params"`
}