expr

type DeepCopier ¶

type DeepCopier interface {
	DeepCopy() DeepCopier
}

type Function ¶

type Function interface {
	Apply(vm *otto.Otto, call otto.FunctionCall) otto.Value
}

Function is an interface for providing functions that are able to be injected into the Otto runtime.

type InputFn ¶

type InputFn struct{}

InputFn provides a function to get the input of a task for the given key. If no key is provided, the default key is used.

func (qf *InputFn) Apply(vm *otto.Otto, call otto.FunctionCall) otto.Value

type InvocationScope ¶

type InvocationScope struct {
	*ObjectMetadata
	Inputs map[string]interface{}
}

InvocationScope object provides information about the current invocation.

func (s *InvocationScope) DeepCopy() DeepCopier

type JavascriptExpressionParser ¶

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

func NewJavascriptExpressionParser() *JavascriptExpressionParser

func (oe *JavascriptExpressionParser) Resolve(rootScope interface{}, currentTask string,
	expr *typedvalues.TypedValue) (*typedvalues.TypedValue, error)

type ObjectMetadata ¶

type ObjectMetadata struct {
	Id        string
	CreatedAt int64 // unix timestamp
}

ObjectMetadata contains identity and meta-data about an object.

func (s *ObjectMetadata) DeepCopy() DeepCopier

type OutputFn ¶

type OutputFn struct{}

OutputFn provides a function to Get the output of a task.

func (qf *OutputFn) Apply(vm *otto.Otto, call otto.FunctionCall) otto.Value

type OutputHeadersFn ¶

type OutputHeadersFn struct{}

OutputHeadersFn provides a function to Get headers in the output of a task.

func (qf *OutputHeadersFn) Apply(vm *otto.Otto, call otto.FunctionCall) otto.Value

type ParamFn ¶

type ParamFn struct{}

ParmFn provides a function to get the invocation param for the given key. If no key is provided, the default key is used.

func (qf *ParamFn) Apply(vm *otto.Otto, call otto.FunctionCall) otto.Value

type Resolver ¶

type Resolver interface {
	Resolve(rootScope interface{}, currentTask string, expr *typedvalues.TypedValue) (*typedvalues.TypedValue, error)
}

resolver resolves an expression within a given context/scope.

type Scope ¶

type Scope struct {
	Workflow   *WorkflowScope
	Invocation *InvocationScope
	Tasks      Tasks
}

Scope is the broadest view of the workflow invocation, which can be queried by the user.

func NewScope(base *Scope, wfi *types.WorkflowInvocation) (*Scope, error)

func (s *Scope) DeepCopy() DeepCopier

type Store ¶

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

TODO Keep old states (but prune if OOM) TODO provide garbage collector

func NewStore() *Store

func (rs *Store) Delete(id string)

func (rs *Store) Get(id string) (*Scope, bool)

func (rs *Store) Range(fn func(key string, value *Scope) bool)

func (rs *Store) Set(id string, data *Scope)

func (rs *Store) Update(id string, updater func(entry *Scope) *Scope)

type TaskFn ¶

type TaskFn struct{}

TaskFn provides a function to get a task for the given taskId. If no argument is provided the current task is returned.

func (qf *TaskFn) Apply(vm *otto.Otto, call otto.FunctionCall) otto.Value

type TaskScope ¶

type TaskScope struct {
	*ObjectMetadata
	Status        string // TaskInvocation status
	UpdatedAt     int64  // unix timestamp
	Inputs        map[string]interface{}
	Requires      map[string]*types.TaskDependencyParameters
	Output        interface{}
	OutputHeaders interface{}
	Function      string
}

TaskScope holds information about a specific task execution within the current workflow invocation.

func (s *TaskScope) DeepCopy() DeepCopier

type Tasks ¶

type Tasks map[string]*TaskScope

func (s Tasks) DeepCopy() DeepCopier

type UidFn ¶

type UidFn struct{}

UidFn provides a function to generate a unique (string) id

func (qf *UidFn) Apply(vm *otto.Otto, call otto.FunctionCall) otto.Value

type WorkflowScope ¶

type WorkflowScope struct {
	*ObjectMetadata
	UpdatedAt int64  // unix timestamp
	Status    string // workflow status
	Name      string
	Internal  bool
}

WorkflowScope provides information about the workflow definition.

func (s *WorkflowScope) DeepCopy() DeepCopier