light_flow

package module

Go to main page

Versions in this module

v1

v1.0.0

Mar 27, 2024

v0

v0.0.7

Mar 25, 2024

v0.0.6

Mar 25, 2024

Changes in this version

type ProcessMeta

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

v0.0.5

Mar 23, 2024

Changes in this version

type Future

+ func (s Future) Exceptions() []string

+ func (s Future) ExplainStatus() []string

+ func (s Future) Has(enum *statusEnum) bool

+ func (s Future) Normal() bool

+ func (s Future) Success() bool

+ type Process struct

+ FlowId string

+ func (bi *Process) GetId() string

+ func (bi *Process) GetName() string

+ func (pi *Process) ContextName() string

+ type Step struct

+ End time.Time

+ Err error

+ FlowId string

+ ProcessId string

+ Start time.Time

+ func (bi Step) GetId() string

+ func (bi Step) GetName() string

+ func (si *Step) Error() error

+ type StepCtx interface

+ GetEndValues func(key string) map[string]any

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

+ type WorkFlow struct

+ func (bi WorkFlow) GetId() string

+ func (bi WorkFlow) GetName() string

v0.0.4

Mar 2, 2024

v0.0.3

Jan 24, 2024

v0.0.2

Jan 21, 2024

v0.0.1

Jan 21, 2024

Changes in this version

+ const After

+ const Before

+ var AbnormalMask = &StatusEnum

+ var CallbackFail = &StatusEnum

+ var Cancel = &StatusEnum

+ var End = &StatusEnum

+ var Error = &StatusEnum

+ var Failed = &StatusEnum

+ var HasNext = &StatusEnum

+ var Head = &StatusEnum

+ var Merged = &StatusEnum

+ var NormalMask = &StatusEnum

+ var Panic = &StatusEnum

+ var Pause = &StatusEnum

+ var Pending = &StatusEnum

+ var Running = &StatusEnum

+ var Stop = &StatusEnum

+ var Success = &StatusEnum

+ var Timeout = &StatusEnum

+ func BuildRunFlow(name string, input map[string]any) *runFlow

+ func CopyProperties(src, dst interface{})

+ func CopyPropertiesSkipNotEmpty(src, dst interface{})

+ func CreateStruct[T any](src any) (target T)

+ func GetFuncName(f interface{}) string

+ func GetStructName(obj any) string

+ func SetIdGenerator(method func() string)

+ type BasicInfoI interface

+ GetId func() string

+ GetName func() string

+ type Context interface

+ ContextName func() string

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

+ GetAll func(key string) map[string]any

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

+ Set func(key string, value any)

+ type Controller interface

+ Pause func()

+ Resume func()

+ Stop func()

+ type FlowConfig struct

+ func CreateDefaultConfig() *FlowConfig

+ func (fc *FlowConfig) AfterFlow(must bool, callback func(*FlowInfo) (keepOn bool, err error)) *callback[*FlowInfo]

+ func (fc *FlowConfig) BeforeFlow(must bool, callback func(*FlowInfo) (keepOn bool, err error)) *callback[*FlowInfo]

+ type FlowController interface

+ Done func() []*Future

+ ListProcess func() []string

+ ProcessController func(name string) Controller

+ func AsyncArgs(name string, args ...any) FlowController

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

+ type FlowInfo struct

+ func (bi FlowInfo) GetId() string

+ func (bi FlowInfo) GetName() string

+ func (vc FlowInfo) ContextName() string

+ func (vc FlowInfo) Get(key string) (value any, exist bool)

+ func (vc FlowInfo) GetAll(key string) map[string]any

+ func (vc FlowInfo) GetResult(key string) (value any, exist bool)

+ func (vc FlowInfo) Set(key string, value any)

+ type FlowMeta struct

+ func RegisterFlow(name string) *FlowMeta

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

+ func (fm *FlowMeta) NoUseDefault() *FlowMeta

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

+ type Future struct

+ func (bi Future) GetId() string

+ func (bi Future) GetName() string

+ func (f *Future) Done()

+ type Handler struct

+ type ProcessConfig struct

+ ProcNotUseDefault bool

+ ProcTimeout time.Duration

+ func (pc *ProcessConfig) AfterProcess(must bool, callback func(*ProcessInfo) (keepOn bool, err error)) *callback[*ProcessInfo]

+ func (pc *ProcessConfig) AfterStep(must bool, callback func(*StepInfo) (keepOn bool, err error)) *callback[*StepInfo]

+ func (pc *ProcessConfig) BeforeProcess(must bool, callback func(*ProcessInfo) (keepOn bool, err error)) *callback[*ProcessInfo]

+ func (pc *ProcessConfig) BeforeStep(must bool, callback func(*StepInfo) (keepOn bool, err error)) *callback[*StepInfo]

+ func (pc *ProcessConfig) NotUseDefault()

+ func (pc *ProcessConfig) ProcessTimeout(timeout time.Duration) *ProcessConfig

+ func (pc *ProcessConfig) StepsRetry(retry int) *ProcessConfig

+ func (pc *ProcessConfig) StepsTimeout(timeout time.Duration) *ProcessConfig

+ type ProcessInfo struct

+ FlowId string

+ func (bi *ProcessInfo) GetId() string

+ func (bi *ProcessInfo) GetName() string

+ func (vc ProcessInfo) ContextName() string

+ func (vc ProcessInfo) Get(key string) (value any, exist bool)

+ func (vc ProcessInfo) GetAll(key string) map[string]any

+ func (vc ProcessInfo) GetResult(key string) (value any, exist bool)

+ func (vc ProcessInfo) Set(key string, value any)

+ type ProcessMeta struct

+ func (pm *ProcessMeta) AliasStep(alias string, run func(ctx Context) (any, error), depends ...any) *StepMeta

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

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

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

+ type ResultI interface

+ Fails func() []*Future

+ Futures func() []*Future

+ func DoneArgs(name string, args ...any) ResultI

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

+ type Set struct

+ func CreateSetBySliceFunc[T any, K comparable](src []T, transfer func(T) K) *Set[K]

+ func NewRoutineUnsafeSet[T comparable]() *Set[T]

+ func (s *Set[T]) Add(item T)

+ func (s *Set[T]) Contains(item T) bool

+ func (s *Set[T]) Remove(item T)

+ func (s *Set[T]) Size() int

+ func (s *Set[T]) Slice() []T

+ type Status int64

+ func (s *Status) Append(enum *StatusEnum) bool

+ func (s *Status) Contain(enum *StatusEnum) bool

+ func (s *Status) Exceptions() []string

+ func (s *Status) ExplainStatus() []string

+ func (s *Status) Normal() bool

+ func (s *Status) Pop(enum *StatusEnum) bool

+ func (s *Status) Success() bool

+ type StatusEnum struct

+ func (s *StatusEnum) Contained(explain ...string) bool

+ func (s *StatusEnum) Message() string

+ type StatusI interface

+ Contain func(enum *StatusEnum) bool

+ Exceptions func() []string

+ Success func() bool

+ type StepConfig struct

+ StepRetry int

+ StepTimeout time.Duration

+ type StepInfo struct

+ End time.Time

+ Err error

+ FlowId string

+ ProcessId string

+ Start time.Time

+ func (bi StepInfo) GetId() string

+ func (bi StepInfo) GetName() string

+ func (si *StepInfo) Error() error

+ func (vc StepInfo) ContextName() string

+ func (vc StepInfo) Get(key string) (value any, exist bool)

+ func (vc StepInfo) GetAll(key string) map[string]any

+ func (vc StepInfo) GetResult(key string) (value any, exist bool)

+ func (vc StepInfo) Set(key string, value any)

+ type StepMeta struct

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

+ func (meta *StepMeta) Priority(priority map[string]any)

+ func (meta *StepMeta) Retry(retry int) *StepMeta

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

+ func (meta *StepMeta) Timeout(timeout time.Duration) *StepMeta

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