execution

type ExecuteOpts struct {
	ContinueOnErrors    bool
	OrchestratorVersion int32

	WrapWithActions bool
	TaskMake        func(*schema.SerializedInvocation) *tasks.ActionEvent
	TaskTracer      trace.Tracer
	TaskOnDone      tasks.OnDoneFunc

	OnWaiter func(context.Context, Waiter)
}

type Funcs[M proto.Message] struct {
	Aliases          []string
	EmitStart        func(context.Context, *schema.SerializedInvocation, M, chan *orchestration.Event)
	Handle           func(context.Context, *schema.SerializedInvocation, M) (*HandleResult, error)
	HandleWithEvents func(context.Context, *schema.SerializedInvocation, M, chan *orchestration.Event) (*HandleResult, error)
	PlanOrder        func(context.Context, M) (*schema.ScheduleOrder, error)
}

type HandleResult struct {
	Waiter  Waiter
	Outputs []Output
}

type Injection[V any] struct {
	// contains filtered or unexported fields
}

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

type Input struct {
	Message  proto.Message
	Instance any
}

type Inputs map[string]Input

type MakeInjectionInstance interface {
	MakeInjection() []InjectionInstance
}

type MakeInjectionInstanceFunc func() []InjectionInstance

type Output struct {
	InstanceID string
	Message    proto.Message
	Instance   any
}

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

type VFuncs[M proto.Message, V any] struct {
	Parse            func(context.Context, *schema.SerializedInvocation, M) (V, error)
	EmitStart        func(context.Context, *schema.SerializedInvocation, V, chan *orchestration.Event)
	Handle           func(context.Context, *schema.SerializedInvocation, V) (*HandleResult, error)
	HandleWithEvents func(context.Context, *schema.SerializedInvocation, V, chan *orchestration.Event) (*HandleResult, error)
	PlanOrder        func(context.Context, V) (*schema.ScheduleOrder, error)
}

type WaitHandler func(context.Context) (chan *orchestration.Event, func(context.Context) error)

type Waiter func(context.Context, chan *orchestration.Event) error