Documentation
¶
Index ¶
- func GetNewRoot(ra *runnerArgs) *cobra.Command
- type InternalJob
- 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
- type RunnerConfig
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetNewRoot ¶
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
Source Files
Click to show internal directories.
Click to hide internal directories.