Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func WithMaxConcurrentTasksLimit ¶
func WithMaxConcurrentTasksLimit(limit int) func(*WorkflowWorkerOptions)
func WithPollerInitialBackoffInterval ¶
func WithPollerInitialBackoffInterval(duration time.Duration) func(*WorkflowWorkerOptions)
func WithPollerMaxBackoffInterval ¶
func WithPollerMaxBackoffInterval(duration time.Duration) func(*WorkflowWorkerOptions)
Types ¶
type WorkflowWorker ¶
type WorkflowWorker struct {
// contains filtered or unexported fields
}
func NewWorkflowWorker ¶
func NewWorkflowWorker( name string, be backend.Backend, registry *registry.WorkflowRegistry, dataConverter dataconverter.DataConverter, logger *zap.Logger, opts ...func(options *WorkflowWorkerOptions), ) *WorkflowWorker
func (*WorkflowWorker) Start ¶
func (w *WorkflowWorker) Start(ctx context.Context)
func (*WorkflowWorker) Stop ¶
func (w *WorkflowWorker) Stop(ctx context.Context)
type WorkflowWorkerOptions ¶
type WorkflowWorkerOptions struct {
WorkerOptions *worker.WorkerOptions
}
func NewWorkflowWorkerOptions ¶
func NewWorkflowWorkerOptions() *WorkflowWorkerOptions
Source Files
Click to show internal directories.
Click to hide internal directories.