kubernetes/pkg/util/async/runner.go

type Runner

// NewRunner makes a runner for the given function(s). The function(s) should loop until
// the channel is closed.
func NewRunner(f ...func(stop chan struct{}

// Start begins running.
func (r *Runner) Start() {}

// Stop stops running.
func (r *Runner) Stop() {}