superflowapi

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

type Def struct {
	Method string
	Route  string
}

type ErrorHandlerIn struct{} // MARKER: ErrorHandler

type ErrorHandlerOut struct{} // MARKER: ErrorHandler

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

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

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

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

type RunSuperSubIn struct{} // MARKER: RunSuperSub

type RunSuperSubOut struct{} // MARKER: RunSuperSub

type SubTaskAIn struct{} // MARKER: SubTaskA

type SubTaskAOut struct{} // MARKER: SubTaskA

type SubTaskBIn struct{} // MARKER: SubTaskB

type SubTaskBOut struct{} // MARKER: SubTaskB

type SuperIn struct {
	Items       []string                `json:"items,omitzero"`
	UseSubgraph bool                    `json:"useSubgraph,omitzero"`
	Behaviors   map[string]TaskBehavior `json:"behaviors,omitzero"`
}

type SuperOut struct{} // MARKER: Super

type SuperSubIn struct {
	Behaviors map[string]TaskBehavior `json:"behaviors,omitzero"`
}

type SuperSubOut struct{} // MARKER: SuperSub

type SuperflowState struct {
	Items       []string                `json:"items,omitzero" jsonschema:"description=Items drives TaskB's forEach fan-out into TaskC"`
	UseSubgraph bool                    `json:"useSubgraph,omitzero" jsonschema:"description=UseSubgraph routes TaskD through SuperSub when true"`
	Behaviors   map[string]TaskBehavior `json:"behaviors,omitzero" jsonschema:"description=Behaviors maps a task name to a per-task behavior knob"`
}

type TaskAIn struct{} // MARKER: TaskA

type TaskAOut struct{} // MARKER: TaskA

type TaskBIn struct{} // MARKER: TaskB

type TaskBOut struct{} // MARKER: TaskB

type TaskBehavior struct {
	SleepMs     int    `json:"sleepMs,omitzero" jsonschema:"description=SleepMs delays the task by this many milliseconds before returning"`
	ErrorStatus int    `json:"errorStatus,omitzero" jsonschema:"description=ErrorStatus returns an error with this HTTP status code"`
	Interrupt   bool   `json:"interrupt,omitzero" jsonschema:"description=Interrupt calls flow.Interrupt(payload) instead of returning normally"`
	Goto        string `json:"goto,omitzero" jsonschema:"description=Goto calls flow.Goto(target) before returning"`
	Retry       bool   `json:"retry,omitzero" jsonschema:"description=Retry calls flow.Retry with an unlimited cap and returns nil"`
}

type TaskCIn struct{} // MARKER: TaskC

type TaskCOut struct{} // MARKER: TaskC

type TaskDIn struct{} // MARKER: TaskD

type TaskDOut struct{} // MARKER: TaskD

type TaskEIn struct{} // MARKER: TaskE

type TaskEOut struct{} // MARKER: TaskE

type TaskZIn struct{} // MARKER: TaskZ

type TaskZOut struct{} // MARKER: TaskZ

type WorkflowRunner interface {
	Run(ctx context.Context, workflowName string, initialState any, opts *workflow.FlowOptions) (outcome *workflow.FlowOutcome, err error)
}