runner

Documentation

Overview

Package runner provides primitives to run tasks as Kubernetes Jobs.

Index

• Variables
• type Runnable
• type RunnableFunc
  • func (f RunnableFunc) Run(ctx context.Context) error
• type Runner
  • func New() Runner
  • func NewWithTimeout(d time.Duration) Runner

Variables

var ErrTimeout = errors.New("runner received timeout")

ErrTimeout is returned when Runner's Run method fails due to a timeout event.

Types

type Runnable

type Runnable interface {
	Run(ctx context.Context) error
}

Runnable is the interface that wraps the basic Run method.

Run should be implemented by any task intended to be executed by the Runner.

type RunnableFunc

type RunnableFunc func(ctx context.Context) error

The RunnableFunc type is an adapter to allow the use of ordinary functions as Runnable tasks. If f is a function with the appropriate signature, RunnableFunc(f) is a Runnable that calls f.

func (RunnableFunc) Run

func (f RunnableFunc) Run(ctx context.Context) error

Run calls f()

type Runner

type Runner interface {
	Run(ctx context.Context, task Runnable) error
}

Runner is the interface that wraps the basic Run method.

Run executes submitted Runnable tasks.

func New

func New() Runner

New constructs a new ready-to-use Runner for running a Runnable task.

func NewWithTimeout

func NewWithTimeout(d time.Duration) Runner

NewWithTimeout constructs a new ready-to-use Runner with the specified timeout for running a Runnable task.