package async

import "k8s.io/kubernetes/pkg/util/async"

Index ¶

• type Runner
• func NewRunner(f ...func(stop chan struct{})) *Runner
• func (r *Runner) Start()
• func (r *Runner) Stop()

Types ¶

type Runner ¶

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

Runner is an abstraction to make it easy to start and stop groups of things that can be described by a single function which waits on a channel close to exit.

func NewRunner ¶

func NewRunner(f ...func(stop chan struct{})) *Runner

NewRunner makes a runner for the given function(s). The function(s) should loop until the channel is closed.

func (*Runner) Start ¶

func (r *Runner) Start()

Start begins running.

func (*Runner) Stop ¶

func (r *Runner) Stop()

Stop stops running.

Source Files ¶

runner.go