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 []SelectCase, defaultCase starlark.Value, timeout time.Duration, timeoutValue starlark.Value) (starlark.Value, error)
	// NewChannel constructs a new channel that yields successive values over time.
	NewChannel() Channel
	Sleep(ctx context.Context, duration time.Duration) error
	Timer(duration time.Duration) Future
	WorkflowKey() string
	// Gather waits for all given sources. Each source is either a Future or a
	// Channel. If returnList is false it returns the single source's value;
	// otherwise it returns a starlark.List of values. If timeout is non-zero and
	// elapses before all sources are ready, it returns timeoutValue instead of a
	// result.
	Gather(ctx context.Context, sources []any, timeout time.Duration, timeoutValue starlark.Value, returnList bool) (starlark.Value, error)
	// Poll invokes action repeatedly until check (a CEL expression over the
	// action's returned value, bound as `ret`) is satisfied, re-attempting every
	// interval until timeout elapses. It returns a Future whose Get() yields the
	// action's value on success, or timeoutValue once timeout elapses without
	// check passing.
	Poll(ctx context.Context, action starlark.Callable, check string, args starlark.Tuple, kwargs []starlark.Tuple, interval, timeout time.Duration, timeoutValue starlark.Value) (Future, error)
}

type Channel interface {
	// Receive blocks until the next value is available and returns it.
	Receive() (starlark.Value, error)
	// Name is the channel's identity.
	Name() string
}

type ChannelType struct {
	C Channel
}

type ExecScriptOptions struct {
	Definition []byte
	Backend    Backend
	Tracer     trace.Tracer
	// Args and Kwargs are the positional and keyword arguments bound to the
	// workflow's main() parameters, i.e. main(w, *Args, **Kwargs). Each Kwargs
	// tuple is a (name, value) pair. They are only ever passed as call
	// arguments; the script cannot reach them any other way.
	Args   []starlark.Value
	Kwargs []starlark.Tuple
}

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

type FutureType struct {
	F Future
}

type SelectCase struct {
	Name string
	// Source is the value the case waits on. It holds either a Future or a
	// Channel.
	Source any
}