runner

package
v0.0.0-...-45a9bcf Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 3, 2024 License: Apache-2.0 Imports: 32 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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 pkgconfigmodel.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 pkgconfigmodel.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)
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL