runner

Documentation

Index

• Variables
• type Option
  • func WithAllEnabled(all bool) Option
  • func WithExecutable(path string, args ...string) Option
  • func WithKubeFactory(factory cmdutil.Factory) Option
  • func WithKubeNamespace(namespace string) Option
  • func WithLogger(l *logger.Logger) Option
  • func WithLoop(loop bool) Option
  • func WithPlugin(plugin Plugin) Option
  • func WithQuiet(quiet bool) Option
  • func WithSleep(d time.Duration) Option
• type Options
  • func (o Options) Apply(runner *Runner) error
• type Plugin
• type Runner
  • func New(options ...Option) (*Runner, error)
  • func (r *Runner) Run(ctx context.Context, m map[string]events.Action) (err error)

Variables

var (
	ErrChildSpawn = errors.New("cannot re-spawn a child process")
)

Helper errors

Types

type Option

type Option func(*Runner) error

Option is a functional option for extractors.

func WithAllEnabled

func WithAllEnabled(all bool) Option

func WithExecutable

func WithExecutable(path string, args ...string) Option

func WithKubeFactory

func WithKubeFactory(factory cmdutil.Factory) Option

func WithKubeNamespace

func WithKubeNamespace(namespace string) Option

func WithLogger

func WithLogger(l *logger.Logger) Option

func WithLoop

func WithLoop(loop bool) Option

func WithPlugin

func WithPlugin(plugin Plugin) Option

func WithQuiet

func WithQuiet(quiet bool) Option

func WithSleep

func WithSleep(d time.Duration) Option

type Options

type Options []Option

Options is a slice of Option.

func (Options) Apply

func (o Options) Apply(runner *Runner) error

Apply interates over Options and calls each functional option with a given runner.

type Plugin

type Plugin interface {
	PreRun(ctx context.Context, log *logger.Entry, n string, f events.Action) error
	PostRun(ctx context.Context, log *logger.Entry, n string, f events.Action, err error) error
}

type Runner

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

func New

func New(options ...Option) (*Runner, error)

func (*Runner) Run

func (r *Runner) Run(ctx context.Context, m map[string]events.Action) (err error)