flow

package module

Go to main page

Versions in this module

v1

v1.1.1

Oct 25, 2024

v1.1.0

Sep 29, 2024

v0

v0.0.8

Sep 26, 2024

v0.0.7

Sep 23, 2024

Changes in this version

+ func SetLogger(l LoggerI)

v0.0.6

Sep 23, 2024

v0.0.5

Sep 23, 2024

Changes in this version

type ProcessMeta

+ func (pm *ProcessMeta) CustomStep(run func(ctx Step) (any, error), name string, depends ...any) *StepMeta

v0.0.4

Sep 23, 2024

Changes in this version

type ProcessMeta

+ func FlowWithProcess(name string) *ProcessMeta

+ func (pm *ProcessMeta) Flow() *FlowMeta

+ func (pm *ProcessMeta) Follow(steps ...func(ctx Step) (any, error)) BuildChain

+ func (pm *ProcessMeta) NamedStep(run func(ctx Step) (any, error), name string, depends ...any) *StepMeta

+ func (pm *ProcessMeta) SyncAll(run func(ctx Step) (any, error), alias string) *StepMeta

+ type SyncPoint interface

+ Points func() []string

v0.0.3

Sep 22, 2024

Changes in this version

+ type BuildChain interface

+ After func(depends ...any)

type ProcessMeta

+ func (pm *ProcessMeta) Parallel(steps ...func(ctx Step) (any, error)) BuildChain

+ func (pm *ProcessMeta) Serial(steps ...func(ctx Step) (any, error)) BuildChain

v0.0.2

Sep 19, 2024

Changes in this version

type ProcessMeta

+ func (pm *ProcessMeta) Then(run func(ctx Step) (any, error), alias ...string) *StepMeta

type StatusEnum

+ func (s *StatusEnum) String() string

v0.0.1

Sep 18, 2024

Changes in this version

+ const FlowScope

+ const ProcessScope

+ const RecoverFailed

+ const RecoverIdle

+ const RecoverRunning

+ const RecoverSuccess

+ const StepScope

+ var CallbackFail = &StatusEnum

+ var Cancel = &StatusEnum

+ var Error = &StatusEnum

+ var Failed = &StatusEnum

+ var NormalMask = &StatusEnum

+ var Panic = &StatusEnum

+ var Pause = &StatusEnum

+ var Pending = &StatusEnum

+ var Recovering = &StatusEnum

+ var Stop = &StatusEnum

+ var Success = &StatusEnum

+ var Suspend = &StatusEnum

+ var Timeout = &StatusEnum

+ func DisableEncrypt()

+ func RegisterType[T any]()

+ func ResetDefaultCallback()

+ func SetEncryptor(encryptor SymmetricEncryptor)

+ func SetIdGenerator(method func() string)

+ func SetMaxSerializeSize(size int)

+ func SuspendPersist(impl Persist)

+ type CheckPoint interface

+ type Comparable interface

+ Less func(other any) bool

+ type Constraint interface

+ Exclude func(status ...*StatusEnum) Constraint

+ If func(condition func() bool) Constraint

+ NotFor func(name ...string) Constraint

+ OnlyFor func(name ...string) Constraint

+ When func(status ...*StatusEnum) Constraint

+ type Equality interface

+ Equal func(other any) bool

+ type EventLayer uint8

+ const FlowLayer

+ const ProcLayer

+ const StepLayer

+ func (s EventLayer) String() string

+ type EventLevel uint8

+ const ErrorLevel

+ const HintLevel

+ const InfoLevel

+ const PanicLevel

+ const WarnLevel

+ func (s EventLevel) String() string

+ type EventStage uint8

+ const InCallback

+ const InPersist

+ const InRecover

+ const InResource

+ const InSuspend

+ func (s EventStage) String() string

+ type ExecCondition interface

+ Condition func(func(step Step) bool) ExecCondition

+ EQ func(match string, expect any) ExecCondition

+ GT func(match string, expect any) ExecCondition

+ GTE func(match string, expect any) ExecCondition

+ LT func(match string, expect any) ExecCondition

+ LTE func(match string, expect any) ExecCondition

+ NEQ func(match string, expect any) ExecCondition

+ OR func() ExecCondition

+ SkipWithDependents func(excludes ...any) ExecCondition

+ type FinishedProcess interface

+ Exceptions func() []FinishedStep

+ Steps func() []FinishedStep

+ type FinishedStep interface

+ type FinishedWorkFlow interface

+ Exceptions func() []FinishedProcess

+ Processes func() []FinishedProcess

+ Recover func() (FinishedWorkFlow, error)

+ func DoneFlow(name string, input map[string]any) FinishedWorkFlow

+ func RecoverFlow(flowId string) (ret FinishedWorkFlow, err error)

+ type FlexEvent interface

+ Get func(key string) (any, bool)

+ type FlowCallback interface

+ AfterFlow func(must bool, callback func(WorkFlow) (keepOn bool, err error)) *decorator[WorkFlow]

+ BeforeFlow func(must bool, callback func(WorkFlow) (keepOn bool, err error)) *decorator[WorkFlow]

+ func DefaultCallback() FlowCallback

+ type FlowConfig interface

+ DisableRecover func() FlowConfig

+ EnableRecover func() FlowConfig

+ func DefaultConfig() FlowConfig

+ type FlowController interface

+ Done func() FinishedWorkFlow

+ Pause func() FlowController

+ Process func(name string) (process ProcController, exist bool)

+ Resume func() FlowController

+ Stop func() FlowController

+ func AsyncFlow(name string, input map[string]any) FlowController

+ type FlowMeta struct

+ func RegisterFlow(name string) *FlowMeta

+ func (f *FlowMeta) AfterFlow(must bool, callback func(WorkFlow) (keepOn bool, err error)) *decorator[WorkFlow]

+ func (f *FlowMeta) BeforeFlow(must bool, callback func(WorkFlow) (keepOn bool, err error)) *decorator[WorkFlow]

+ func (f *FlowMeta) DisableDefaultCallback()

+ func (f *FlowMeta) DisableRecover() FlowConfig

+ func (f *FlowMeta) EnableRecover() FlowConfig

+ func (fm *FlowMeta) Name() string

+ func (fm *FlowMeta) Process(name string) *ProcessMeta

+ type FlowPersistence interface

+ OnInsert func(func(WorkFlow) error) FlowPersistence

+ OnUpdate func(func(WorkFlow) error) FlowPersistence

+ func FlowPersist() FlowPersistence

+ type HandlerRegister interface

+ Capacity func(capacity int) HandlerRegister

+ Clear func()

+ DisableLog func(stages ...EventStage) HandlerRegister

+ Discard func(stage EventStage, discards ...func(event FlexEvent) (keepOn bool)) HandlerRegister

+ EventTimeoutSec func(sec int) HandlerRegister

+ Handle func(stage EventStage, handles ...func(event FlexEvent) (keepOn bool)) HandlerRegister

+ MaxHandler func(num int) HandlerRegister

+ func EventHandler() HandlerRegister

+ type LoggerI interface

+ Debug func(v ...interface{})

+ Debugf func(format string, v ...interface{})

+ Error func(v ...interface{})

+ Errorf func(format string, v ...interface{})

+ Info func(v ...interface{})

+ Infof func(format string, v ...interface{})

+ Warn func(v ...interface{})

+ Warnf func(format string, v ...interface{})

+ type Persist interface

+ GetLatestRecord func(rootUid string) (RecoverRecord, error)

+ ListCheckpoints func(recoverId string) ([]CheckPoint, error)

+ SaveCheckpointAndRecord func(checkpoint []CheckPoint, record RecoverRecord) error

+ UpdateRecordStatus func(record RecoverRecord) error

+ type ProcController interface

+ Pause func() ProcController

+ Resume func() ProcController

+ Step func(name string) (step StepController, exist bool)

+ Stop func() ProcController

+ type ProcPersistence interface

+ OnInsert func(func(Process) error) ProcPersistence

+ OnUpdate func(func(Process) error) ProcPersistence

+ func ProcPersist() ProcPersistence

+ type Process interface

+ type ProcessCallback interface

+ AfterProcess func(must bool, callback func(Process) (keepOn bool, err error)) *decorator[Process]

+ BeforeProcess func(must bool, callback func(Process) (keepOn bool, err error)) *decorator[Process]

+ DisableDefaultCallback func()

+ type ProcessConfig interface

+ ProcessTimeout func(time.Duration) ProcessConfig

+ type ProcessMeta struct

+ func (p *ProcessMeta) AfterProcess(must bool, callback func(Process) (keepOn bool, err error)) *decorator[Process]

+ func (p *ProcessMeta) BeforeProcess(must bool, callback func(Process) (keepOn bool, err error)) *decorator[Process]

+ func (p *ProcessMeta) DisableDefaultCallback()

+ func (pc *ProcessMeta) ProcessTimeout(duration time.Duration) ProcessConfig

+ func (pm *ProcessMeta) Merge(name string)

+ func (pm *ProcessMeta) Name() string

+ func (pm *ProcessMeta) NameStep(run func(ctx Step) (any, error), name string, depends ...any) *StepMeta

+ func (pm *ProcessMeta) Step(run func(ctx Step) (any, error), depends ...any) *StepMeta

+ func (pm *ProcessMeta) Tail(run func(ctx Step) (any, error), alias ...string) *StepMeta

+ type RecoverRecord interface

+ GetName func() string

+ GetRecoverId func() string

+ GetRootUid func() string

+ GetStatus func() uint8

+ type Resource interface

+ Clear func() any

+ Entity func() any

+ Fetch func(key string) (value any, exist bool)

+ ProcessID func() string

+ ProcessName func() string

+ Put func(key string, value any) any

+ Update func(entity any) any

+ type ResourceManager interface

+ OnInitialize func(func(res Resource, initParam any) (entity any, err error)) ResourceManager

+ OnRecover func(func(res Resource) error) ResourceManager

+ OnRelease func(func(res Resource) error) ResourceManager

+ OnSuspend func(func(res Resource) error) ResourceManager

+ func AddResource(name string) ResourceManager

+ type StatusEnum struct

+ func (s *StatusEnum) Message() string

+ type Step interface

+ type StepCallback interface

+ AfterStep func(must bool, callback func(Step) (keepOn bool, err error)) *decorator[Step]

+ BeforeStep func(must bool, callback func(Step) (keepOn bool, err error)) *decorator[Step]

+ type StepConfig interface

+ StepRetry func(int) StepConfig

+ StepTimeout func(time.Duration) StepConfig

+ type StepController interface

+ type StepMeta struct

+ func (c *StepMeta) Condition(f func(step Step) bool) ExecCondition

+ func (c *StepMeta) EQ(match string, expect any) ExecCondition

+ func (c *StepMeta) GT(match string, expect any) ExecCondition

+ func (c *StepMeta) GTE(match string, expect any) ExecCondition

+ func (c *StepMeta) LT(match string, expect any) ExecCondition

+ func (c *StepMeta) LTE(match string, expect any) ExecCondition

+ func (c *StepMeta) NEQ(match string, expect any) ExecCondition

+ func (c *StepMeta) OR() ExecCondition

+ func (c *StepMeta) SkipWithDependents(excludes ...any) ExecCondition

+ func (meta *StepMeta) Name() string

+ func (meta *StepMeta) Next(run func(ctx Step) (any, error), alias ...string) *StepMeta

+ func (meta *StepMeta) Restrict(restrict map[string]any)

+ func (meta *StepMeta) Same(run func(ctx Step) (any, error), alias ...string) *StepMeta

+ func (s *StepMeta) StepRetry(i int) StepConfig

+ func (s *StepMeta) StepTimeout(duration time.Duration) StepConfig

+ type StepPersistence interface

+ OnInsert func(func(Step) error) StepPersistence

+ OnUpdate func(func(Step) error) StepPersistence

+ func StepPersist() StepPersistence

+ type SymmetricEncryptor interface

+ GetSecret func() []byte

+ NeedEncrypt func(key string) bool

+ func NewAES256Encryptor(secret []byte, needEncrypt ...string) SymmetricEncryptor

+ type WorkFlow interface

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