executor

Oct 27, 2024

Changes in this version

+ type Cache interface

+ Evict func(ctx context.Context, instance *core.WorkflowInstance) error

+ Get func(ctx context.Context, instance *core.WorkflowInstance) (WorkflowExecutor, bool, error)

+ StartEviction func(ctx context.Context)

+ Store func(ctx context.Context, instance *core.WorkflowInstance, ...) error

+ type ExecutionResult struct

+ ActivityEvents []*history.Event

+ Executed []*history.Event

+ State core.WorkflowInstanceState

+ TimerEvents []*history.Event

+ WorkflowEvents []*history.WorkflowEvent

+ type WorkflowExecutor interface

+ Close func()

+ ExecuteTask func(ctx context.Context, t *backend.WorkflowTask) (*ExecutionResult, error)

+ func NewExecutor(logger *slog.Logger, tracer trace.Tracer, registry *registry.Registry, ...) (WorkflowExecutor, error)

+ type WorkflowHistoryProvider interface

+ GetWorkflowInstanceHistory func(ctx context.Context, instance *core.WorkflowInstance, lastSequenceID *int64) ([]*history.Event, error)