Documentation
¶
Index ¶
- func WithMaxConcurrentTasksLimit(limit int) func(*ActivityWorkerOptions)
- func WithPollerBackoffMultiplier(multiplier float64) func(*ActivityWorkerOptions)
- func WithPollerInitialBackoffInterval(duration time.Duration) func(*ActivityWorkerOptions)
- func WithPollerMaxBackoffInterval(duration time.Duration) func(*ActivityWorkerOptions)
- func WithTaskProcessorBackoffMultiplier(multiplier float64) func(*ActivityWorkerOptions)
- func WithTaskProcessorInitialBackoffInterval(duration time.Duration) func(*ActivityWorkerOptions)
- func WithTaskProcessorMaxBackoffInterval(duration time.Duration) func(*ActivityWorkerOptions)
- type ActivityWorker
- type ActivityWorkerOptions
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func WithMaxConcurrentTasksLimit ¶
func WithMaxConcurrentTasksLimit(limit int) func(*ActivityWorkerOptions)
func WithPollerBackoffMultiplier ¶
func WithPollerBackoffMultiplier(multiplier float64) func(*ActivityWorkerOptions)
func WithPollerInitialBackoffInterval ¶
func WithPollerInitialBackoffInterval(duration time.Duration) func(*ActivityWorkerOptions)
func WithPollerMaxBackoffInterval ¶
func WithPollerMaxBackoffInterval(duration time.Duration) func(*ActivityWorkerOptions)
func WithTaskProcessorBackoffMultiplier ¶
func WithTaskProcessorBackoffMultiplier(multiplier float64) func(*ActivityWorkerOptions)
func WithTaskProcessorInitialBackoffInterval ¶
func WithTaskProcessorInitialBackoffInterval(duration time.Duration) func(*ActivityWorkerOptions)
func WithTaskProcessorMaxBackoffInterval ¶
func WithTaskProcessorMaxBackoffInterval(duration time.Duration) func(*ActivityWorkerOptions)
Types ¶
type ActivityWorker ¶
type ActivityWorker struct {
// contains filtered or unexported fields
}
func NewActivityWorker ¶
func NewActivityWorker( name string, be backend.Backend, registry *registry.ActivityRegistry, dataConverter dataconverter.DataConverter, logger *zap.Logger, opts ...func(options *ActivityWorkerOptions), ) *ActivityWorker
func (*ActivityWorker) Start ¶
func (a *ActivityWorker) Start(ctx context.Context)
func (*ActivityWorker) Stop ¶
func (a *ActivityWorker) Stop(ctx context.Context)
type ActivityWorkerOptions ¶
type ActivityWorkerOptions struct {
WorkerOptions *worker.WorkerOptions
ActivityTaskProcessorOptions *activity.ActivityTaskProcessorOptions
}
func NewActivityWorkerOptions ¶
func NewActivityWorkerOptions() *ActivityWorkerOptions
Source Files
Click to show internal directories.
Click to hide internal directories.