middleware

Documentation

Index

• type CheckWrapper
  • func NewCheckWrapper(inner check.Check, senderManager sender.SenderManager) *CheckWrapper
  • func (c *CheckWrapper) Cancel()
  • func (c *CheckWrapper) ConfigSource() string
  • func (c *CheckWrapper) Configure(senderManager sender.SenderManager, integrationConfigDigest uint64, ...) error
  • func (c *CheckWrapper) GetDiagnoses() ([]diagnosis.Diagnosis, error)
  • func (c *CheckWrapper) GetSenderStats() (stats.SenderStats, error)
  • func (c *CheckWrapper) GetWarnings() []error
  • func (c *CheckWrapper) ID() checkid.ID
  • func (c *CheckWrapper) InitConfig() string
  • func (c *CheckWrapper) InstanceConfig() string
  • func (c *CheckWrapper) Interval() time.Duration
  • func (c *CheckWrapper) IsTelemetryEnabled() bool
  • func (c *CheckWrapper) Run() error
  • func (c *CheckWrapper) Stop()
  • func (c *CheckWrapper) String() string
  • func (c *CheckWrapper) Version() string

Types

type CheckWrapper

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

CheckWrapper cleans up the check sender after a check was descheduled, taking care that Run is not executing during or after that.

func NewCheckWrapper

func NewCheckWrapper(inner check.Check, senderManager sender.SenderManager) *CheckWrapper

NewCheckWrapper returns a wrapped check.

func (*CheckWrapper) Cancel

func (c *CheckWrapper) Cancel()

Cancel implements Check#Cancel

func (*CheckWrapper) ConfigSource

func (c *CheckWrapper) ConfigSource() string

ConfigSource implements Check#ConfigSource

func (*CheckWrapper) Configure

func (c *CheckWrapper) Configure(senderManager sender.SenderManager, integrationConfigDigest uint64, config, initConfig integration.Data, source string) error

Configure implements Check#Configure

func (*CheckWrapper) GetDiagnoses

func (c *CheckWrapper) GetDiagnoses() ([]diagnosis.Diagnosis, error)

GetDiagnoses returns the diagnoses cached in last run or diagnose explicitly

func (*CheckWrapper) GetSenderStats

func (c *CheckWrapper) GetSenderStats() (stats.SenderStats, error)

GetSenderStats implements Check#GetSenderStats

func (*CheckWrapper) GetWarnings

func (c *CheckWrapper) GetWarnings() []error

GetWarnings implements Check#GetWarnings

func (*CheckWrapper) ID

func (c *CheckWrapper) ID() checkid.ID

ID implements Check#ID

func (*CheckWrapper) InitConfig

func (c *CheckWrapper) InitConfig() string

InitConfig implements Check#InitConfig

func (*CheckWrapper) InstanceConfig

func (c *CheckWrapper) InstanceConfig() string

InstanceConfig implements Check#InstanceConfig

func (*CheckWrapper) Interval

func (c *CheckWrapper) Interval() time.Duration

Interval implements Check#Interval

func (*CheckWrapper) IsTelemetryEnabled

func (c *CheckWrapper) IsTelemetryEnabled() bool

IsTelemetryEnabled implements Check#IsTelemetryEnabled

func (*CheckWrapper) Run

func (c *CheckWrapper) Run() error

Run implements Check#Run

func (*CheckWrapper) Stop

func (c *CheckWrapper) Stop()

Stop implements Check#Stop

func (*CheckWrapper) String

func (c *CheckWrapper) String() string

String implements Check#String

func (*CheckWrapper) Version

func (c *CheckWrapper) Version() string

Version implements Check#Version