Documentation
¶
Index ¶
- Constants
- func InjectActivityExecutionContext(ctx context.Context, activityExecutionContext *ActivityExecutionContext) context.Context
- func NewActivityTaskProcessor(be backend.Backend, executor ActivityTaskExecutor, logger *zap.Logger, ...) worker.TaskProcessor[*task.ActivityTask, *task.ActivityTaskResult]
- func WithBackoffMultiplier(multiplier float64) func(*ActivityTaskProcessorOptions)
- func WithInitialBackoffInterval(duration time.Duration) func(*ActivityTaskProcessorOptions)
- func WithMaxBackoffInterval(duration time.Duration) func(*ActivityTaskProcessorOptions)
- type ActivityExecutionContext
- type ActivityTaskExecutor
- type ActivityTaskProcessorOptions
Constants ¶
View Source
const ActivityExecutionContextKey = "activityExecutionContext"
Variables ¶
This section is empty.
Functions ¶
func InjectActivityExecutionContext ¶
func InjectActivityExecutionContext(ctx context.Context, activityExecutionContext *ActivityExecutionContext) context.Context
func NewActivityTaskProcessor ¶
func NewActivityTaskProcessor( be backend.Backend, executor ActivityTaskExecutor, logger *zap.Logger, options *ActivityTaskProcessorOptions, ) worker.TaskProcessor[*task.ActivityTask, *task.ActivityTaskResult]
func WithBackoffMultiplier ¶
func WithBackoffMultiplier(multiplier float64) func(*ActivityTaskProcessorOptions)
func WithInitialBackoffInterval ¶
func WithInitialBackoffInterval(duration time.Duration) func(*ActivityTaskProcessorOptions)
func WithMaxBackoffInterval ¶
func WithMaxBackoffInterval(duration time.Duration) func(*ActivityTaskProcessorOptions)
Types ¶
type ActivityExecutionContext ¶
type ActivityExecutionContext struct {
Task *task.ActivityTask
}
func MustExtractActivityExecutionContext ¶
func MustExtractActivityExecutionContext(ctx context.Context) *ActivityExecutionContext
func NewActivityExecutionContext ¶
func NewActivityExecutionContext( task *task.ActivityTask, ) *ActivityExecutionContext
type ActivityTaskExecutor ¶
type ActivityTaskExecutor interface {
Execute(ctx context.Context, task *task.ActivityTask) (*task.ActivityTaskResult, error)
}
func NewActivityTaskExecutor ¶
func NewActivityTaskExecutor( activityRegistry *registry.ActivityRegistry, dataConverter dataconverter.DataConverter, logger *zap.Logger, ) ActivityTaskExecutor
type ActivityTaskProcessorOptions ¶
type ActivityTaskProcessorOptions struct {
InitialBackoffInterval time.Duration
MaxBackoffInterval time.Duration
BackoffMultiplier float64
}
func NewActivityTaskProcessorOptions ¶
func NewActivityTaskProcessorOptions() *ActivityTaskProcessorOptions
Source Files
Click to show internal directories.
Click to hide internal directories.