trigger

Documentation

Index

• func NewNetworkTrigger() base.Trigger
• func NewOffCPUTrigger() base.Trigger
• func NewOnCPUTrigger() base.Trigger
• type BaseTrigger
  • func NewMultipleProcessBasedTrigger(conf *base.ContinuousConfig, ...) *BaseTrigger
  • func NewSingleProcessBaseTrigger(conf *base.ContinuousConfig, ...) *BaseTrigger
  • func (c *BaseTrigger) Init(conf *base.ContinuousConfig) error
  • func (c *BaseTrigger) ShouldTrigger(p api.ProcessInterface) bool
  • func (c *BaseTrigger) TriggerTasks(reporter base.TriggerReporter, causes []base.ThresholdCause) int
• type NetworkTrigger
  • func (n *NetworkTrigger) Init(moduleMgr *module.Manager, conf *base.ContinuousConfig) error
• type OffCPUTrigger
  • func (o *OffCPUTrigger) Init(moduleMgr *module.Manager, conf *base.ContinuousConfig) error
• type OnCPUTrigger
  • func (c *OnCPUTrigger) Init(moduleMgr *module.Manager, conf *base.ContinuousConfig) error

Functions

func NewNetworkTrigger

func NewNetworkTrigger() base.Trigger

func NewOffCPUTrigger

func NewOffCPUTrigger() base.Trigger

func NewOnCPUTrigger

func NewOnCPUTrigger() base.Trigger

Types

type BaseTrigger

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

func NewMultipleProcessBasedTrigger

func NewMultipleProcessBasedTrigger(conf *base.ContinuousConfig,
	profilingTaskDimension func(p api.ProcessInterface) string,
	mainProcessSelector func(ps []api.ProcessInterface) api.ProcessInterface,
	taskSetter func(task *taskBase.ProfilingTask, processes []api.ProcessInterface, thresholds []base.ThresholdCause),
	reportSetter func(report *v3.ContinuousProfilingReport, processes []api.ProcessInterface, thresholds []base.ThresholdCause)) *BaseTrigger

func NewSingleProcessBaseTrigger

func NewSingleProcessBaseTrigger(conf *base.ContinuousConfig,
	taskSetter func(task *taskBase.ProfilingTask, processes []api.ProcessInterface, thresholds []base.ThresholdCause),
	reportSetter func(report *v3.ContinuousProfilingReport, processes []api.ProcessInterface, thresholds []base.ThresholdCause)) *BaseTrigger

func (*BaseTrigger) Init

func (c *BaseTrigger) Init(conf *base.ContinuousConfig) error

func (*BaseTrigger) ShouldTrigger

func (c *BaseTrigger) ShouldTrigger(p api.ProcessInterface) bool

func (*BaseTrigger) TriggerTasks

func (c *BaseTrigger) TriggerTasks(reporter base.TriggerReporter, causes []base.ThresholdCause) int

type NetworkTrigger

type NetworkTrigger struct {
	*BaseTrigger
}

func (*NetworkTrigger) Init

func (n *NetworkTrigger) Init(moduleMgr *module.Manager, conf *base.ContinuousConfig) error

type OffCPUTrigger

type OffCPUTrigger struct {
	*BaseTrigger
}

func (*OffCPUTrigger) Init

func (o *OffCPUTrigger) Init(moduleMgr *module.Manager, conf *base.ContinuousConfig) error

type OnCPUTrigger

type OnCPUTrigger struct {
	*BaseTrigger
}

func (*OnCPUTrigger) Init

func (c *OnCPUTrigger) Init(moduleMgr *module.Manager, conf *base.ContinuousConfig) error