runners

Documentation

Index

• func GetNewRoot(ra *runnerArgs) *cobra.Command
• type InternalJob
  • func NewInternalJob(runner Runner, peerNodeCount int) *InternalJob
  • func Parse(clusterCfg config.ClusterConfig, config RunnerConfig, args []string, ...) (*InternalJob, error)
  • func (j *InternalJob) Config() RunnerConfig
  • func (j *InternalJob) Description() string
  • func (j *InternalJob) DestHosts() []string
  • func (j *InternalJob) GetLastRun() *time.Time
  • func (j *InternalJob) JobID() string
  • func (j *InternalJob) PeerNodeCount() int
  • func (j *InternalJob) Period() time.Duration
  • func (j *InternalJob) SetLastRun(lastRun *time.Time)
  • func (j *InternalJob) Tick(nodeName string, ch chan<- *nwpd.Observation) error
• type Runner
  • func NewCheckHTTPSGet(endpoints []config.Endpoint, rconfig RunnerConfig) Runner
  • func NewCheckTCPPort(endpoints []config.Endpoint, rconfig RunnerConfig) Runner
  • func NewNSLookup(names []string, rconfig RunnerConfig) Runner
  • func NewPingHost(nodes []config.Node, rconfig RunnerConfig) Runner
• type RunnerConfig

Functions

func GetNewRoot

func GetNewRoot(ra *runnerArgs) *cobra.Command

Types

type InternalJob

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

func NewInternalJob

func NewInternalJob(runner Runner, peerNodeCount int) *InternalJob

func Parse

func Parse(clusterCfg config.ClusterConfig, config RunnerConfig, args []string, sampleCfg *config.SampleConfig) (*InternalJob, error)

func (*InternalJob) Config

func (j *InternalJob) Config() RunnerConfig

func (*InternalJob) Description

func (j *InternalJob) Description() string

func (*InternalJob) DestHosts

func (j *InternalJob) DestHosts() []string

func (*InternalJob) GetLastRun

func (j *InternalJob) GetLastRun() *time.Time

func (*InternalJob) JobID

func (j *InternalJob) JobID() string

func (*InternalJob) PeerNodeCount

func (j *InternalJob) PeerNodeCount() int

func (*InternalJob) Period

func (j *InternalJob) Period() time.Duration

func (*InternalJob) SetLastRun

func (j *InternalJob) SetLastRun(lastRun *time.Time)

func (*InternalJob) Tick

func (j *InternalJob) Tick(nodeName string, ch chan<- *nwpd.Observation) error

type Runner

type Runner interface {
	Run(nodeName string, ch chan<- *nwpd.Observation)
	Config() RunnerConfig
	Description() string
	TestData() any
	DestHosts() []string
}

func NewCheckHTTPSGet

func NewCheckHTTPSGet(endpoints []config.Endpoint, rconfig RunnerConfig) Runner

func NewCheckTCPPort

func NewCheckTCPPort(endpoints []config.Endpoint, rconfig RunnerConfig) Runner

func NewNSLookup

func NewNSLookup(names []string, rconfig RunnerConfig) Runner

func NewPingHost

func NewPingHost(nodes []config.Node, rconfig RunnerConfig) Runner

type RunnerConfig

type RunnerConfig struct {
	config.Job
	Period time.Duration
}