workflow

type ActivityPromise struct {
	WorkflowRuntime *WorkflowRuntime
	Activity        any
	Promise         *promise.Promise[[]byte]
}

type TimerPromise struct {
	WorkflowRuntime *WorkflowRuntime
	Promise         *promise.Promise[struct{}]
}

type WorkflowExecutionContext struct {
	WorkflowRuntime *WorkflowRuntime
	UserDefinedVars map[string]any
	EventCallbacks  map[string][]func([]byte)
}

type WorkflowRuntime struct {
	// init
	WorkflowRegistry *registry.WorkflowRegistry
	DataConverter    dataconverter.DataConverter
	// workflow task
	Task *task.WorkflowTask
	// runtime state
	HistoryIndex            int
	IsReplaying             bool
	SequenceNo              int64
	CurrentTimestamp        int64
	ActivityScheduledEvents map[int64]*history.ActivityScheduled
	ActivityPromises        map[int64]*ActivityPromise
	TimerCreatedEvents      map[int64]*history.TimerCreated
	TimerPromises           map[int64]*TimerPromise
	// start
	WorkflowExecutionStartedTimestamp int64
	WorkflowExecutionStartedEvent     *history.WorkflowExecutionStarted
	WorkflowExecutionContext          *WorkflowExecutionContext
	Version                           string
	// final event, can only be execution completed event, and it's internally emit
	WorkflowExecutionCompleted *history.WorkflowExecutionCompleted
}

type WorkflowTaskExecutor interface {
	Execute(ctx context.Context, task *task.WorkflowTask) (*task.WorkflowTaskResult, error)
}