Versions in this module Expand all Collapse all v0 v0.19.0 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)
Go to main page