task

Documentation

Index

• Constants
• Variables
• func LookupAction(v *cue.Value) (string, *cue.Value)
• func Register(typ string, f NewFunc)
• func Then(ctx context.Context, v *cue.Value) error
• type NewFunc
• type State
  • func ParseState(s string) (State, error)
  • func (s State) CanTransition(t State) bool
  • func (s State) String() string
• type Stdout
  • func (t *Stdout) Name() string
  • func (t *Stdout) Run(ctx context.Context, v *cue.Value) (*cue.Value, error)
• type Task
  • func Lookup(v *cue.Value) (Task, error)
  • func New(typ string) Task

Constants

const HTTP2_GOAWAY_CHECK = "http2: server sent GOAWAY and closed the connection"

Variables

var (
	ErrNotTask = errors.New("not a task")
)

Functions

func LookupAction

func LookupAction(v *cue.Value) (string, *cue.Value)

lookup action type in cue

func Register

func Register(typ string, f NewFunc)

Register a task type and initializer

func Then

func Then(ctx context.Context, v *cue.Value) error

do then action

Types

type NewFunc

type NewFunc func() Task

type State

type State int8

State is the state of the task.

const (
	// state order is important here since it defines the  order
	// on how states can transition only forwards
	// computing > completed > canceled > failed
	StateComputing State = iota
	StateSkipped
	StateCompleted
	StateCanceled
	StateFailed
)

func ParseState

func ParseState(s string) (State, error)

func (State) CanTransition

func (s State) CanTransition(t State) bool

func (State) String

func (s State) String() string

type Stdout

type Stdout struct {
}

func (*Stdout) Name

func (t *Stdout) Name() string

func (*Stdout) Run

func (t *Stdout) Run(ctx context.Context, v *cue.Value) (*cue.Value, error)

type Task

type Task interface {
	Run(ctx context.Context, v *cue.Value) (*cue.Value, error)
	Name() string
}

return result

func Lookup

func Lookup(v *cue.Value) (Task, error)

find action type by path

func New

func New(typ string) Task

New creates a new Task of the given type.