autoflow

type Backend interface {
	Print(msg string)
	Now() time.Time
	Load(ctx context.Context, thread *starlark.Thread, module string) (starlark.StringDict, error)
	Select(ctx context.Context, cases *starlark.Dict, defaultCase starlark.Value, timeout time.Duration, timeoutValue starlark.Value) (starlark.Value, error)
	Signal(ctx context.Context, workflowID, signalName, payloadJSON, runID string) (bool, error)
	ReceiveChannel(channelName string) (Future, error)
	Sleep(ctx context.Context, duration time.Duration) error
	Timer(duration time.Duration) Future
	WorkflowID() string
	// Gather waits for all given futures. If returnList is false it returns the
	// single future's value; otherwise it returns a starlark.List of values.
	// If timeout is non-zero and elapses before all futures are ready, it returns
	// timeoutValue instead of a result.
	Gather(ctx context.Context, futures []Future, timeout time.Duration, timeoutValue starlark.Value, returnList bool) (starlark.Value, error)
	// Run schedules a built-in activity identified by uri and returns a Future
	// whose Get() yields the activity's decoded output value. args are the
	// remaining positional arguments in stringified form; their meaning is
	// uri-specific and opaque to the engine.
	Run(uri string, args []string) (Future, error)
}

type ExecScriptOptions struct {
	Definition []byte
	Backend    Backend
	Tracer     trace.Tracer
	// ExtraWMembers are merged into the `w` Starlark module that is passed to `main(w).
	ExtraWMembers starlark.StringDict
}

type Future interface {
	Get() (starlark.Value, error)
	Unwrap() any
}

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