runner

Documentation

Index

• func GetCheckStats() map[check.ID]*check.Stats
• type Runner
  • func NewRunner(numWorkers int) *Runner
  • func (r *Runner) GetChan() chan<- check.Check
  • func (r *Runner) Stop()
  • func (r *Runner) StopCheck(id check.ID) error

Functions

func GetCheckStats

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

GetCheckStats returns the check stats map

Types

type Runner

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

Runner ...

func NewRunner

func NewRunner(numWorkers int) *Runner

NewRunner takes the number of desired goroutines processing incoming checks.

func (*Runner) GetChan

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

GetChan returns a write-only version of the pending channel

func (*Runner) Stop

func (r *Runner) Stop()

Stop closes the pending channel so all workers will exit their loop and terminate

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