ogimpl

type AssertNode struct {
	ograph.BaseNode

	AssertExpr string

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

type AsyncWrapper struct {
	ograph.BaseWrapper
	*slog.Logger
}

type ChooseCluster struct {
	ograph.BaseCluster
	*slog.Logger

	ChooseExpr string

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

type CmdNode struct {
	ograph.BaseNode
	*slog.Logger

	Cmd  []string
	Env  []string
	Dir  string
	Path string
}

type ConditionWrapper struct {
	ograph.BaseWrapper

	ConditionExpr string

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

type DebugWrapper struct {
	ograph.BaseWrapper
	*slog.Logger
}

type DelayWrapper struct {
	ograph.BaseWrapper

	Wait  time.Duration
	Until time.Time
}

type FastState struct {
	// contains filtered or unexported fields
}

type GuardState struct {
	// contains filtered or unexported fields
}

type HookState struct {
	Base ogcore.State

	Hooks []StateHookFn
}

type HttpReqNode struct {
	ograph.BaseNode
	*slog.Logger

	Method      string
	Url         string
	ContentType string
	Body        *string
	BodyTpl     *string
}

type LoopWrapper struct {
	ograph.BaseWrapper

	LoopTimes    int
	LoopInterval time.Duration

	ConditionExpr string
	Condition     func(ctx context.Context, state ogcore.State) bool
}

type OverlayState struct {
	Upper map[any]any
	Lower ogcore.State

	sync.RWMutex
}

type ParallelCluster struct {
	ograph.BaseCluster
}

type RaceCluster struct {
	ograph.BaseCluster
	*slog.Logger

	StateIsolation bool
}

type RetryWrapper struct {
	ograph.BaseWrapper
	*slog.Logger

	MaxRetryTimes int
	RetryDelay    *time.Duration
}

type SilentWrapper struct {
	ograph.BaseWrapper
	*slog.Logger
}

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

type TimeoutWrapper struct {
	ograph.BaseWrapper

	Timeout time.Duration
}

type TraceWrapper struct {
	ograph.BaseWrapper
	*slog.Logger
}

type Visitor struct {
	Identifiers []string
}