continuous

Documentation

Index

• type Checkers
  • func NewCheckers(ctx context.Context, moduleMgr *module.Manager, conf *base.ContinuousConfig, ...) (*Checkers, error)
  • func (c *Checkers) CheckProfilingPolicies() error
  • func (c *Checkers) ShouldCheck(p api.ProcessInterface, item *base.PolicyItem) bool
  • func (c *Checkers) Start()
  • func (c *Checkers) Stop() error
• type Manager
  • func NewManager(ctx context.Context, taskManager *task.Manager, moduleMgr *module.Manager, ...) (*Manager, error)
  • func (m *Manager) CheckPolicies() error
  • func (m *Manager) Shutdown() error
  • func (m *Manager) Start()
• type QueryPolicyUpdate
• type QueryPolicyUpdateItem
  • func (p *QueryPolicyUpdateItem) Validate() error
• type Triggers
  • func NewTriggers(ctx context.Context, moduleMgr *module.Manager, taskManager *task.Manager, ...) (*Triggers, error)
  • func (m *Triggers) ReportProcesses(process api.ProcessInterface, profilingProcesses []api.ProcessInterface, ...) (*task.Context, error)

Types

type Checkers

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

func NewCheckers

func NewCheckers(ctx context.Context, moduleMgr *module.Manager, conf *base.ContinuousConfig, triggers *Triggers) (*Checkers, error)

func (*Checkers) CheckProfilingPolicies

func (c *Checkers) CheckProfilingPolicies() error

func (*Checkers) ShouldCheck

func (c *Checkers) ShouldCheck(p api.ProcessInterface, item *base.PolicyItem) bool

func (*Checkers) Start

func (c *Checkers) Start()

func (*Checkers) Stop

func (c *Checkers) Stop() error

type Manager

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

func NewManager

func NewManager(ctx context.Context, taskManager *task.Manager, moduleMgr *module.Manager, config *base.ContinuousConfig) (*Manager, error)

func (*Manager) CheckPolicies

func (m *Manager) CheckPolicies() error

func (*Manager) Shutdown

func (m *Manager) Shutdown() error

func (*Manager) Start

func (m *Manager) Start()

type QueryPolicyUpdate

type QueryPolicyUpdate struct {
	ServiceName string `json:"ServiceName"`
	UUID        string `json:"UUID"`
	Profiling   map[base.TargetProfilingType]map[base.CheckType]*QueryPolicyUpdateItem
}

type QueryPolicyUpdateItem

type QueryPolicyUpdateItem struct {
	Threshold string   `json:"Threshold"`
	Period    int      `json:"Period"`
	Count     int      `json:"Count"`
	URIList   []string `json:"URIList"`
	URIRegex  string   `json:"URIRegex"`
}

func (*QueryPolicyUpdateItem) Validate

func (p *QueryPolicyUpdateItem) Validate() error

type Triggers

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

func NewTriggers

func NewTriggers(ctx context.Context, moduleMgr *module.Manager, taskManager *task.Manager, conf *base.ContinuousConfig) (*Triggers, error)

func (*Triggers) ReportProcesses

func (m *Triggers) ReportProcesses(process api.ProcessInterface, profilingProcesses []api.ProcessInterface, cases []base.ThresholdCause,
	taskSetter func(task *taskBase.ProfilingTask), reportSetter func(report *v3.ContinuousProfilingReport)) (*task.Context, error)