runner

Documentation

Index

• Variables
• func GetCheckStats() map[string]map[check.ID]*check.Stats
• func RemoveCheckStats(checkID check.ID)
• type Runner
  • func NewRunner() *Runner
  • func (r *Runner) AddWorker()
  • func (r *Runner) GetChan() chan<- check.Check
  • func (r *Runner) SetScheduler(s *scheduler.Scheduler)
  • func (r *Runner) Stop()
  • func (r *Runner) StopCheck(id check.ID) error
  • func (r *Runner) UpdateNumWorkers(numChecks int64)

Variables

var (
	// TestWg is used for testing the number of check workers
	TestWg sync.WaitGroup
)

Functions

func GetCheckStats

func GetCheckStats() map[string]map[check.ID]*check.Stats

GetCheckStats returns the check stats map

func RemoveCheckStats

func RemoveCheckStats(checkID check.ID)

RemoveCheckStats removes a check from the check stats map

Types

type Runner

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

Runner ...

func NewRunner

func NewRunner() *Runner

NewRunner takes the number of desired goroutines processing incoming checks.

func (*Runner) AddWorker

func (r *Runner) AddWorker()

AddWorker adds a new worker to the worker pull

func (*Runner) GetChan

func (r *Runner) GetChan() chan<- check.Check

GetChan returns a write-only version of the pending channel

func (*Runner) SetScheduler

func (r *Runner) SetScheduler(s *scheduler.Scheduler)

SetScheduler sets the scheduler for the runner

func (*Runner) Stop

func (r *Runner) Stop()

Stop closes the pending channel so all workers will exit their loop and terminate All publishers to the pending channel need to have stopped before Stop is called

func (*Runner) StopCheck

func (r *Runner) StopCheck(id check.ID) error

StopCheck invokes the `Stop` method on a check if it's running. If the check is not running, this is a noop

func (*Runner) UpdateNumWorkers

func (r *Runner) UpdateNumWorkers(numChecks int64)

UpdateNumWorkers checks if the current number of workers is reasonable, and adds more if needed