ogimpl

package

Go to main page

Versions in this module

v0

v0.8.2

May 3, 2025

v0.8.1

Mar 19, 2025

v0.8.0

Mar 16, 2025

Changes in this version

+ const Assert

+ var AssertNodeFactory = func() ogcore.Node

+ func AssertOp(expr string) ograph.ElementOption

+ func ChooseOp(expr string, candidates ...*ograph.Element) ograph.ElementOption

+ func NewAssertNodeFactory(assertFn func(ctx context.Context, state ogcore.State) (bool, error)) func() ogcore.Node

+ type AssertNode struct

+ AssertExpr string

+ AssertFn func(ctx context.Context, state ogcore.State) (bool, error)

+ func (node *AssertNode) Init(params map[string]any) error

+ func (node *AssertNode) Run(ctx context.Context, state ogcore.State) error

v0.7.0

Feb 9, 2025

Changes in this version

+ func ConditionOp(expr string) ograph.ElementOption

+ func LoopWhileOp(expr string) ograph.ElementOption

type ChooseCluster

+ ChooseExpr string

+ func (cluster *ChooseCluster) Init(params map[string]any) error

type ConditionWrapper

+ ConditionExpr string

+ func (wrapper *ConditionWrapper) Init(params map[string]any) error

type LoopWrapper

+ Condition func(ctx context.Context, state ogcore.State) bool

+ ConditionExpr string

+ func (wrapper *LoopWrapper) Init(params map[string]any) error

+ type Visitor struct

+ Identifiers []string

+ func (v *Visitor) Visit(node *ast.Node)

v0.6.1

Dec 28, 2024

v0.6.0

Dec 21, 2024

Changes in this version

+ const AllowRead

+ const AllowWrite

+ const Async

+ const CMD

+ const Choose

+ const Condition

+ const Debug

+ const Delay

+ const HttpReq

+ const Loop

+ const Parallel

+ const Queue

+ const Race

+ const Retry

+ const Silent

+ const Timeout

+ const Trace

+ var AsyncWrapperFactory = func() ogcore.Node

+ var ChooseClusterFactory = func() ogcore.Node

+ var CmdNodeFactory = func() ogcore.Node

+ var ConditionWrapperFactory = func() ogcore.Node

+ var DebugWrapperFactory = func() ogcore.Node

+ var DelayWrapperFactory = func() ogcore.Node

+ var ErrTimeout = errors.New("the running time exceeds the limit")

+ var HttpReqNodeFactory = func() ogcore.Node

+ var LoopWrapperFactory = func() ogcore.Node

+ var ParallelClusterFactory = func() ogcore.Node

+ var QueueClusterFactory = func() ogcore.Node

+ var RaceClusterFactory = func() ogcore.Node

+ var RetryWrapperFactory = func() ogcore.Node

+ var SilentWrapperFactory = NewSilentWrapper

+ var TimeoutWrapperFactory = func() ogcore.Node

+ var TraceWrapperFactory = func() ogcore.Node

+ func DelayOp(wait time.Duration) ograph.ElementOption

+ func LoopOp(n int) ograph.ElementOption

+ func NewChooseClusterFactory(chooseFn func(ctx context.Context, state ogcore.State) int) func() ogcore.Node

+ func NewConditionWrapperFactory(cond func(ctx context.Context, state ogcore.State) bool) func() ogcore.Node

+ func NewRetryWrapper(times int) ogcore.Node

+ func NewSilentWrapper() ogcore.Node

+ func NewTimeoutWrapper(timeout time.Duration) ogcore.Node

+ func RetryOp(n int) ograph.ElementOption

+ func SetTraceId(state ogcore.State, id string)

+ func TimeoutOp(dur time.Duration) ograph.ElementOption

+ type AsyncWrapper struct

+ func (wrapper *AsyncWrapper) Run(ctx context.Context, state ogcore.State) error

+ type ChooseCluster struct

+ ChooseFn func(ctx context.Context, state ogcore.State) int

+ ChooseNode string

+ func (cluster *ChooseCluster) Run(ctx context.Context, state ogcore.State) error

+ type CmdNode struct

+ Cmd []string

+ Dir string

+ Env []string

+ Path string

+ func (node *CmdNode) CmdIsAllowed() bool

+ func (node *CmdNode) Run(ctx context.Context, state ogcore.State) error

+ type ConditionWrapper struct

+ Condition func(ctx context.Context, state ogcore.State) bool

+ Switch string

+ func (wrapper *ConditionWrapper) Run(ctx context.Context, state ogcore.State) error

+ type DebugWrapper struct

+ func (wrapper *DebugWrapper) Run(ctx context.Context, state ogcore.State) error

+ type DelayWrapper struct

+ Until time.Time

+ Wait time.Duration

+ func (wrapper *DelayWrapper) Run(ctx context.Context, state ogcore.State) error

+ type FastState struct

+ func NewFastState() *FastState

+ func (state *FastState) Get(key any) (any, bool)

+ func (state *FastState) Set(key any, val any)

+ func (state *FastState) Update(key any, updateFunc func(val any) any)

+ type GuardState struct

+ func NewGuardState(state ogcore.State, guard func(key any) (flag int)) *GuardState

+ func (state *GuardState) Get(key any) (any, bool)

+ func (state *GuardState) Set(key any, val any)

+ func (state *GuardState) Update(key any, updateFunc func(val any) any)

+ type HookState struct

+ Base ogcore.State

+ Hooks []StateHookFn

+ func NewHookState(base ogcore.State, hooks ...StateHookFn) *HookState

+ func (state *HookState) Get(key any) (any, bool)

+ func (state *HookState) Set(key any, val any)

+ func (state *HookState) Update(key any, updateFunc func(val any) any)

+ type HttpReqNode struct

+ Body *string

+ BodyTpl *string

+ ContentType string

+ Method string

+ Url string

+ func (node *HttpReqNode) Run(ctx context.Context, state ogcore.State) error

+ type LoopWrapper struct

+ LoopInterval time.Duration

+ LoopTimes int

+ func (wrapper *LoopWrapper) Run(ctx context.Context, state ogcore.State) error

+ type OverlayState struct

+ Lower ogcore.State

+ Upper map[any]any

+ func NewOverlayState(state ogcore.State) *OverlayState

+ func (state *OverlayState) Get(key any) (any, bool)

+ func (state *OverlayState) Set(key any, val any)

+ func (state *OverlayState) Sync()

+ func (state *OverlayState) Update(key any, updateFunc func(val any) any)

+ type ParallelCluster struct

+ func (cluster *ParallelCluster) Run(ctx context.Context, state ogcore.State) error

+ type RaceCluster struct

+ StateIsolation bool

+ func (cluster *RaceCluster) Run(ctx context.Context, state ogcore.State) error

+ type RetryWrapper struct

+ MaxRetryTimes int

+ RetryDelay *time.Duration

+ func (wrapper *RetryWrapper) Run(ctx context.Context, state ogcore.State) error

+ type SilentWrapper struct

+ func (wrapper *SilentWrapper) Run(ctx context.Context, state ogcore.State) error

+ type StateHookFn func(state ogcore.State, event string, key any, completed bool)

+ type TimeoutWrapper struct

+ Timeout time.Duration

+ func (wrapper *TimeoutWrapper) Run(ctx context.Context, state ogcore.State) error

+ type TraceWrapper struct

+ func (wrapper *TraceWrapper) Run(ctx context.Context, state ogcore.State) error

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