Documentation ¶
Index ¶
- Variables
- func NewWorkflow(workflowFn reflect.Value) *workflow
- func Replaying(ctx sync.Context) bool
- type Activity
- type ErrInvalidActivity
- type ErrInvalidWorkflow
- type ExecutionResult
- type Registry
- type Workflow
- type WorkflowExecutor
- type WorkflowExecutorCache
- type WorkflowExecutorCacheOptions
- type WorkflowHistoryProvider
Constants ¶
This section is empty.
Variables ¶
View Source
var DefaultWorkflowExecutorCacheOptions = WorkflowExecutorCacheOptions{ CacheDuration: 30 * time.Second, }
Functions ¶
func NewWorkflow ¶
Types ¶
type ErrInvalidActivity ¶ added in v0.3.0
type ErrInvalidActivity struct {
// contains filtered or unexported fields
}
func (*ErrInvalidActivity) Error ¶ added in v0.3.0
func (e *ErrInvalidActivity) Error() string
type ErrInvalidWorkflow ¶ added in v0.3.0
type ErrInvalidWorkflow struct {
// contains filtered or unexported fields
}
func (*ErrInvalidWorkflow) Error ¶ added in v0.3.0
func (e *ErrInvalidWorkflow) Error() string
type ExecutionResult ¶ added in v0.0.5
type Registry ¶
func NewRegistry ¶
func NewRegistry() *Registry
func (*Registry) GetActivity ¶
func (*Registry) RegisterActivity ¶
func (*Registry) RegisterWorkflow ¶
type WorkflowExecutor ¶
type WorkflowExecutor interface { ExecuteTask(ctx context.Context, t *task.Workflow) (*ExecutionResult, error) Close() }
func NewExecutor ¶
func NewExecutor(logger log.Logger, tracer trace.Tracer, registry *Registry, historyProvider WorkflowHistoryProvider, instance *core.WorkflowInstance, clock clock.Clock) (WorkflowExecutor, error)
type WorkflowExecutorCache ¶
type WorkflowExecutorCache interface { Store(ctx context.Context, instance *core.WorkflowInstance, workflow WorkflowExecutor) error Get(ctx context.Context, instance *core.WorkflowInstance) (WorkflowExecutor, bool, error) StartEviction(ctx context.Context) }
func NewWorkflowExecutorCache ¶
func NewWorkflowExecutorCache(options WorkflowExecutorCacheOptions) WorkflowExecutorCache
type WorkflowHistoryProvider ¶ added in v0.0.9
Click to show internal directories.
Click to hide internal directories.