Versions in this module Expand all Collapse all v0 v0.1.0 Sep 1, 2026 Changes in this version + const RunStatusEnded + const RunStatusIdle + const RunStatusNotStarted + const RunStatusPendingRequests + const RunStatusRunning + var Concurrent = newExecutionEnvironment(execution.ModeOffThread, true, nil) + var Default = OffThread + var Lockstep = newExecutionEnvironment(execution.ModeLockstep, false, nil) + var OffThread = newExecutionEnvironment(execution.ModeOffThread, false, nil) + func BindSubworkflowAsExecutor(wf *workflow.Workflow, id string) workflow.ExecutorBinding + type ExecutionEnvironment struct + func (e *ExecutionEnvironment) IsCheckpointingEnabled() bool + func (e *ExecutionEnvironment) OpenStreaming(ctx context.Context, wf *workflow.Workflow, opts ...ExecutionOption) (*StreamingRun, error) + func (e *ExecutionEnvironment) Resume(ctx context.Context, wf *workflow.Workflow, ...) (*Run, error) + func (e *ExecutionEnvironment) ResumeStreaming(ctx context.Context, wf *workflow.Workflow, ...) (*StreamingRun, error) + func (e *ExecutionEnvironment) Run(ctx context.Context, wf *workflow.Workflow, msg any, opts ...ExecutionOption) (*Run, error) + func (e *ExecutionEnvironment) RunStreaming(ctx context.Context, wf *workflow.Workflow, msg any, opts ...ExecutionOption) (*StreamingRun, error) + func (e *ExecutionEnvironment) WithCheckpointing(mgr checkpoint.Manager) *ExecutionEnvironment + type ExecutionOption func(*executionOptions) + func WithPendingRequestRepublish(enabled bool) ExecutionOption + func WithSessionID(sessionID string) ExecutionOption + type Run struct + func (run *Run) Checkpoints() []workflow.CheckpointInfo + func (run *Run) Close(ctx context.Context) error + func (run *Run) GetStatus(ctx context.Context) (RunStatus, error) + func (run *Run) IsCheckpointingEnabled() bool + func (run *Run) LastCheckpoint() (workflow.CheckpointInfo, bool) + func (run *Run) NewEventCount() int + func (run *Run) NewEvents() iter.Seq[workflow.Event] + func (run *Run) OutgoingEvents() iter.Seq[workflow.Event] + func (run *Run) RestoreCheckpoint(ctx context.Context, checkpointInfo workflow.CheckpointInfo) error + func (run *Run) Resume(ctx context.Context, messages ...any) (bool, error) + func (run *Run) RunToNextHalt(ctx context.Context) (bool, error) + func (run *Run) SessionID() string + type RunStatus = execution.RunStatus + type StreamingRun struct + func (stream *StreamingRun) CancelRun() error + func (stream *StreamingRun) Checkpoints() []workflow.CheckpointInfo + func (stream *StreamingRun) Close(ctx context.Context) error + func (stream *StreamingRun) GetStatus(ctx context.Context) (RunStatus, error) + func (stream *StreamingRun) IsCheckpointingEnabled() bool + func (stream *StreamingRun) LastCheckpoint() (workflow.CheckpointInfo, bool) + func (stream *StreamingRun) ResponsePortExecutorID(portID string) (string, bool) + func (stream *StreamingRun) RestoreCheckpoint(ctx context.Context, checkpointInfo workflow.CheckpointInfo) error + func (stream *StreamingRun) SendResponse(ctx context.Context, response *workflow.ExternalResponse) error + func (stream *StreamingRun) SessionID() string + func (stream *StreamingRun) TrySendMessage(ctx context.Context, message any) (bool, error) + func (stream *StreamingRun) WatchStream(ctx context.Context) iter.Seq2[workflow.Event, error] + func (stream *StreamingRun) WatchUntilHalt(ctx context.Context) iter.Seq2[workflow.Event, error]
Go to main page