provisioner

Documentation

Index

• type Executor
• type Handler
• type Runner
  • func (r *Runner) AsyncTask() *Task
  • func (r *Runner) Run(ctx context.Context) ([]state.State, error)
• type RunnerStage
• type Task
  • func (t *Task) Err() error
  • func (t *Task) Outputs() []state.State
  • func (t *Task) Start(oldCtx context.Context)

Types

type Executor

type Executor interface {
	// Stage returns the stage that the executor belongs to.
	// Prepare prepares the executor for execution.
	Prepare(ctx context.Context, input state.State) error
	// Execute executes the executor, returning the next states.
	Execute(ctx context.Context) ([]state.State, error)
}

Executor executes a single step in provisioner execution. It transforms a set of states into their next stages.

type Handler

type Handler struct {
	Executor Executor
	Handles  []state.State
}

type Runner

type Runner struct {
	State  []state.State
	Stages []RunnerStage
	// contains filtered or unexported fields
}

Runner runs a set of provision handlers on a set of input states.

It returns the final set of states after all handlers have been executed.

func (*Runner) AsyncTask

func (r *Runner) AsyncTask() *Task

func (*Runner) Run

func (r *Runner) Run(ctx context.Context) ([]state.State, error)

type RunnerStage

type RunnerStage struct {
	Name     string
	Handlers []Handler
}

type Task

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

Task is an async running provisioner task.

func (*Task) Err

func (t *Task) Err() error

func (*Task) Outputs

func (t *Task) Outputs() []state.State

func (*Task) Start

func (t *Task) Start(oldCtx context.Context)