runner

Documentation

Index

• type CheckRunner
  • func NewRunner(config ddconfig.Reader, sysCfg *sysconfigtypes.Config, ...) (*CheckRunner, error)
  • func NewRunnerWithChecks(config ddconfig.Reader, sysProbeCfg *checks.SysProbeConfig, ...) (*CheckRunner, error)
  • func (l *CheckRunner) GetChecks() []checks.Check
  • func (l *CheckRunner) IsRealTimeEnabled() bool
  • func (l *CheckRunner) Run() error
  • func (l *CheckRunner) RunRealTime() bool
  • func (l *CheckRunner) Stop()
  • func (l *CheckRunner) UpdateRTStatus(statuses []*model.CollectorStatus)
• type CheckSubmitter
  • func NewSubmitter(config config.Component, log log.Component, forwarders forwarders.Component, ...) (*CheckSubmitter, error)
  • func (s *CheckSubmitter) GetRTNotifierChan() <-chan types.RTResponse
  • func (s *CheckSubmitter) Start() error
  • func (s *CheckSubmitter) Stop()
  • func (s *CheckSubmitter) Submit(start time.Time, name string, messages *types.Payload)
• type Runner
• type Submitter

Types

type CheckRunner

type CheckRunner struct {

	// Submits check payloads to datadog
	Submitter Submitter
	// contains filtered or unexported fields
}

CheckRunner will collect metrics from the local system and ship to the backend.

func NewRunner

func NewRunner(
	config ddconfig.Reader,
	sysCfg *sysconfigtypes.Config,
	hostInfo *checks.HostInfo,
	enabledChecks []checks.Check,
	rtNotifierChan <-chan types.RTResponse,
) (*CheckRunner, error)

NewRunner creates a new CheckRunner

func NewRunnerWithChecks

func NewRunnerWithChecks(
	config ddconfig.Reader,
	sysProbeCfg *checks.SysProbeConfig,
	hostInfo *checks.HostInfo,
	checks []checks.Check,
	runRealTime bool,
	rtNotifierChan <-chan types.RTResponse,
) (*CheckRunner, error)

NewRunnerWithChecks creates a new CheckRunner

func (*CheckRunner) GetChecks

func (l *CheckRunner) GetChecks() []checks.Check

func (*CheckRunner) IsRealTimeEnabled

func (l *CheckRunner) IsRealTimeEnabled() bool

func (*CheckRunner) Run

func (l *CheckRunner) Run() error

func (*CheckRunner) RunRealTime

func (l *CheckRunner) RunRealTime() bool

func (*CheckRunner) Stop

func (l *CheckRunner) Stop()

func (*CheckRunner) UpdateRTStatus

func (l *CheckRunner) UpdateRTStatus(statuses []*model.CollectorStatus)

type CheckSubmitter

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

func NewSubmitter

func NewSubmitter(config config.Component, log log.Component, forwarders forwarders.Component, hostname string) (*CheckSubmitter, error)

func (*CheckSubmitter) GetRTNotifierChan

func (s *CheckSubmitter) GetRTNotifierChan() <-chan types.RTResponse

func (*CheckSubmitter) Start

func (s *CheckSubmitter) Start() error

func (*CheckSubmitter) Stop

func (s *CheckSubmitter) Stop()

func (*CheckSubmitter) Submit

func (s *CheckSubmitter) Submit(start time.Time, name string, messages *types.Payload)

type Runner

type Runner interface{}

type Submitter

type Submitter interface {
	Submit(start time.Time, name string, messages *types.Payload)
}