workflow

package

Go to main page

Versions in this module

v1

v1.24.0

Jan 8, 2024

Changes in this version

+ func ExecutionShape() shape.Shape

+ func MatchCommandR0(x Command, f1 func(x *Run), f2 func(x *Callback), f3 func(x *TryRecover), ...)

+ func MatchCommandR1[T0 any](x Command, f1 func(x *Run) T0, f2 func(x *Callback) T0, ...) T0

+ func MatchCommandR3[T0, T1, T2 any](x Command, f1 func(x *Run) (T0, T1, T2), f2 func(x *Callback) (T0, T1, T2), ...) (T0, T1, T2)

+ func MatchExprR0(x Expr, f1 func(x *End), f2 func(x *Assign), f3 func(x *Apply), ...)

+ func MatchExprR1[T0 any](x Expr, f1 func(x *End) T0, f2 func(x *Assign) T0, f3 func(x *Apply) T0, ...) T0

+ func MatchExprR3[T0, T1, T2 any](x Expr, f1 func(x *End) (T0, T1, T2), f2 func(x *Assign) (T0, T1, T2), ...) (T0, T1, T2)

+ func MatchPredicateR0(x Predicate, f1 func(x *And), f2 func(x *Or), f3 func(x *Not), ...)

+ func MatchPredicateR1[T0 any](x Predicate, f1 func(x *And) T0, f2 func(x *Or) T0, f3 func(x *Not) T0, ...) T0

+ func MatchPredicateR3[T0, T1, T2 any](x Predicate, f1 func(x *And) (T0, T1, T2), f2 func(x *Or) (T0, T1, T2), ...) (T0, T1, T2)

+ func MatchReshaperR0(x Reshaper, f1 func(x *GetValue), f2 func(x *SetValue))

+ func MatchReshaperR1[T0 any](x Reshaper, f1 func(x *GetValue) T0, f2 func(x *SetValue) T0) T0

+ func MatchReshaperR3[T0, T1, T2 any](x Reshaper, f1 func(x *GetValue) (T0, T1, T2), ...) (T0, T1, T2)

+ func MatchRunOptionR0(x RunOption, f1 func(x *ScheduleRun), f2 func(x *DelayRun))

+ func MatchRunOptionR1[T0 any](x RunOption, f1 func(x *ScheduleRun) T0, f2 func(x *DelayRun) T0) T0

+ func MatchRunOptionR3[T0, T1, T2 any](x RunOption, f1 func(x *ScheduleRun) (T0, T1, T2), ...) (T0, T1, T2)

+ func MatchStateR0(x State, f1 func(x *NextOperation), f2 func(x *Done), f3 func(x *Error), ...)

+ func MatchStateR1[T0 any](x State, f1 func(x *NextOperation) T0, f2 func(x *Done) T0, ...) T0

+ func MatchStateR3[T0, T1, T2 any](x State, f1 func(x *NextOperation) (T0, T1, T2), f2 func(x *Done) (T0, T1, T2), ...) (T0, T1, T2)

+ func MatchWorkflowR0(x Workflow, f1 func(x *Flow), f2 func(x *FlowRef))

+ func MatchWorkflowR1[T0 any](x Workflow, f1 func(x *Flow) T0, f2 func(x *FlowRef) T0) T0

+ func MatchWorkflowR3[T0, T1, T2 any](x Workflow, f1 func(x *Flow) (T0, T1, T2), f2 func(x *FlowRef) (T0, T1, T2)) (T0, T1, T2)

v1.23.0

Jan 6, 2024

v1.22.0

Jan 4, 2024

v1.21.1

Jan 3, 2024

Changes in this version

+ func AndShape() shape.Shape

+ func AndToJSON(x *And) ([]byte, error)

+ func ApplyAwaitOptionsShape() shape.Shape

+ func ApplyShape() shape.Shape

+ func ApplyToJSON(x *Apply) ([]byte, error)

+ func AssignShape() shape.Shape

+ func AssignToJSON(x *Assign) ([]byte, error)

+ func AwaitShape() shape.Shape

+ func AwaitToJSON(x *Await) ([]byte, error)

+ func BaseStateShape() shape.Shape

+ func CallbackShape() shape.Shape

+ func CallbackToJSON(x *Callback) ([]byte, error)

+ func ChooseShape() shape.Shape

+ func ChooseToJSON(x *Choose) ([]byte, error)

+ func CommandShape() shape.Shape

+ func CommandToJSON(x Command) ([]byte, error)

+ func CompareShape() shape.Shape

+ func CompareToJSON(x *Compare) ([]byte, error)

+ func DelayRunShape() shape.Shape

+ func DelayRunToJSON(x *DelayRun) ([]byte, error)

+ func DoneShape() shape.Shape

+ func DoneToJSON(x *Done) ([]byte, error)

+ func EndShape() shape.Shape

+ func EndToJSON(x *End) ([]byte, error)

+ func ErrorShape() shape.Shape

+ func ErrorToJSON(x *Error) ([]byte, error)

+ func ExprShape() shape.Shape

+ func ExprToJSON(x Expr) ([]byte, error)

+ func FlowRefShape() shape.Shape

+ func FlowRefToJSON(x *FlowRef) ([]byte, error)

+ func FlowShape() shape.Shape

+ func FlowToJSON(x *Flow) ([]byte, error)

+ func FunctionInputShape() shape.Shape

+ func FunctionOutputShape() shape.Shape

+ func GetValueShape() shape.Shape

+ func GetValueToJSON(x *GetValue) ([]byte, error)

+ func MatchCommandR2[TOut1, TOut2 any](x Command, f1 func(x *Run) (TOut1, TOut2), f2 func(x *Callback) (TOut1, TOut2), ...) (TOut1, TOut2)

+ func MatchCommand[TOut any](x Command, f1 func(x *Run) TOut, f2 func(x *Callback) TOut, ...) TOut

+ func MatchExprR2[TOut1, TOut2 any](x Expr, f1 func(x *End) (TOut1, TOut2), f2 func(x *Assign) (TOut1, TOut2), ...) (TOut1, TOut2)

+ func MatchExpr[TOut any](x Expr, f1 func(x *End) TOut, f2 func(x *Assign) TOut, f3 func(x *Apply) TOut, ...) TOut

+ func MatchPredicateR2[TOut1, TOut2 any](x Predicate, f1 func(x *And) (TOut1, TOut2), f2 func(x *Or) (TOut1, TOut2), ...) (TOut1, TOut2)

+ func MatchPredicate[TOut any](x Predicate, f1 func(x *And) TOut, f2 func(x *Or) TOut, f3 func(x *Not) TOut, ...) TOut

+ func MatchReshaperR2[TOut1, TOut2 any](x Reshaper, f1 func(x *GetValue) (TOut1, TOut2), ...) (TOut1, TOut2)

+ func MatchReshaper[TOut any](x Reshaper, f1 func(x *GetValue) TOut, f2 func(x *SetValue) TOut, ...) TOut

+ func MatchRunOptionR2[TOut1, TOut2 any](x RunOption, f1 func(x *ScheduleRun) (TOut1, TOut2), ...) (TOut1, TOut2)

+ func MatchRunOption[TOut any](x RunOption, f1 func(x *ScheduleRun) TOut, f2 func(x *DelayRun) TOut, ...) TOut

+ func MatchStateR2[TOut1, TOut2 any](x State, f1 func(x *NextOperation) (TOut1, TOut2), ...) (TOut1, TOut2)

+ func MatchState[TOut any](x State, f1 func(x *NextOperation) TOut, f2 func(x *Done) TOut, ...) TOut

+ func MatchWorkflowR2[TOut1, TOut2 any](x Workflow, f1 func(x *Flow) (TOut1, TOut2), ...) (TOut1, TOut2)

+ func MatchWorkflow[TOut any](x Workflow, f1 func(x *Flow) TOut, f2 func(x *FlowRef) TOut, ...) TOut

+ func MustMatchCommandR0(x Command, f1 func(x *Run), f2 func(x *Callback), f3 func(x *TryRecover), ...)

+ func MustMatchCommandR2[TOut1, TOut2 any](x Command, f1 func(x *Run) (TOut1, TOut2), f2 func(x *Callback) (TOut1, TOut2), ...) (TOut1, TOut2)

+ func MustMatchCommand[TOut any](x Command, f1 func(x *Run) TOut, f2 func(x *Callback) TOut, ...) TOut

+ func MustMatchExprR0(x Expr, f1 func(x *End), f2 func(x *Assign), f3 func(x *Apply), ...)

+ func MustMatchExprR2[TOut1, TOut2 any](x Expr, f1 func(x *End) (TOut1, TOut2), f2 func(x *Assign) (TOut1, TOut2), ...) (TOut1, TOut2)

+ func MustMatchExpr[TOut any](x Expr, f1 func(x *End) TOut, f2 func(x *Assign) TOut, f3 func(x *Apply) TOut, ...) TOut

+ func MustMatchPredicateR0(x Predicate, f1 func(x *And), f2 func(x *Or), f3 func(x *Not), ...)

+ func MustMatchPredicateR2[TOut1, TOut2 any](x Predicate, f1 func(x *And) (TOut1, TOut2), f2 func(x *Or) (TOut1, TOut2), ...) (TOut1, TOut2)

+ func MustMatchPredicate[TOut any](x Predicate, f1 func(x *And) TOut, f2 func(x *Or) TOut, f3 func(x *Not) TOut, ...) TOut

+ func MustMatchReshaperR0(x Reshaper, f1 func(x *GetValue), f2 func(x *SetValue))

+ func MustMatchReshaperR2[TOut1, TOut2 any](x Reshaper, f1 func(x *GetValue) (TOut1, TOut2), ...) (TOut1, TOut2)

+ func MustMatchReshaper[TOut any](x Reshaper, f1 func(x *GetValue) TOut, f2 func(x *SetValue) TOut) TOut

+ func MustMatchRunOptionR0(x RunOption, f1 func(x *ScheduleRun), f2 func(x *DelayRun))

+ func MustMatchRunOptionR2[TOut1, TOut2 any](x RunOption, f1 func(x *ScheduleRun) (TOut1, TOut2), ...) (TOut1, TOut2)

+ func MustMatchRunOption[TOut any](x RunOption, f1 func(x *ScheduleRun) TOut, f2 func(x *DelayRun) TOut) TOut

+ func MustMatchStateR0(x State, f1 func(x *NextOperation), f2 func(x *Done), f3 func(x *Error), ...)

+ func MustMatchStateR2[TOut1, TOut2 any](x State, f1 func(x *NextOperation) (TOut1, TOut2), ...) (TOut1, TOut2)

+ func MustMatchState[TOut any](x State, f1 func(x *NextOperation) TOut, f2 func(x *Done) TOut, ...) TOut

+ func MustMatchWorkflowR0(x Workflow, f1 func(x *Flow), f2 func(x *FlowRef))

+ func MustMatchWorkflowR2[TOut1, TOut2 any](x Workflow, f1 func(x *Flow) (TOut1, TOut2), ...) (TOut1, TOut2)

+ func MustMatchWorkflow[TOut any](x Workflow, f1 func(x *Flow) TOut, f2 func(x *FlowRef) TOut) TOut

+ func NextOperationShape() shape.Shape

+ func NextOperationToJSON(x *NextOperation) ([]byte, error)

+ func NotShape() shape.Shape

+ func NotToJSON(x *Not) ([]byte, error)

+ func OrShape() shape.Shape

+ func OrToJSON(x *Or) ([]byte, error)

+ func PredicateShape() shape.Shape

+ func PredicateToJSON(x Predicate) ([]byte, error)

+ func ReshaperShape() shape.Shape

+ func ReshaperToJSON(x Reshaper) ([]byte, error)

+ func ResumeOptionsShape() shape.Shape

+ func ResumeScheduleShape() shape.Shape

+ func ResumeScheduleToJSON(x *ResumeSchedule) ([]byte, error)

+ func RunOptionShape() shape.Shape

+ func RunOptionToJSON(x RunOption) ([]byte, error)

+ func RunShape() shape.Shape

+ func RunToJSON(x *Run) ([]byte, error)

+ func ScheduleRunShape() shape.Shape

+ func ScheduleRunToJSON(x *ScheduleRun) ([]byte, error)

+ func ScheduleStoppedShape() shape.Shape

+ func ScheduleStoppedToJSON(x *ScheduleStopped) ([]byte, error)

+ func ScheduledShape() shape.Shape

+ func ScheduledToJSON(x *Scheduled) ([]byte, error)

+ func SetValueShape() shape.Shape

+ func SetValueToJSON(x *SetValue) ([]byte, error)

+ func StateShape() shape.Shape

+ func StateToJSON(x State) ([]byte, error)

+ func StopScheduleShape() shape.Shape

+ func StopScheduleToJSON(x *StopSchedule) ([]byte, error)

+ func TryRecoverShape() shape.Shape

+ func TryRecoverToJSON(x *TryRecover) ([]byte, error)

+ func WorkflowShape() shape.Shape

+ func WorkflowToJSON(x Workflow) ([]byte, error)

type And

+ func AndFromJSON(x []byte) (*And, error)

+ func (r *And) AcceptPredicate(v PredicateVisitor) any

+ func (r *And) MarshalJSON() ([]byte, error)

+ func (r *And) UnmarshalJSON(data []byte) error

type Apply

+ func ApplyFromJSON(x []byte) (*Apply, error)

+ func (r *Apply) AcceptExpr(v ExprVisitor) any

+ func (r *Apply) MarshalJSON() ([]byte, error)

+ func (r *Apply) UnmarshalJSON(data []byte) error

type ApplyAwaitOptions

+ func (r *ApplyAwaitOptions) MarshalJSON() ([]byte, error)

+ func (r *ApplyAwaitOptions) UnmarshalJSON(data []byte) error

type Assign

+ func AssignFromJSON(x []byte) (*Assign, error)

+ func (r *Assign) AcceptExpr(v ExprVisitor) any

+ func (r *Assign) MarshalJSON() ([]byte, error)

+ func (r *Assign) UnmarshalJSON(data []byte) error

type Await

+ func AwaitFromJSON(x []byte) (*Await, error)

+ func (r *Await) AcceptState(v StateVisitor) any

+ func (r *Await) MarshalJSON() ([]byte, error)

+ func (r *Await) UnmarshalJSON(data []byte) error

type BaseState

+ func (r *BaseState) MarshalJSON() ([]byte, error)

+ func (r *BaseState) UnmarshalJSON(data []byte) error

type Callback

+ func CallbackFromJSON(x []byte) (*Callback, error)

+ func (r *Callback) AcceptCommand(v CommandVisitor) any

+ func (r *Callback) MarshalJSON() ([]byte, error)

+ func (r *Callback) UnmarshalJSON(data []byte) error

type Choose

+ func ChooseFromJSON(x []byte) (*Choose, error)

+ func (r *Choose) AcceptExpr(v ExprVisitor) any

+ func (r *Choose) MarshalJSON() ([]byte, error)

+ func (r *Choose) UnmarshalJSON(data []byte) error

+ type Command interface

+ AcceptCommand func(g CommandVisitor) any

+ func CommandFromJSON(x []byte) (Command, error)

+ type CommandUnionJSON struct

+ Callback json.RawMessage

+ ResumeSchedule json.RawMessage

+ Run json.RawMessage

+ StopSchedule json.RawMessage

+ TryRecover json.RawMessage

+ Type string

+ type CommandVisitor interface

+ VisitCallback func(v *Callback) any

+ VisitResumeSchedule func(v *ResumeSchedule) any

+ VisitRun func(v *Run) any

+ VisitStopSchedule func(v *StopSchedule) any

+ VisitTryRecover func(v *TryRecover) any

type Compare

+ func CompareFromJSON(x []byte) (*Compare, error)

+ func (r *Compare) AcceptPredicate(v PredicateVisitor) any

+ func (r *Compare) MarshalJSON() ([]byte, error)

+ func (r *Compare) UnmarshalJSON(data []byte) error

type DelayRun

+ func DelayRunFromJSON(x []byte) (*DelayRun, error)

+ func (r *DelayRun) AcceptRunOption(v RunOptionVisitor) any

+ func (r *DelayRun) MarshalJSON() ([]byte, error)

+ func (r *DelayRun) UnmarshalJSON(data []byte) error

type Done

+ func DoneFromJSON(x []byte) (*Done, error)

+ func (r *Done) AcceptState(v StateVisitor) any

+ func (r *Done) MarshalJSON() ([]byte, error)

+ func (r *Done) UnmarshalJSON(data []byte) error

type End

+ func EndFromJSON(x []byte) (*End, error)

+ func (r *End) AcceptExpr(v ExprVisitor) any

+ func (r *End) MarshalJSON() ([]byte, error)

+ func (r *End) UnmarshalJSON(data []byte) error

type Error

+ func ErrorFromJSON(x []byte) (*Error, error)

+ func (r *Error) AcceptState(v StateVisitor) any

+ func (r *Error) MarshalJSON() ([]byte, error)

+ func (r *Error) UnmarshalJSON(data []byte) error

+ type Expr interface

+ AcceptExpr func(g ExprVisitor) any

+ func ExprFromJSON(x []byte) (Expr, error)

+ type ExprUnionJSON struct

+ Apply json.RawMessage

+ Assign json.RawMessage

+ Choose json.RawMessage

+ End json.RawMessage

+ Type string

+ type ExprVisitor interface

+ VisitApply func(v *Apply) any

+ VisitAssign func(v *Assign) any

+ VisitChoose func(v *Choose) any

+ VisitEnd func(v *End) any

type Flow

+ func FlowFromJSON(x []byte) (*Flow, error)

+ func (r *Flow) AcceptWorkflow(v WorkflowVisitor) any

+ func (r *Flow) MarshalJSON() ([]byte, error)

+ func (r *Flow) UnmarshalJSON(data []byte) error

type FlowRef

+ func FlowRefFromJSON(x []byte) (*FlowRef, error)

+ func (r *FlowRef) AcceptWorkflow(v WorkflowVisitor) any

+ func (r *FlowRef) MarshalJSON() ([]byte, error)

+ func (r *FlowRef) UnmarshalJSON(data []byte) error

type FunctionInput

+ func (r *FunctionInput) MarshalJSON() ([]byte, error)

+ func (r *FunctionInput) UnmarshalJSON(data []byte) error

type FunctionOutput

+ func (r *FunctionOutput) MarshalJSON() ([]byte, error)

+ func (r *FunctionOutput) UnmarshalJSON(data []byte) error

type GetValue

+ func GetValueFromJSON(x []byte) (*GetValue, error)

+ func (r *GetValue) AcceptReshaper(v ReshaperVisitor) any

+ func (r *GetValue) MarshalJSON() ([]byte, error)

+ func (r *GetValue) UnmarshalJSON(data []byte) error

type NextOperation

+ func NextOperationFromJSON(x []byte) (*NextOperation, error)

+ func (r *NextOperation) AcceptState(v StateVisitor) any

+ func (r *NextOperation) MarshalJSON() ([]byte, error)

+ func (r *NextOperation) UnmarshalJSON(data []byte) error

type Not

+ func NotFromJSON(x []byte) (*Not, error)

+ func (r *Not) AcceptPredicate(v PredicateVisitor) any

+ func (r *Not) MarshalJSON() ([]byte, error)

+ func (r *Not) UnmarshalJSON(data []byte) error

type Or

+ func OrFromJSON(x []byte) (*Or, error)

+ func (r *Or) AcceptPredicate(v PredicateVisitor) any

+ func (r *Or) MarshalJSON() ([]byte, error)

+ func (r *Or) UnmarshalJSON(data []byte) error

+ type Predicate interface

+ AcceptPredicate func(g PredicateVisitor) any

+ func PredicateFromJSON(x []byte) (Predicate, error)

+ type PredicateUnionJSON struct

+ And json.RawMessage

+ Compare json.RawMessage

+ Not json.RawMessage

+ Or json.RawMessage

+ Type string

+ type PredicateVisitor interface

+ VisitAnd func(v *And) any

+ VisitCompare func(v *Compare) any

+ VisitNot func(v *Not) any

+ VisitOr func(v *Or) any

+ type Reshaper interface

+ AcceptReshaper func(g ReshaperVisitor) any

+ func ReshaperFromJSON(x []byte) (Reshaper, error)

+ type ReshaperUnionJSON struct

+ GetValue json.RawMessage

+ SetValue json.RawMessage

+ Type string

+ type ReshaperVisitor interface

+ VisitGetValue func(v *GetValue) any

+ VisitSetValue func(v *SetValue) any

type ResumeOptions

+ func (r *ResumeOptions) MarshalJSON() ([]byte, error)

+ func (r *ResumeOptions) UnmarshalJSON(data []byte) error

type ResumeSchedule

+ func ResumeScheduleFromJSON(x []byte) (*ResumeSchedule, error)

+ func (r *ResumeSchedule) AcceptCommand(v CommandVisitor) any

+ func (r *ResumeSchedule) MarshalJSON() ([]byte, error)

+ func (r *ResumeSchedule) UnmarshalJSON(data []byte) error

type Run

+ func RunFromJSON(x []byte) (*Run, error)

+ func (r *Run) AcceptCommand(v CommandVisitor) any

+ func (r *Run) MarshalJSON() ([]byte, error)

+ func (r *Run) UnmarshalJSON(data []byte) error

+ type RunOption interface

+ AcceptRunOption func(g RunOptionVisitor) any

+ func RunOptionFromJSON(x []byte) (RunOption, error)

+ type RunOptionUnionJSON struct

+ DelayRun json.RawMessage

+ ScheduleRun json.RawMessage

+ Type string

+ type RunOptionVisitor interface

+ VisitDelayRun func(v *DelayRun) any

+ VisitScheduleRun func(v *ScheduleRun) any

type ScheduleRun

+ func ScheduleRunFromJSON(x []byte) (*ScheduleRun, error)

+ func (r *ScheduleRun) AcceptRunOption(v RunOptionVisitor) any

+ func (r *ScheduleRun) MarshalJSON() ([]byte, error)

+ func (r *ScheduleRun) UnmarshalJSON(data []byte) error

type ScheduleStopped

+ func ScheduleStoppedFromJSON(x []byte) (*ScheduleStopped, error)

+ func (r *ScheduleStopped) AcceptState(v StateVisitor) any

+ func (r *ScheduleStopped) MarshalJSON() ([]byte, error)

+ func (r *ScheduleStopped) UnmarshalJSON(data []byte) error

type Scheduled

+ func ScheduledFromJSON(x []byte) (*Scheduled, error)

+ func (r *Scheduled) AcceptState(v StateVisitor) any

+ func (r *Scheduled) MarshalJSON() ([]byte, error)

+ func (r *Scheduled) UnmarshalJSON(data []byte) error

type SetValue

+ func SetValueFromJSON(x []byte) (*SetValue, error)

+ func (r *SetValue) AcceptReshaper(v ReshaperVisitor) any

+ func (r *SetValue) MarshalJSON() ([]byte, error)

+ func (r *SetValue) UnmarshalJSON(data []byte) error

+ type State interface

+ AcceptState func(g StateVisitor) any

+ func ExecuteAll(context BaseState, x *Flow, dep Dependency) State

+ func ExecuteExpr(context BaseState, expr Expr, dep Dependency) State

+ func StateFromJSON(x []byte) (State, error)

+ func Transition(cmd Command, state State, dep Dependency) (State, error)

+ type StateUnionJSON struct

+ Await json.RawMessage

+ Done json.RawMessage

+ Error json.RawMessage

+ NextOperation json.RawMessage

+ ScheduleStopped json.RawMessage

+ Scheduled json.RawMessage

+ Type string

+ type StateVisitor interface

+ VisitAwait func(v *Await) any

+ VisitDone func(v *Done) any

+ VisitError func(v *Error) any

+ VisitNextOperation func(v *NextOperation) any

+ VisitScheduleStopped func(v *ScheduleStopped) any

+ VisitScheduled func(v *Scheduled) any

type StopSchedule

+ func StopScheduleFromJSON(x []byte) (*StopSchedule, error)

+ func (r *StopSchedule) AcceptCommand(v CommandVisitor) any

+ func (r *StopSchedule) MarshalJSON() ([]byte, error)

+ func (r *StopSchedule) UnmarshalJSON(data []byte) error

type TryRecover

+ func TryRecoverFromJSON(x []byte) (*TryRecover, error)

+ func (r *TryRecover) AcceptCommand(v CommandVisitor) any

+ func (r *TryRecover) MarshalJSON() ([]byte, error)

+ func (r *TryRecover) UnmarshalJSON(data []byte) error

+ type Workflow interface

+ AcceptWorkflow func(g WorkflowVisitor) any

+ func WorkflowFromJSON(x []byte) (Workflow, error)

+ type WorkflowUnionJSON struct

+ Flow json.RawMessage

+ FlowRef json.RawMessage

+ Type string

+ type WorkflowVisitor interface

+ VisitFlow func(v *Flow) any

+ VisitFlowRef func(v *FlowRef) any

v1.21.0

Jan 3, 2024

Changes in this version

type ScheduleRun

+ ParentRunID string

type TryRecover

+ RunID string

v1.20.2

Dec 15, 2023

v1.20.1

Dec 12, 2023

v1.20.0

Dec 10, 2023

v1.19.0

Nov 10, 2023

Changes in this version

+ var ErrAlreadyStarted = errors.New("already started")

+ var ErrCallbackNotMatch = errors.New("callback not match")

+ var ErrExpressionHasResult = errors.New("expression has result")

+ var ErrFlowNotFound = errors.New("flow not found")

+ var ErrFlowNotSet = errors.New("flow not set")

+ var ErrIntervalParse = errors.New("failed to parse interval")

+ var ErrInvalidStateTransition = errors.New("invalid state transition")

+ var ErrMaxRetriesReached = errors.New("max retries reached")

+ var ErrRunIDNotMatch = errors.New("run id not match")

+ var ErrStateReachEnd = errors.New("cannot apply commands, when workflow is completed")

+ func ExecutePredicate(context BaseState, predicate Predicate, dep Dependency) (bool, error)

+ func ExecuteReshaper(context BaseState, reshaper Reshaper) (schema.Schema, error)

+ func GetRunID(state State) string

+ func NewMachine(di Dependency, state State) *machine.Machine[Command, State]

+ func ToStrExpr(expr Expr, depth int) string

+ func ToStrPredicate(predicate Predicate, depth int) string

+ func ToStrReshaper(reshaper Reshaper, depth int) string

+ func ToStrSchema(x schema.Schema, depth int) string

+ func ToStrWorkflow(workflow Worflow, depth int) string

+ type And struct

+ L []Predicate

+ type Apply struct

+ Args []Reshaper

+ Await *ApplyAwaitOptions

+ ID string

+ Name string

+ type ApplyAwaitOptions struct

+ Timeout int64

+ type Assign struct

+ ID string

+ Val Expr

+ VarErr string

+ VarOk string

+ type Await struct

+ BaseState BaseState

+ CallbackID string

+ Timeout int64

+ type BaseState struct

+ DefaultMaxRetries int64

+ ExprResult map[string]schema.Schema

+ Flow Worflow

+ RunID string

+ RunOption RunOption

+ StepID string

+ Variables map[string]schema.Schema

+ func GetBaseState(status State) BaseState

+ type Callback struct

+ CallbackID string

+ Result schema.Schema

+ type Choose struct

+ Else []Expr

+ ID string

+ If Predicate

+ Then []Expr

+ type Compare struct

+ Left Reshaper

+ Operation string

+ Right Reshaper

+ type DI struct

+ DefaultMaxRetries int64

+ FindFunctionF func(funcID string) (Function, error)

+ FindWorkflowF func(flowID string) (*Flow, error)

+ GenerateCallbackIDF func() string

+ GenerateRunIDF func() string

+ MockTimeNow *time.Time

+ func (di *DI) FindFunction(funcID string) (Function, error)

+ func (di *DI) FindWorkflow(flowID string) (*Flow, error)

+ func (di *DI) GenerateCallbackID() string

+ func (di *DI) GenerateRunID() string

+ func (di *DI) MaxRetries() int64

+ func (di *DI) TimeNow() time.Time

+ type DelayRun struct

+ DelayBySeconds int64

+ type Dependency interface

+ FindFunction func(funcID string) (Function, error)

+ FindWorkflow func(flowID string) (*Flow, error)

+ GenerateCallbackID func() string

+ GenerateRunID func() string

+ MaxRetries func() int64

+ TimeNow func() time.Time

+ type Done struct

+ BaseState BaseState

+ Result schema.Schema

+ type End struct

+ ID string

+ Result Reshaper

+ type Error struct

+ BaseState BaseState

+ Code string

+ Reason string

+ Retried int64

+ type Execution struct

+ EndTime int64

+ FlowID string

+ Location string

+ StartTime int64

+ Status State

+ Variables map[string]schema.Schema

+ type Flow struct

+ Arg string

+ Body []Expr

+ Name string

+ type FlowRef struct

+ FlowID string

+ type Function func(args *FunctionInput) (*FunctionOutput, error)

+ type FunctionInput struct

+ Args []schema.Schema

+ CallbackID string

+ Name string

+ type FunctionOutput struct

+ Result schema.Schema

+ type GetValue struct

+ Path string

+ type NextOperation struct

+ BaseState BaseState

+ Result schema.Schema

+ type Not struct

+ P Predicate

+ type Or struct

+ L []Predicate

+ type ResumeOptions struct

+ Timeout int64

+ type ResumeSchedule struct

+ ParentRunID string

+ type Run struct

+ Flow Worflow

+ Input schema.Schema

+ RunOption RunOption

+ func ScheduleNext(x State, dep Dependency) *Run

+ type ScheduleRun struct

+ Interval string

+ type ScheduleStopped struct

+ BaseState BaseState

+ ParentRunID string

+ type Scheduled struct

+ BaseState BaseState

+ ExpectedRunTimestamp int64

+ ParentRunID string

+ type SetValue struct

+ Value schema.Schema

+ type StopSchedule struct

+ ParentRunID string

+ type TryRecover struct

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL