Documentation ¶
Overview ¶
Package task is a generated GoMock package.
Index ¶
- Variables
- func GetOrCreateDomainTaggedScope(shard shard.Context, scopeIdx int, domainID string, logger log.Logger) metrics.Scope
- func GetTimerTaskMetricScope(taskType int, isActive bool) int
- func GetTransferTaskMetricsScope(taskType int, isActive bool) int
- func InitializeLoggerForTask(shardID int, task Info, logger log.Logger) log.Logger
- func NewMockTaskMatcher(mockTask *MockTask) gomock.Matcher
- type Executor
- func NewTimerActiveTaskExecutor(shard shard.Context, archiverClient archiver.Client, ...) Executor
- func NewTimerStandbyTaskExecutor(shard shard.Context, archiverClient archiver.Client, ...) Executor
- func NewTransferActiveTaskExecutor(shard shard.Context, archiverClient archiver.Client, ...) Executor
- func NewTransferStandbyTaskExecutor(shard shard.Context, archiverClient archiver.Client, ...) Executor
- type Filter
- type Info
- type Initializer
- type Key
- type MockExecutor
- type MockExecutorMockRecorder
- type MockInfo
- func (m *MockInfo) EXPECT() *MockInfoMockRecorder
- func (m *MockInfo) GetDomainID() string
- func (m *MockInfo) GetRunID() string
- func (m *MockInfo) GetTaskID() int64
- func (m *MockInfo) GetTaskType() int
- func (m *MockInfo) GetVersion() int64
- func (m *MockInfo) GetVisibilityTimestamp() time.Time
- func (m *MockInfo) GetWorkflowID() string
- type MockInfoMockRecorder
- func (mr *MockInfoMockRecorder) GetDomainID() *gomock.Call
- func (mr *MockInfoMockRecorder) GetRunID() *gomock.Call
- func (mr *MockInfoMockRecorder) GetTaskID() *gomock.Call
- func (mr *MockInfoMockRecorder) GetTaskType() *gomock.Call
- func (mr *MockInfoMockRecorder) GetVersion() *gomock.Call
- func (mr *MockInfoMockRecorder) GetVisibilityTimestamp() *gomock.Call
- func (mr *MockInfoMockRecorder) GetWorkflowID() *gomock.Call
- type MockKey
- type MockKeyMockRecorder
- type MockPriorityAssigner
- type MockPriorityAssignerMockRecorder
- type MockProcessor
- type MockProcessorMockRecorder
- func (mr *MockProcessorMockRecorder) Start() *gomock.Call
- func (mr *MockProcessorMockRecorder) Stop() *gomock.Call
- func (mr *MockProcessorMockRecorder) StopShardProcessor(arg0 interface{}) *gomock.Call
- func (mr *MockProcessorMockRecorder) Submit(arg0 interface{}) *gomock.Call
- func (mr *MockProcessorMockRecorder) TrySubmit(arg0 interface{}) *gomock.Call
- type MockRedispatcher
- type MockRedispatcherMockRecorder
- func (mr *MockRedispatcherMockRecorder) AddTask(arg0 interface{}) *gomock.Call
- func (mr *MockRedispatcherMockRecorder) Redispatch(targetSize interface{}) *gomock.Call
- func (mr *MockRedispatcherMockRecorder) Size() *gomock.Call
- func (mr *MockRedispatcherMockRecorder) Start() *gomock.Call
- func (mr *MockRedispatcherMockRecorder) Stop() *gomock.Call
- type MockTask
- func (m *MockTask) Ack()
- func (m *MockTask) EXPECT() *MockTaskMockRecorder
- func (m *MockTask) Execute() error
- func (m *MockTask) GetAttempt() int
- func (m *MockTask) GetDomainID() string
- func (m *MockTask) GetQueueType() QueueType
- func (m *MockTask) GetRunID() string
- func (m *MockTask) GetShard() shard.Context
- func (m *MockTask) GetTaskID() int64
- func (m *MockTask) GetTaskType() int
- func (m *MockTask) GetVersion() int64
- func (m *MockTask) GetVisibilityTimestamp() time.Time
- func (m *MockTask) GetWorkflowID() string
- func (m *MockTask) HandleErr(err error) error
- func (m *MockTask) Nack()
- func (m *MockTask) Priority() int
- func (m *MockTask) RetryErr(err error) bool
- func (m *MockTask) SetPriority(arg0 int)
- func (m *MockTask) State() task.State
- type MockTaskMockRecorder
- func (mr *MockTaskMockRecorder) Ack() *gomock.Call
- func (mr *MockTaskMockRecorder) Execute() *gomock.Call
- func (mr *MockTaskMockRecorder) GetAttempt() *gomock.Call
- func (mr *MockTaskMockRecorder) GetDomainID() *gomock.Call
- func (mr *MockTaskMockRecorder) GetQueueType() *gomock.Call
- func (mr *MockTaskMockRecorder) GetRunID() *gomock.Call
- func (mr *MockTaskMockRecorder) GetShard() *gomock.Call
- func (mr *MockTaskMockRecorder) GetTaskID() *gomock.Call
- func (mr *MockTaskMockRecorder) GetTaskType() *gomock.Call
- func (mr *MockTaskMockRecorder) GetVersion() *gomock.Call
- func (mr *MockTaskMockRecorder) GetVisibilityTimestamp() *gomock.Call
- func (mr *MockTaskMockRecorder) GetWorkflowID() *gomock.Call
- func (mr *MockTaskMockRecorder) HandleErr(err interface{}) *gomock.Call
- func (mr *MockTaskMockRecorder) Nack() *gomock.Call
- func (mr *MockTaskMockRecorder) Priority() *gomock.Call
- func (mr *MockTaskMockRecorder) RetryErr(err interface{}) *gomock.Call
- func (mr *MockTaskMockRecorder) SetPriority(arg0 interface{}) *gomock.Call
- func (mr *MockTaskMockRecorder) State() *gomock.Call
- type PriorityAssigner
- type Processor
- type QueueAckMgr
- type QueueType
- type Redispatcher
- type RedispatcherOptions
- type Task
- type TimerQueueAckMgr
Constants ¶
This section is empty.
Variables ¶
var ( // ErrTaskDiscarded is the error indicating that the timer / transfer task is pending for too long and discarded. ErrTaskDiscarded = errors.New("passive task pending for too long") // ErrTaskRedispatch is the error indicating that the timer / transfer task should be re0dispatched and retried. ErrTaskRedispatch = errors.New("passive task should be redispatched due to condition in mutable state is not met") // ErrTaskPendingActive is the error indicating that the task should be re-dispatched ErrTaskPendingActive = errors.New("redispatch the task while the domain is pending-active") )
var ( // ErrMissingRequestCancelInfo indicates missing request cancel info ErrMissingRequestCancelInfo = &workflow.InternalServiceError{Message: "unable to get request cancel info"} // ErrMissingSignalInfo indicates missing signal external ErrMissingSignalInfo = &workflow.InternalServiceError{Message: "unable to get signal info"} )
Functions ¶
func GetOrCreateDomainTaggedScope ¶ added in v0.14.0
func GetOrCreateDomainTaggedScope( shard shard.Context, scopeIdx int, domainID string, logger log.Logger, ) metrics.Scope
GetOrCreateDomainTaggedScope returns cached domain-tagged metrics scope if exists otherwise, it creates a new domain-tagged scope, cache and return the scope
func GetTimerTaskMetricScope ¶ added in v0.14.0
GetTimerTaskMetricScope returns the metrics scope index for timer task
func GetTransferTaskMetricsScope ¶ added in v0.14.0
GetTransferTaskMetricsScope returns the metrics scope index for transfer task
func InitializeLoggerForTask ¶ added in v0.14.0
InitializeLoggerForTask creates a new logger with additional tags for task info
func NewMockTaskMatcher ¶ added in v0.14.0
NewMockTaskMatcher creates a gomock matcher for mock Task
Types ¶
type Executor ¶
Executor contains the execution logic for Task
func NewTimerActiveTaskExecutor ¶
func NewTimerActiveTaskExecutor( shard shard.Context, archiverClient archiver.Client, executionCache *execution.Cache, logger log.Logger, metricsClient metrics.Client, config *config.Config, ) Executor
NewTimerActiveTaskExecutor creates a new task executor for active timer task
func NewTimerStandbyTaskExecutor ¶
func NewTimerStandbyTaskExecutor( shard shard.Context, archiverClient archiver.Client, executionCache *execution.Cache, historyRereplicator xdc.HistoryRereplicator, nDCHistoryResender xdc.NDCHistoryResender, logger log.Logger, metricsClient metrics.Client, clusterName string, config *config.Config, ) Executor
NewTimerStandbyTaskExecutor creates a new task executor for standby timer task
func NewTransferActiveTaskExecutor ¶
func NewTransferActiveTaskExecutor( shard shard.Context, archiverClient archiver.Client, executionCache *execution.Cache, workflowResetor reset.WorkflowResetor, workflowResetter reset.WorkflowResetter, logger log.Logger, metricsClient metrics.Client, config *config.Config, ) Executor
NewTransferActiveTaskExecutor creates a new task executor for active transfer task
func NewTransferStandbyTaskExecutor ¶
func NewTransferStandbyTaskExecutor( shard shard.Context, archiverClient archiver.Client, executionCache *execution.Cache, historyRereplicator xdc.HistoryRereplicator, nDCHistoryResender xdc.NDCHistoryResender, logger log.Logger, metricsClient metrics.Client, clusterName string, config *config.Config, ) Executor
NewTransferStandbyTaskExecutor creates a new task executor for standby transfer task
type Info ¶
type Info interface { GetVersion() int64 GetTaskID() int64 GetTaskType() int GetVisibilityTimestamp() time.Time GetWorkflowID() string GetRunID() string GetDomainID() string }
Info contains the metadata for a task
type Initializer ¶ added in v0.14.0
Initializer initializes a Task based on the Info
type MockExecutor ¶
type MockExecutor struct {
// contains filtered or unexported fields
}
MockExecutor is a mock of Executor interface
func NewMockExecutor ¶
func NewMockExecutor(ctrl *gomock.Controller) *MockExecutor
NewMockExecutor creates a new mock instance
func (*MockExecutor) EXPECT ¶
func (m *MockExecutor) EXPECT() *MockExecutorMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
type MockExecutorMockRecorder ¶
type MockExecutorMockRecorder struct {
// contains filtered or unexported fields
}
MockExecutorMockRecorder is the mock recorder for MockExecutor
func (*MockExecutorMockRecorder) Execute ¶
func (mr *MockExecutorMockRecorder) Execute(taskInfo, shouldProcessTask interface{}) *gomock.Call
Execute indicates an expected call of Execute
type MockInfo ¶
type MockInfo struct {
// contains filtered or unexported fields
}
MockInfo is a mock of Info interface
func NewMockInfo ¶
func NewMockInfo(ctrl *gomock.Controller) *MockInfo
NewMockInfo creates a new mock instance
func (*MockInfo) EXPECT ¶
func (m *MockInfo) EXPECT() *MockInfoMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockInfo) GetDomainID ¶
GetDomainID mocks base method
func (*MockInfo) GetVisibilityTimestamp ¶
GetVisibilityTimestamp mocks base method
func (*MockInfo) GetWorkflowID ¶
GetWorkflowID mocks base method
type MockInfoMockRecorder ¶
type MockInfoMockRecorder struct {
// contains filtered or unexported fields
}
MockInfoMockRecorder is the mock recorder for MockInfo
func (*MockInfoMockRecorder) GetDomainID ¶
func (mr *MockInfoMockRecorder) GetDomainID() *gomock.Call
GetDomainID indicates an expected call of GetDomainID
func (*MockInfoMockRecorder) GetRunID ¶
func (mr *MockInfoMockRecorder) GetRunID() *gomock.Call
GetRunID indicates an expected call of GetRunID
func (*MockInfoMockRecorder) GetTaskID ¶
func (mr *MockInfoMockRecorder) GetTaskID() *gomock.Call
GetTaskID indicates an expected call of GetTaskID
func (*MockInfoMockRecorder) GetTaskType ¶
func (mr *MockInfoMockRecorder) GetTaskType() *gomock.Call
GetTaskType indicates an expected call of GetTaskType
func (*MockInfoMockRecorder) GetVersion ¶
func (mr *MockInfoMockRecorder) GetVersion() *gomock.Call
GetVersion indicates an expected call of GetVersion
func (*MockInfoMockRecorder) GetVisibilityTimestamp ¶
func (mr *MockInfoMockRecorder) GetVisibilityTimestamp() *gomock.Call
GetVisibilityTimestamp indicates an expected call of GetVisibilityTimestamp
func (*MockInfoMockRecorder) GetWorkflowID ¶
func (mr *MockInfoMockRecorder) GetWorkflowID() *gomock.Call
GetWorkflowID indicates an expected call of GetWorkflowID
type MockKey ¶
type MockKey struct {
// contains filtered or unexported fields
}
MockKey is a mock of Key interface
func NewMockKey ¶
func NewMockKey(ctrl *gomock.Controller) *MockKey
NewMockKey creates a new mock instance
func (*MockKey) EXPECT ¶
func (m *MockKey) EXPECT() *MockKeyMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
type MockKeyMockRecorder ¶
type MockKeyMockRecorder struct {
// contains filtered or unexported fields
}
MockKeyMockRecorder is the mock recorder for MockKey
func (*MockKeyMockRecorder) Less ¶
func (mr *MockKeyMockRecorder) Less(arg0 interface{}) *gomock.Call
Less indicates an expected call of Less
type MockPriorityAssigner ¶
type MockPriorityAssigner struct {
// contains filtered or unexported fields
}
MockPriorityAssigner is a mock of PriorityAssigner interface
func NewMockPriorityAssigner ¶
func NewMockPriorityAssigner(ctrl *gomock.Controller) *MockPriorityAssigner
NewMockPriorityAssigner creates a new mock instance
func (*MockPriorityAssigner) Assign ¶
func (m *MockPriorityAssigner) Assign(arg0 Task) error
Assign mocks base method
func (*MockPriorityAssigner) EXPECT ¶
func (m *MockPriorityAssigner) EXPECT() *MockPriorityAssignerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
type MockPriorityAssignerMockRecorder ¶
type MockPriorityAssignerMockRecorder struct {
// contains filtered or unexported fields
}
MockPriorityAssignerMockRecorder is the mock recorder for MockPriorityAssigner
func (*MockPriorityAssignerMockRecorder) Assign ¶
func (mr *MockPriorityAssignerMockRecorder) Assign(arg0 interface{}) *gomock.Call
Assign indicates an expected call of Assign
type MockProcessor ¶
type MockProcessor struct {
// contains filtered or unexported fields
}
MockProcessor is a mock of Processor interface
func NewMockProcessor ¶
func NewMockProcessor(ctrl *gomock.Controller) *MockProcessor
NewMockProcessor creates a new mock instance
func (*MockProcessor) EXPECT ¶
func (m *MockProcessor) EXPECT() *MockProcessorMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockProcessor) StopShardProcessor ¶
func (m *MockProcessor) StopShardProcessor(arg0 shard.Context)
StopShardProcessor mocks base method
func (*MockProcessor) Submit ¶
func (m *MockProcessor) Submit(arg0 Task) error
Submit mocks base method
type MockProcessorMockRecorder ¶
type MockProcessorMockRecorder struct {
// contains filtered or unexported fields
}
MockProcessorMockRecorder is the mock recorder for MockProcessor
func (*MockProcessorMockRecorder) Start ¶
func (mr *MockProcessorMockRecorder) Start() *gomock.Call
Start indicates an expected call of Start
func (*MockProcessorMockRecorder) Stop ¶
func (mr *MockProcessorMockRecorder) Stop() *gomock.Call
Stop indicates an expected call of Stop
func (*MockProcessorMockRecorder) StopShardProcessor ¶
func (mr *MockProcessorMockRecorder) StopShardProcessor(arg0 interface{}) *gomock.Call
StopShardProcessor indicates an expected call of StopShardProcessor
func (*MockProcessorMockRecorder) Submit ¶
func (mr *MockProcessorMockRecorder) Submit(arg0 interface{}) *gomock.Call
Submit indicates an expected call of Submit
func (*MockProcessorMockRecorder) TrySubmit ¶
func (mr *MockProcessorMockRecorder) TrySubmit(arg0 interface{}) *gomock.Call
TrySubmit indicates an expected call of TrySubmit
type MockRedispatcher ¶ added in v0.14.0
type MockRedispatcher struct {
// contains filtered or unexported fields
}
MockRedispatcher is a mock of Redispatcher interface
func NewMockRedispatcher ¶ added in v0.14.0
func NewMockRedispatcher(ctrl *gomock.Controller) *MockRedispatcher
NewMockRedispatcher creates a new mock instance
func (*MockRedispatcher) AddTask ¶ added in v0.14.0
func (m *MockRedispatcher) AddTask(arg0 Task)
AddTask mocks base method
func (*MockRedispatcher) EXPECT ¶ added in v0.14.0
func (m *MockRedispatcher) EXPECT() *MockRedispatcherMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockRedispatcher) Redispatch ¶ added in v0.14.0
func (m *MockRedispatcher) Redispatch(targetSize int)
Redispatch mocks base method
func (*MockRedispatcher) Size ¶ added in v0.14.0
func (m *MockRedispatcher) Size() int
Size mocks base method
func (*MockRedispatcher) Start ¶ added in v0.14.0
func (m *MockRedispatcher) Start()
Start mocks base method
func (*MockRedispatcher) Stop ¶ added in v0.14.0
func (m *MockRedispatcher) Stop()
Stop mocks base method
type MockRedispatcherMockRecorder ¶ added in v0.14.0
type MockRedispatcherMockRecorder struct {
// contains filtered or unexported fields
}
MockRedispatcherMockRecorder is the mock recorder for MockRedispatcher
func (*MockRedispatcherMockRecorder) AddTask ¶ added in v0.14.0
func (mr *MockRedispatcherMockRecorder) AddTask(arg0 interface{}) *gomock.Call
AddTask indicates an expected call of AddTask
func (*MockRedispatcherMockRecorder) Redispatch ¶ added in v0.14.0
func (mr *MockRedispatcherMockRecorder) Redispatch(targetSize interface{}) *gomock.Call
Redispatch indicates an expected call of Redispatch
func (*MockRedispatcherMockRecorder) Size ¶ added in v0.14.0
func (mr *MockRedispatcherMockRecorder) Size() *gomock.Call
Size indicates an expected call of Size
func (*MockRedispatcherMockRecorder) Start ¶ added in v0.14.0
func (mr *MockRedispatcherMockRecorder) Start() *gomock.Call
Start indicates an expected call of Start
func (*MockRedispatcherMockRecorder) Stop ¶ added in v0.14.0
func (mr *MockRedispatcherMockRecorder) Stop() *gomock.Call
Stop indicates an expected call of Stop
type MockTask ¶
type MockTask struct {
// contains filtered or unexported fields
}
MockTask is a mock of Task interface
func NewMockTask ¶
func NewMockTask(ctrl *gomock.Controller) *MockTask
NewMockTask creates a new mock instance
func (*MockTask) EXPECT ¶
func (m *MockTask) EXPECT() *MockTaskMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockTask) GetDomainID ¶
GetDomainID mocks base method
func (*MockTask) GetQueueType ¶
GetQueueType mocks base method
func (*MockTask) GetVisibilityTimestamp ¶
GetVisibilityTimestamp mocks base method
func (*MockTask) GetWorkflowID ¶
GetWorkflowID mocks base method
func (*MockTask) SetPriority ¶
SetPriority mocks base method
type MockTaskMockRecorder ¶
type MockTaskMockRecorder struct {
// contains filtered or unexported fields
}
MockTaskMockRecorder is the mock recorder for MockTask
func (*MockTaskMockRecorder) Ack ¶
func (mr *MockTaskMockRecorder) Ack() *gomock.Call
Ack indicates an expected call of Ack
func (*MockTaskMockRecorder) Execute ¶
func (mr *MockTaskMockRecorder) Execute() *gomock.Call
Execute indicates an expected call of Execute
func (*MockTaskMockRecorder) GetAttempt ¶
func (mr *MockTaskMockRecorder) GetAttempt() *gomock.Call
GetAttempt indicates an expected call of GetAttempt
func (*MockTaskMockRecorder) GetDomainID ¶
func (mr *MockTaskMockRecorder) GetDomainID() *gomock.Call
GetDomainID indicates an expected call of GetDomainID
func (*MockTaskMockRecorder) GetQueueType ¶
func (mr *MockTaskMockRecorder) GetQueueType() *gomock.Call
GetQueueType indicates an expected call of GetQueueType
func (*MockTaskMockRecorder) GetRunID ¶
func (mr *MockTaskMockRecorder) GetRunID() *gomock.Call
GetRunID indicates an expected call of GetRunID
func (*MockTaskMockRecorder) GetShard ¶
func (mr *MockTaskMockRecorder) GetShard() *gomock.Call
GetShard indicates an expected call of GetShard
func (*MockTaskMockRecorder) GetTaskID ¶
func (mr *MockTaskMockRecorder) GetTaskID() *gomock.Call
GetTaskID indicates an expected call of GetTaskID
func (*MockTaskMockRecorder) GetTaskType ¶
func (mr *MockTaskMockRecorder) GetTaskType() *gomock.Call
GetTaskType indicates an expected call of GetTaskType
func (*MockTaskMockRecorder) GetVersion ¶
func (mr *MockTaskMockRecorder) GetVersion() *gomock.Call
GetVersion indicates an expected call of GetVersion
func (*MockTaskMockRecorder) GetVisibilityTimestamp ¶
func (mr *MockTaskMockRecorder) GetVisibilityTimestamp() *gomock.Call
GetVisibilityTimestamp indicates an expected call of GetVisibilityTimestamp
func (*MockTaskMockRecorder) GetWorkflowID ¶
func (mr *MockTaskMockRecorder) GetWorkflowID() *gomock.Call
GetWorkflowID indicates an expected call of GetWorkflowID
func (*MockTaskMockRecorder) HandleErr ¶
func (mr *MockTaskMockRecorder) HandleErr(err interface{}) *gomock.Call
HandleErr indicates an expected call of HandleErr
func (*MockTaskMockRecorder) Nack ¶
func (mr *MockTaskMockRecorder) Nack() *gomock.Call
Nack indicates an expected call of Nack
func (*MockTaskMockRecorder) Priority ¶
func (mr *MockTaskMockRecorder) Priority() *gomock.Call
Priority indicates an expected call of Priority
func (*MockTaskMockRecorder) RetryErr ¶
func (mr *MockTaskMockRecorder) RetryErr(err interface{}) *gomock.Call
RetryErr indicates an expected call of RetryErr
func (*MockTaskMockRecorder) SetPriority ¶
func (mr *MockTaskMockRecorder) SetPriority(arg0 interface{}) *gomock.Call
SetPriority indicates an expected call of SetPriority
func (*MockTaskMockRecorder) State ¶
func (mr *MockTaskMockRecorder) State() *gomock.Call
State indicates an expected call of State
type PriorityAssigner ¶
PriorityAssigner assigns priority to Tasks
func NewPriorityAssigner ¶
func NewPriorityAssigner( currentClusterName string, domainCache cache.DomainCache, logger log.Logger, metricClient metrics.Client, config *config.Config, ) PriorityAssigner
NewPriorityAssigner creates a new task priority assigner
type Processor ¶
type Processor interface { common.Daemon StopShardProcessor(shard.Context) Submit(Task) error TrySubmit(Task) (bool, error) }
Processor is the worker pool for processing Tasks
type QueueAckMgr ¶
type QueueAckMgr interface {
CompleteQueueTask(taskID int64)
}
QueueAckMgr is the interface for acking transfer task
type QueueType ¶
type QueueType int
QueueType is the type of task queue
const ( // QueueTypeActiveTransfer is the queue type for active transfer queue processor QueueTypeActiveTransfer QueueType = iota + 1 // QueueTypeStandbyTransfer is the queue type for standby transfer queue processor QueueTypeStandbyTransfer // QueueTypeActiveTimer is the queue type for active timer queue processor QueueTypeActiveTimer // QueueTypeStandbyTimer is the queue type for standby timer queue processor QueueTypeStandbyTimer // QueueTypeReplication is the queue type for replication queue processor QueueTypeReplication )
type Redispatcher ¶ added in v0.14.0
Redispatcher buffers tasks and periodically redispatch them to Processor redispatch can also be triggered immediately by calling the Redispatch method
func NewRedispatcher ¶ added in v0.14.0
func NewRedispatcher( taskProcessor Processor, options *RedispatcherOptions, logger log.Logger, metricsScope metrics.Scope, ) Redispatcher
NewRedispatcher creates a new task Redispatcher
type RedispatcherOptions ¶ added in v0.14.0
type RedispatcherOptions struct { TaskRedispatchInterval dynamicconfig.DurationPropertyFn TaskRedispatchIntervalJitterCoefficient dynamicconfig.FloatPropertyFn }
RedispatcherOptions configs redispatch interval
type Task ¶
type Task interface { task.PriorityTask Info GetQueueType() QueueType GetShard() shard.Context GetAttempt() int }
Task is the interface for all tasks generated by history service
func NewTimerTask ¶
func NewTimerTask( shard shard.Context, taskInfo Info, queueType QueueType, logger log.Logger, taskFilter Filter, taskExecutor Executor, redispatchFn func(task Task), timeSource clock.TimeSource, maxRetryCount dynamicconfig.IntPropertyFn, ackMgr TimerQueueAckMgr, ) Task
NewTimerTask creates a new timer task
func NewTransferTask ¶
func NewTransferTask( shard shard.Context, taskInfo Info, queueType QueueType, logger log.Logger, taskFilter Filter, taskExecutor Executor, redispatchFn func(task Task), timeSource clock.TimeSource, maxRetryCount dynamicconfig.IntPropertyFn, ackMgr QueueAckMgr, ) Task
NewTransferTask creates a new transfer task
type TimerQueueAckMgr ¶
type TimerQueueAckMgr interface {
CompleteTimerTask(timerTask *persistence.TimerTaskInfo)
}
TimerQueueAckMgr is the interface for acking timer task
Source Files ¶
- interface.go
- interface_mock.go
- priority_assigner.go
- processor.go
- redispatcher.go
- standby_task_util.go
- task.go
- task_util.go
- timer_active_task_executor.go
- timer_standby_task_executor.go
- timer_task_executor_base.go
- transfer_active_task_executor.go
- transfer_standby_task_executor.go
- transfer_task_executor_base.go