Versions in this module Expand all Collapse all v0 v0.1.0 May 25, 2025 Changes in this version + const StateCompleted + const StateFailed + const StatePaused + const StatePending + const StateRunning + var ContextKey = KeyOf[*Context]() + var EventKey = KeyOf[*event.Service]() + var ExecutionKey = KeyOf[*Execution]() + var ProcessKey = KeyOf[*Process]() + var TaskKey = KeyOf[*graph.Task]() + func ContextValue[T any](ctx context.Context) T + func KeyOf[T any]() reflect.Type + type Context struct + func NewContext(ctx context.Context, actions *extension.Actions, service *event.Service) *Context + func (c *Context) ExecutionContext(process *Process, execution *Execution, task *graph.Task) *Context + func (c *Context) Value(key any) any + type Execution struct + CompletedAt *time.Time + Data map[string]interface{} + Dependencies map[string]TaskState + DependsOn []string + Error string + GoToTask string + GroupID string + ID string + Input interface{} + Meta map[string]interface{} + Output interface{} + ParentTaskID string + PausedAt *time.Time + ProcessID string + ScheduledAt time.Time + StartedAt *time.Time + State TaskState + TaskID string + func NewExecution(processID string, parent, task *graph.Task) *Execution + func (e *Execution) Complete() + func (e *Execution) Context(eventType string, task *graph.Task) *event.Context + func (e *Execution) Fail(err error) + func (e *Execution) Merge(execution *Execution) + func (e *Execution) Pause() + func (e *Execution) Schedule() + func (e *Execution) Skip() + func (e *Execution) Start() + type Option func(session *Session) + func WithConverter(converter *conv.Converter) Option + func WithImports(imports ...*model.Import) Option + func WithState(state map[string]interface{}) Option + func WithTypes(types *extension.Types) Option + type Process struct + ActiveTaskCount int + ActiveTaskGroups map[string]bool + CreatedAt time.Time + Errors map[string]string + FinishedAt *time.Time + ID string + Mode string + Name string + ParentID string + SCN int + Session *Session + Stack []*Execution + State string + UpdatedAt time.Time + Workflow *model.Workflow + func NewProcess(id string, name string, workflow *model.Workflow, ...) *Process + func (p *Process) AddActiveTaskGroup(groupID string) + func (p *Process) AllTasks() map[string]*graph.Task + func (p *Process) DecrementActiveTaskCount() int + func (p *Process) GetActiveTaskCount() int + func (p *Process) GetState() string + func (p *Process) HasActiveTaskGroup(groupID string) bool + func (p *Process) IncrementActiveTaskCount() int + func (p *Process) LookupExecution(taskID string) *Execution + func (p *Process) LookupTask(taskID string) *graph.Task + func (p *Process) Peek() *Execution + func (p *Process) Push(executions ...*Execution) + func (p *Process) Remove(anExecution *Execution) + func (p *Process) RemoveActiveTaskGroup(groupID string) + func (p *Process) SetState(state string) + type ProcessOutput struct + Errors map[string]string + Output map[string]interface{} + ProcessID string + State string + TimeTaken time.Duration + Timeout bool + type Session struct + ID string + State map[string]interface{} + func NewSession(id string, opt ...Option) *Session + func (s *Session) Append(key string, value interface{}) + func (s *Session) ApplyParameters(params state.Parameters) error + func (s *Session) Clone() *Session + func (s *Session) Expand(value interface{}) (interface{}, error) + func (s *Session) Get(key string) (interface{}, bool) + func (s *Session) GetAll() map[string]interface{} + func (s *Session) GetBool(key string) (bool, bool) + func (s *Session) GetInt(key string) (int, bool) + func (s *Session) GetString(key string) (string, bool) + func (s *Session) Set(key string, value interface{}) + func (s *Session) TaskSession(from map[string]interface{}, options ...Option) *Session + func (s *Session) TypedValue(aType reflect.Type, value interface{}) (interface{}, error) + type TaskState string + const TaskStateCompleted + const TaskStateFailed + const TaskStatePaused + const TaskStatePending + const TaskStateRunning + const TaskStateScheduled + const TaskStateSkipped + const TaskStateWaitForDependencies + const TaskStateWaitForSubTasks + type Wait func(ctx context.Context, timeout time.Duration) (*ProcessOutput, error)
Go to main page