task

package
v1.3.7-prerelease21 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 2, 2025 License: Apache-2.0 Imports: 47 Imported by: 0

Documentation

Overview

Package task is a generated GoMock package.

Package task is a generated GoMock package.

Index

Constants

This section is empty.

Variables

View Source 
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")
	// ErrTaskPendingActive is the error indicating that the task should be re-dispatched
	ErrTaskPendingActive = errors.New("redispatch the task while the domain is pending-active")
)
View Source 
var (
	// ErrMissingRequestCancelInfo indicates missing request cancel info
	ErrMissingRequestCancelInfo = &types.InternalServiceError{Message: "unable to get request cancel info"}
	// ErrMissingSignalInfo indicates missing signal external
	ErrMissingSignalInfo = &types.InternalServiceError{Message: "unable to get signal info"}
)

Functions

func GetTimerTaskMetricScope added in v0.14.0 

func GetTimerTaskMetricScope(
	taskType int,
	isActive bool,
) metrics.ScopeIdx

GetTimerTaskMetricScope returns the metrics scope index for timer task

func GetTransferTaskMetricsScope added in v0.14.0 

func GetTransferTaskMetricsScope(
	taskType int,
	isActive bool,
) metrics.ScopeIdx

GetTransferTaskMetricsScope returns the metrics scope index for transfer task

func InitializeLoggerForTask added in v0.14.0 

func InitializeLoggerForTask(
	shardID int,
	task persistence.Task,
	logger log.Logger,
) log.Logger

InitializeLoggerForTask creates a new logger with additional tags for task info

func NewMockTaskMatcher added in v0.14.0 

func NewMockTaskMatcher(mockTask *MockTask) gomock.Matcher

NewMockTaskMatcher creates a gomock matcher for mock Task

Types

type CrossClusterTask added in v0.22.0 

type CrossClusterTask interface {
	Task

	IsValid() bool
	IsReadyForPoll() bool
	GetCrossClusterRequest() (*types.CrossClusterTaskRequest, error)
	RecordResponse(*types.CrossClusterTaskResponse) error
}

CrossClusterTask is the interface for processing cross cluster task in the source cluster

type DomainPriorityKey added in v1.2.18 

type DomainPriorityKey struct {
	DomainID string
	Priority int
}

type ExecuteResponse added in v1.3.3 

type ExecuteResponse struct {
	Scope        metrics.Scope
	IsActiveTask bool
}

type Executor 

type Executor interface {
	Execute(task Task) (ExecuteResponse, error)
	Stop()
}

Executor contains the execution logic for Task

func NewExecutorWrapper added in v1.3.2 

func NewExecutorWrapper(
	currentClusterName string,
	activeClusterMgr activecluster.Manager,
	activeExecutor Executor,
	standbyExecutor Executor,
	logger log.Logger,
) Executor

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,
	historyResender ndc.HistoryResender,
	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,
	workflowResetter reset.WorkflowResetter,
	logger log.Logger,
	config *config.Config,
	wfIDCache workflowcache.WFCache,
) Executor

NewTransferActiveTaskExecutor creates a new task executor for active transfer task

func NewTransferStandbyTaskExecutor 

func NewTransferStandbyTaskExecutor(
	shard shard.Context,
	archiverClient archiver.Client,
	executionCache execution.Cache,
	historyResender ndc.HistoryResender,
	logger log.Logger,
	clusterName string,
	config *config.Config,
) Executor

NewTransferStandbyTaskExecutor creates a new task executor for standby transfer task

type Fetcher added in v0.22.0 

type Fetcher interface {
	common.Daemon
	GetSourceCluster() string
	Fetch(shardID int, fetchParams ...interface{}) future.Future
}

Fetcher is a host level component for aggregating task fetch requests from all shards on the host and perform one fetching operation for aggregated requests.

type Fetchers added in v0.22.0 

type Fetchers []Fetcher

Fetchers is a group of Fetchers, one for each source cluster

type Filter 

type Filter func(task persistence.Task) (bool, error)

Filter filters Task

type Initializer added in v0.14.0 

type Initializer func(persistence.Task) Task

Initializer initializes a Task based on the Info

type Key 

type Key interface {
	Less(Key) bool
}

Key identifies a Task and defines a total order among tasks

type MockCrossClusterTask added in v0.23.1 

type MockCrossClusterTask struct {
	// contains filtered or unexported fields
}

MockCrossClusterTask is a mock of CrossClusterTask interface.

func NewMockCrossClusterTask added in v0.23.1 

func NewMockCrossClusterTask(ctrl *gomock.Controller) *MockCrossClusterTask

NewMockCrossClusterTask creates a new mock instance.

func (*MockCrossClusterTask) Ack added in v0.23.1 

func (m *MockCrossClusterTask) Ack()

Ack mocks base method.

func (*MockCrossClusterTask) ByteSize added in v1.3.0 

func (m *MockCrossClusterTask) ByteSize() uint64

ByteSize mocks base method.

func (*MockCrossClusterTask) Cancel added in v1.3.3 

func (m *MockCrossClusterTask) Cancel()

Cancel mocks base method.

func (*MockCrossClusterTask) EXPECT added in v0.23.1 

func (m *MockCrossClusterTask) EXPECT() *MockCrossClusterTaskMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockCrossClusterTask) Execute added in v0.23.1 

func (m *MockCrossClusterTask) Execute() error

Execute mocks base method.

func (*MockCrossClusterTask) GetAttempt added in v0.23.1 

func (m *MockCrossClusterTask) GetAttempt() int

GetAttempt mocks base method.

func (*MockCrossClusterTask) GetCrossClusterRequest added in v0.23.1 

func (m *MockCrossClusterTask) GetCrossClusterRequest() (*types.CrossClusterTaskRequest, error)

GetCrossClusterRequest mocks base method.

func (*MockCrossClusterTask) GetDomainID added in v0.23.1 

func (m *MockCrossClusterTask) GetDomainID() string

GetDomainID mocks base method.

func (*MockCrossClusterTask) GetInfo added in v0.23.1 

func (m *MockCrossClusterTask) GetInfo() persistence.Task

GetInfo mocks base method.

func (*MockCrossClusterTask) GetQueueType added in v0.23.1 

func (m *MockCrossClusterTask) GetQueueType() QueueType

GetQueueType mocks base method.

func (*MockCrossClusterTask) GetRunID added in v0.23.1 

func (m *MockCrossClusterTask) GetRunID() string

GetRunID mocks base method.

func (*MockCrossClusterTask) GetShard added in v0.23.1 

func (m *MockCrossClusterTask) GetShard() shard.Context

GetShard mocks base method.

func (*MockCrossClusterTask) GetTaskCategory added in v1.3.0 

func (m *MockCrossClusterTask) GetTaskCategory() persistence.HistoryTaskCategory

GetTaskCategory mocks base method.

func (*MockCrossClusterTask) GetTaskID added in v0.23.1 

func (m *MockCrossClusterTask) GetTaskID() int64

GetTaskID mocks base method.

func (*MockCrossClusterTask) GetTaskKey added in v1.3.1 

func (m *MockCrossClusterTask) GetTaskKey() persistence.HistoryTaskKey

GetTaskKey mocks base method.

func (*MockCrossClusterTask) GetTaskType added in v0.23.1 

func (m *MockCrossClusterTask) GetTaskType() int

GetTaskType mocks base method.

func (*MockCrossClusterTask) GetVersion added in v0.23.1 

func (m *MockCrossClusterTask) GetVersion() int64

GetVersion mocks base method.

func (*MockCrossClusterTask) GetVisibilityTimestamp added in v0.23.1 

func (m *MockCrossClusterTask) GetVisibilityTimestamp() time.Time

GetVisibilityTimestamp mocks base method.

func (*MockCrossClusterTask) GetWorkflowID added in v0.23.1 

func (m *MockCrossClusterTask) GetWorkflowID() string

GetWorkflowID mocks base method.

func (*MockCrossClusterTask) HandleErr added in v0.23.1 

func (m *MockCrossClusterTask) HandleErr(err error) error

HandleErr mocks base method.

func (*MockCrossClusterTask) IsReadyForPoll added in v0.23.1 

func (m *MockCrossClusterTask) IsReadyForPoll() bool

IsReadyForPoll mocks base method.

func (*MockCrossClusterTask) IsValid added in v0.23.1 

func (m *MockCrossClusterTask) IsValid() bool

IsValid mocks base method.

func (*MockCrossClusterTask) Nack added in v0.23.1 

func (m *MockCrossClusterTask) Nack(err error)

Nack mocks base method.

func (*MockCrossClusterTask) Priority added in v0.23.1 

func (m *MockCrossClusterTask) Priority() int

Priority mocks base method.

func (*MockCrossClusterTask) RecordResponse added in v0.24.0 

func (m *MockCrossClusterTask) RecordResponse(arg0 *types.CrossClusterTaskResponse) error

RecordResponse mocks base method.

func (*MockCrossClusterTask) RetryErr added in v0.23.1 

func (m *MockCrossClusterTask) RetryErr(err error) bool

RetryErr mocks base method.

func (*MockCrossClusterTask) SetInitialSubmitTime added in v1.3.3 

func (m *MockCrossClusterTask) SetInitialSubmitTime(arg0 time.Time)

SetInitialSubmitTime mocks base method.

func (*MockCrossClusterTask) SetPriority added in v0.23.1 

func (m *MockCrossClusterTask) SetPriority(arg0 int)

SetPriority mocks base method.

func (*MockCrossClusterTask) SetTaskID added in v1.3.0 

func (m *MockCrossClusterTask) SetTaskID(id int64)

SetTaskID mocks base method.

func (*MockCrossClusterTask) SetVersion added in v1.3.0 

func (m *MockCrossClusterTask) SetVersion(version int64)

SetVersion mocks base method.

func (*MockCrossClusterTask) SetVisibilityTimestamp added in v1.3.0 

func (m *MockCrossClusterTask) SetVisibilityTimestamp(timestamp time.Time)

SetVisibilityTimestamp mocks base method.

func (*MockCrossClusterTask) State added in v0.23.1 

func (m *MockCrossClusterTask) State() task.State

State mocks base method.

func (*MockCrossClusterTask) ToInternalReplicationTaskInfo added in v1.3.0 

func (m *MockCrossClusterTask) ToInternalReplicationTaskInfo() (*types.ReplicationTaskInfo, error)

ToInternalReplicationTaskInfo mocks base method.

func (*MockCrossClusterTask) ToTimerTaskInfo added in v1.3.0 

func (m *MockCrossClusterTask) ToTimerTaskInfo() (*persistence.TimerTaskInfo, error)

ToTimerTaskInfo mocks base method.

func (*MockCrossClusterTask) ToTransferTaskInfo added in v1.3.0 

func (m *MockCrossClusterTask) ToTransferTaskInfo() (*persistence.TransferTaskInfo, error)

ToTransferTaskInfo mocks base method.

type MockCrossClusterTaskMockRecorder added in v0.23.1 

type MockCrossClusterTaskMockRecorder struct {
	// contains filtered or unexported fields
}

MockCrossClusterTaskMockRecorder is the mock recorder for MockCrossClusterTask.

func (*MockCrossClusterTaskMockRecorder) Ack added in v0.23.1 

func (mr *MockCrossClusterTaskMockRecorder) Ack() *gomock.Call

Ack indicates an expected call of Ack.

func (*MockCrossClusterTaskMockRecorder) ByteSize added in v1.3.0 

func (mr *MockCrossClusterTaskMockRecorder) ByteSize() *gomock.Call

ByteSize indicates an expected call of ByteSize.

func (*MockCrossClusterTaskMockRecorder) Cancel added in v1.3.3 

func (mr *MockCrossClusterTaskMockRecorder) Cancel() *gomock.Call

Cancel indicates an expected call of Cancel.

func (*MockCrossClusterTaskMockRecorder) Execute added in v0.23.1 

func (mr *MockCrossClusterTaskMockRecorder) Execute() *gomock.Call

Execute indicates an expected call of Execute.

func (*MockCrossClusterTaskMockRecorder) GetAttempt added in v0.23.1 

func (mr *MockCrossClusterTaskMockRecorder) GetAttempt() *gomock.Call

GetAttempt indicates an expected call of GetAttempt.

func (*MockCrossClusterTaskMockRecorder) GetCrossClusterRequest added in v0.23.1 

func (mr *MockCrossClusterTaskMockRecorder) GetCrossClusterRequest() *gomock.Call

GetCrossClusterRequest indicates an expected call of GetCrossClusterRequest.

func (*MockCrossClusterTaskMockRecorder) GetDomainID added in v0.23.1 

func (mr *MockCrossClusterTaskMockRecorder) GetDomainID() *gomock.Call

GetDomainID indicates an expected call of GetDomainID.

func (*MockCrossClusterTaskMockRecorder) GetInfo added in v0.23.1 

func (mr *MockCrossClusterTaskMockRecorder) GetInfo() *gomock.Call

GetInfo indicates an expected call of GetInfo.

func (*MockCrossClusterTaskMockRecorder) GetQueueType added in v0.23.1 

func (mr *MockCrossClusterTaskMockRecorder) GetQueueType() *gomock.Call

GetQueueType indicates an expected call of GetQueueType.

func (*MockCrossClusterTaskMockRecorder) GetRunID added in v0.23.1 

func (mr *MockCrossClusterTaskMockRecorder) GetRunID() *gomock.Call

GetRunID indicates an expected call of GetRunID.

func (*MockCrossClusterTaskMockRecorder) GetShard added in v0.23.1 

func (mr *MockCrossClusterTaskMockRecorder) GetShard() *gomock.Call

GetShard indicates an expected call of GetShard.

func (*MockCrossClusterTaskMockRecorder) GetTaskCategory added in v1.3.0 

func (mr *MockCrossClusterTaskMockRecorder) GetTaskCategory() *gomock.Call

GetTaskCategory indicates an expected call of GetTaskCategory.

func (*MockCrossClusterTaskMockRecorder) GetTaskID added in v0.23.1 

func (mr *MockCrossClusterTaskMockRecorder) GetTaskID() *gomock.Call

GetTaskID indicates an expected call of GetTaskID.

func (*MockCrossClusterTaskMockRecorder) GetTaskKey added in v1.3.1 

func (mr *MockCrossClusterTaskMockRecorder) GetTaskKey() *gomock.Call

GetTaskKey indicates an expected call of GetTaskKey.

func (*MockCrossClusterTaskMockRecorder) GetTaskType added in v0.23.1 

func (mr *MockCrossClusterTaskMockRecorder) GetTaskType() *gomock.Call

GetTaskType indicates an expected call of GetTaskType.

func (*MockCrossClusterTaskMockRecorder) GetVersion added in v0.23.1 

func (mr *MockCrossClusterTaskMockRecorder) GetVersion() *gomock.Call

GetVersion indicates an expected call of GetVersion.

func (*MockCrossClusterTaskMockRecorder) GetVisibilityTimestamp added in v0.23.1 

func (mr *MockCrossClusterTaskMockRecorder) GetVisibilityTimestamp() *gomock.Call

GetVisibilityTimestamp indicates an expected call of GetVisibilityTimestamp.

func (*MockCrossClusterTaskMockRecorder) GetWorkflowID added in v0.23.1 

func (mr *MockCrossClusterTaskMockRecorder) GetWorkflowID() *gomock.Call

GetWorkflowID indicates an expected call of GetWorkflowID.

func (*MockCrossClusterTaskMockRecorder) HandleErr added in v0.23.1 

func (mr *MockCrossClusterTaskMockRecorder) HandleErr(err any) *gomock.Call

HandleErr indicates an expected call of HandleErr.

func (*MockCrossClusterTaskMockRecorder) IsReadyForPoll added in v0.23.1 

func (mr *MockCrossClusterTaskMockRecorder) IsReadyForPoll() *gomock.Call

IsReadyForPoll indicates an expected call of IsReadyForPoll.

func (*MockCrossClusterTaskMockRecorder) IsValid added in v0.23.1 

func (mr *MockCrossClusterTaskMockRecorder) IsValid() *gomock.Call

IsValid indicates an expected call of IsValid.

func (*MockCrossClusterTaskMockRecorder) Nack added in v0.23.1 

func (mr *MockCrossClusterTaskMockRecorder) Nack(err any) *gomock.Call

Nack indicates an expected call of Nack.

func (*MockCrossClusterTaskMockRecorder) Priority added in v0.23.1 

func (mr *MockCrossClusterTaskMockRecorder) Priority() *gomock.Call

Priority indicates an expected call of Priority.

func (*MockCrossClusterTaskMockRecorder) RecordResponse added in v0.24.0 

func (mr *MockCrossClusterTaskMockRecorder) RecordResponse(arg0 any) *gomock.Call

RecordResponse indicates an expected call of RecordResponse.

func (*MockCrossClusterTaskMockRecorder) RetryErr added in v0.23.1 

func (mr *MockCrossClusterTaskMockRecorder) RetryErr(err any) *gomock.Call

RetryErr indicates an expected call of RetryErr.

func (*MockCrossClusterTaskMockRecorder) SetInitialSubmitTime added in v1.3.3 

func (mr *MockCrossClusterTaskMockRecorder) SetInitialSubmitTime(arg0 any) *gomock.Call

SetInitialSubmitTime indicates an expected call of SetInitialSubmitTime.

func (*MockCrossClusterTaskMockRecorder) SetPriority added in v0.23.1 

func (mr *MockCrossClusterTaskMockRecorder) SetPriority(arg0 any) *gomock.Call

SetPriority indicates an expected call of SetPriority.

func (*MockCrossClusterTaskMockRecorder) SetTaskID added in v1.3.0 

func (mr *MockCrossClusterTaskMockRecorder) SetTaskID(id any) *gomock.Call

SetTaskID indicates an expected call of SetTaskID.

func (*MockCrossClusterTaskMockRecorder) SetVersion added in v1.3.0 

func (mr *MockCrossClusterTaskMockRecorder) SetVersion(version any) *gomock.Call

SetVersion indicates an expected call of SetVersion.

func (*MockCrossClusterTaskMockRecorder) SetVisibilityTimestamp added in v1.3.0 

func (mr *MockCrossClusterTaskMockRecorder) SetVisibilityTimestamp(timestamp any) *gomock.Call

SetVisibilityTimestamp indicates an expected call of SetVisibilityTimestamp.

func (*MockCrossClusterTaskMockRecorder) State added in v0.23.1 

func (mr *MockCrossClusterTaskMockRecorder) State() *gomock.Call

State indicates an expected call of State.

func (*MockCrossClusterTaskMockRecorder) ToInternalReplicationTaskInfo added in v1.3.0 

func (mr *MockCrossClusterTaskMockRecorder) ToInternalReplicationTaskInfo() *gomock.Call

ToInternalReplicationTaskInfo indicates an expected call of ToInternalReplicationTaskInfo.

func (*MockCrossClusterTaskMockRecorder) ToTimerTaskInfo added in v1.3.0 

func (mr *MockCrossClusterTaskMockRecorder) ToTimerTaskInfo() *gomock.Call

ToTimerTaskInfo indicates an expected call of ToTimerTaskInfo.

func (*MockCrossClusterTaskMockRecorder) ToTransferTaskInfo added in v1.3.0 

func (mr *MockCrossClusterTaskMockRecorder) ToTransferTaskInfo() *gomock.Call

ToTransferTaskInfo indicates an expected call of ToTransferTaskInfo.

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.

func (*MockExecutor) Execute 

func (m *MockExecutor) Execute(task Task) (ExecuteResponse, error)

Execute mocks base method.

func (*MockExecutor) Stop added in v1.2.10 

func (m *MockExecutor) Stop()

Stop mocks base method.

type MockExecutorMockRecorder 

type MockExecutorMockRecorder struct {
	// contains filtered or unexported fields
}

MockExecutorMockRecorder is the mock recorder for MockExecutor.

func (*MockExecutorMockRecorder) Execute 

func (mr *MockExecutorMockRecorder) Execute(task any) *gomock.Call

Execute indicates an expected call of Execute.

func (*MockExecutorMockRecorder) Stop added in v1.2.10 

func (mr *MockExecutorMockRecorder) Stop() *gomock.Call

Stop indicates an expected call of Stop.

type MockFetcher added in v0.22.0 

type MockFetcher struct {
	// contains filtered or unexported fields
}

MockFetcher is a mock of Fetcher interface.

func NewMockFetcher added in v0.22.0 

func NewMockFetcher(ctrl *gomock.Controller) *MockFetcher

NewMockFetcher creates a new mock instance.

func (*MockFetcher) EXPECT added in v0.22.0 

func (m *MockFetcher) EXPECT() *MockFetcherMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockFetcher) Fetch added in v0.22.0 

func (m *MockFetcher) Fetch(shardID int, fetchParams ...any) future.Future

Fetch mocks base method.

func (*MockFetcher) GetSourceCluster added in v0.22.0 

func (m *MockFetcher) GetSourceCluster() string

GetSourceCluster mocks base method.

func (*MockFetcher) Start added in v0.22.0 

func (m *MockFetcher) Start()

Start mocks base method.

func (*MockFetcher) Stop added in v0.22.0 

func (m *MockFetcher) Stop()

Stop mocks base method.

type MockFetcherMockRecorder added in v0.22.0 

type MockFetcherMockRecorder struct {
	// contains filtered or unexported fields
}

MockFetcherMockRecorder is the mock recorder for MockFetcher.

func (*MockFetcherMockRecorder) Fetch added in v0.22.0 

func (mr *MockFetcherMockRecorder) Fetch(shardID any, fetchParams ...any) *gomock.Call

Fetch indicates an expected call of Fetch.

func (*MockFetcherMockRecorder) GetSourceCluster added in v0.22.0 

func (mr *MockFetcherMockRecorder) GetSourceCluster() *gomock.Call

GetSourceCluster indicates an expected call of GetSourceCluster.

func (*MockFetcherMockRecorder) Start added in v0.22.0 

func (mr *MockFetcherMockRecorder) Start() *gomock.Call

Start indicates an expected call of Start.

func (*MockFetcherMockRecorder) Stop added in v0.22.0 

func (mr *MockFetcherMockRecorder) Stop() *gomock.Call

Stop indicates an expected call of Stop.

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.

func (*MockKey) Less 

func (m *MockKey) Less(arg0 Key) bool

Less mocks base method.

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 any) *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 any) *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) Start 

func (m *MockProcessor) Start()

Start mocks base method.

func (*MockProcessor) Stop 

func (m *MockProcessor) Stop()

Stop mocks base method.

func (*MockProcessor) Submit 

func (m *MockProcessor) Submit(arg0 Task) error

Submit mocks base method.

func (*MockProcessor) TrySubmit 

func (m *MockProcessor) TrySubmit(arg0 Task) (bool, error)

TrySubmit 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) Submit 

func (mr *MockProcessorMockRecorder) Submit(arg0 any) *gomock.Call

Submit indicates an expected call of Submit.

func (*MockProcessorMockRecorder) TrySubmit 

func (mr *MockProcessorMockRecorder) TrySubmit(arg0 any) *gomock.Call

TrySubmit indicates an expected call of TrySubmit.

type MockRateLimiter added in v1.2.18 

type MockRateLimiter struct {
	// contains filtered or unexported fields
}

MockRateLimiter is a mock of RateLimiter interface.

func NewMockRateLimiter added in v1.2.18 

func NewMockRateLimiter(ctrl *gomock.Controller) *MockRateLimiter

NewMockRateLimiter creates a new mock instance.

func (*MockRateLimiter) Allow added in v1.2.18 

func (m *MockRateLimiter) Allow(arg0 Task) bool

Allow mocks base method.

func (*MockRateLimiter) EXPECT added in v1.2.18 

func (m *MockRateLimiter) EXPECT() *MockRateLimiterMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockRateLimiter) Wait added in v1.2.18 

func (m *MockRateLimiter) Wait(arg0 context.Context, arg1 Task) error

Wait mocks base method.

type MockRateLimiterMockRecorder added in v1.2.18 

type MockRateLimiterMockRecorder struct {
	// contains filtered or unexported fields
}

MockRateLimiterMockRecorder is the mock recorder for MockRateLimiter.

func (*MockRateLimiterMockRecorder) Allow added in v1.2.18 

func (mr *MockRateLimiterMockRecorder) Allow(arg0 any) *gomock.Call

Allow indicates an expected call of Allow.

func (*MockRateLimiterMockRecorder) Wait added in v1.2.18 

func (mr *MockRateLimiterMockRecorder) Wait(arg0, arg1 any) *gomock.Call

Wait indicates an expected call of Wait.

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) RedispatchTask added in v1.3.2 

func (m *MockRedispatcher) RedispatchTask(arg0 Task, arg1 time.Time)

RedispatchTask 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 any) *gomock.Call

AddTask indicates an expected call of AddTask.

func (*MockRedispatcherMockRecorder) Redispatch added in v0.14.0 

func (mr *MockRedispatcherMockRecorder) Redispatch(targetSize any) *gomock.Call

Redispatch indicates an expected call of Redispatch.

func (*MockRedispatcherMockRecorder) RedispatchTask added in v1.3.2 

func (mr *MockRedispatcherMockRecorder) RedispatchTask(arg0, arg1 any) *gomock.Call

RedispatchTask indicates an expected call of RedispatchTask.

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 MockRescheduler added in v1.3.5 

type MockRescheduler struct {
	// contains filtered or unexported fields
}

MockRescheduler is a mock of Rescheduler interface.

func NewMockRescheduler added in v1.3.5 

func NewMockRescheduler(ctrl *gomock.Controller) *MockRescheduler

NewMockRescheduler creates a new mock instance.

func (*MockRescheduler) EXPECT added in v1.3.5 

func (m *MockRescheduler) EXPECT() *MockReschedulerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockRescheduler) RescheduleDomains added in v1.3.5 

func (m *MockRescheduler) RescheduleDomains(domainIDs map[string]struct{})

RescheduleDomains mocks base method.

func (*MockRescheduler) RescheduleTask added in v1.3.5 

func (m *MockRescheduler) RescheduleTask(arg0 Task, arg1 time.Time)

RescheduleTask mocks base method.

func (*MockRescheduler) Size added in v1.3.5 

func (m *MockRescheduler) Size() int

Size mocks base method.

func (*MockRescheduler) Start added in v1.3.5 

func (m *MockRescheduler) Start()

Start mocks base method.

func (*MockRescheduler) Stop added in v1.3.5 

func (m *MockRescheduler) Stop()

Stop mocks base method.

type MockReschedulerMockRecorder added in v1.3.5 

type MockReschedulerMockRecorder struct {
	// contains filtered or unexported fields
}

MockReschedulerMockRecorder is the mock recorder for MockRescheduler.

func (*MockReschedulerMockRecorder) RescheduleDomains added in v1.3.5 

func (mr *MockReschedulerMockRecorder) RescheduleDomains(domainIDs any) *gomock.Call

RescheduleDomains indicates an expected call of RescheduleDomains.

func (*MockReschedulerMockRecorder) RescheduleTask added in v1.3.5 

func (mr *MockReschedulerMockRecorder) RescheduleTask(arg0, arg1 any) *gomock.Call

RescheduleTask indicates an expected call of RescheduleTask.

func (*MockReschedulerMockRecorder) Size added in v1.3.5 

func (mr *MockReschedulerMockRecorder) Size() *gomock.Call

Size indicates an expected call of Size.

func (*MockReschedulerMockRecorder) Start added in v1.3.5 

func (mr *MockReschedulerMockRecorder) Start() *gomock.Call

Start indicates an expected call of Start.

func (*MockReschedulerMockRecorder) Stop added in v1.3.5 

func (mr *MockReschedulerMockRecorder) 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) Ack 

func (m *MockTask) Ack()

Ack mocks base method.

func (*MockTask) ByteSize added in v1.3.0 

func (m *MockTask) ByteSize() uint64

ByteSize mocks base method.

func (*MockTask) Cancel added in v1.3.3 

func (m *MockTask) Cancel()

Cancel mocks base method.

func (*MockTask) EXPECT 

func (m *MockTask) EXPECT() *MockTaskMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockTask) Execute 

func (m *MockTask) Execute() error

Execute mocks base method.

func (*MockTask) GetAttempt 

func (m *MockTask) GetAttempt() int

GetAttempt mocks base method.

func (*MockTask) GetDomainID 

func (m *MockTask) GetDomainID() string

GetDomainID mocks base method.

func (*MockTask) GetInfo added in v0.23.1 

func (m *MockTask) GetInfo() persistence.Task

GetInfo mocks base method.

func (*MockTask) GetQueueType 

func (m *MockTask) GetQueueType() QueueType

GetQueueType mocks base method.

func (*MockTask) GetRunID 

func (m *MockTask) GetRunID() string

GetRunID mocks base method.

func (*MockTask) GetShard 

func (m *MockTask) GetShard() shard.Context

GetShard mocks base method.

func (*MockTask) GetTaskCategory added in v1.3.0 

func (m *MockTask) GetTaskCategory() persistence.HistoryTaskCategory

GetTaskCategory mocks base method.

func (*MockTask) GetTaskID 

func (m *MockTask) GetTaskID() int64

GetTaskID mocks base method.

func (*MockTask) GetTaskKey added in v1.3.1 

func (m *MockTask) GetTaskKey() persistence.HistoryTaskKey

GetTaskKey mocks base method.

func (*MockTask) GetTaskType 

func (m *MockTask) GetTaskType() int

GetTaskType mocks base method.

func (*MockTask) GetVersion 

func (m *MockTask) GetVersion() int64

GetVersion mocks base method.

func (*MockTask) GetVisibilityTimestamp 

func (m *MockTask) GetVisibilityTimestamp() time.Time

GetVisibilityTimestamp mocks base method.

func (*MockTask) GetWorkflowID 

func (m *MockTask) GetWorkflowID() string

GetWorkflowID mocks base method.

func (*MockTask) HandleErr 

func (m *MockTask) HandleErr(err error) error

HandleErr mocks base method.

func (*MockTask) Nack 

func (m *MockTask) Nack(err error)

Nack mocks base method.

func (*MockTask) Priority 

func (m *MockTask) Priority() int

Priority mocks base method.

func (*MockTask) RetryErr 

func (m *MockTask) RetryErr(err error) bool

RetryErr mocks base method.

func (*MockTask) SetInitialSubmitTime added in v1.3.3 

func (m *MockTask) SetInitialSubmitTime(arg0 time.Time)

SetInitialSubmitTime mocks base method.

func (*MockTask) SetPriority 

func (m *MockTask) SetPriority(arg0 int)

SetPriority mocks base method.

func (*MockTask) SetTaskID added in v1.3.0 

func (m *MockTask) SetTaskID(id int64)

SetTaskID mocks base method.

func (*MockTask) SetVersion added in v1.3.0 

func (m *MockTask) SetVersion(version int64)

SetVersion mocks base method.

func (*MockTask) SetVisibilityTimestamp added in v1.3.0 

func (m *MockTask) SetVisibilityTimestamp(timestamp time.Time)

SetVisibilityTimestamp mocks base method.

func (*MockTask) State 

func (m *MockTask) State() task.State

State mocks base method.

func (*MockTask) ToInternalReplicationTaskInfo added in v1.3.0 

func (m *MockTask) ToInternalReplicationTaskInfo() (*types.ReplicationTaskInfo, error)

ToInternalReplicationTaskInfo mocks base method.

func (*MockTask) ToTimerTaskInfo added in v1.3.0 

func (m *MockTask) ToTimerTaskInfo() (*persistence.TimerTaskInfo, error)

ToTimerTaskInfo mocks base method.

func (*MockTask) ToTransferTaskInfo added in v1.3.0 

func (m *MockTask) ToTransferTaskInfo() (*persistence.TransferTaskInfo, error)

ToTransferTaskInfo 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) ByteSize added in v1.3.0 

func (mr *MockTaskMockRecorder) ByteSize() *gomock.Call

ByteSize indicates an expected call of ByteSize.

func (*MockTaskMockRecorder) Cancel added in v1.3.3 

func (mr *MockTaskMockRecorder) Cancel() *gomock.Call

Cancel indicates an expected call of Cancel.

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) GetInfo added in v0.23.1 

func (mr *MockTaskMockRecorder) GetInfo() *gomock.Call

GetInfo indicates an expected call of GetInfo.

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) GetTaskCategory added in v1.3.0 

func (mr *MockTaskMockRecorder) GetTaskCategory() *gomock.Call

GetTaskCategory indicates an expected call of GetTaskCategory.

func (*MockTaskMockRecorder) GetTaskID 

func (mr *MockTaskMockRecorder) GetTaskID() *gomock.Call

GetTaskID indicates an expected call of GetTaskID.

func (*MockTaskMockRecorder) GetTaskKey added in v1.3.1 

func (mr *MockTaskMockRecorder) GetTaskKey() *gomock.Call

GetTaskKey indicates an expected call of GetTaskKey.

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 any) *gomock.Call

HandleErr indicates an expected call of HandleErr.

func (*MockTaskMockRecorder) Nack 

func (mr *MockTaskMockRecorder) Nack(err any) *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 any) *gomock.Call

RetryErr indicates an expected call of RetryErr.

func (*MockTaskMockRecorder) SetInitialSubmitTime added in v1.3.3 

func (mr *MockTaskMockRecorder) SetInitialSubmitTime(arg0 any) *gomock.Call

SetInitialSubmitTime indicates an expected call of SetInitialSubmitTime.

func (*MockTaskMockRecorder) SetPriority 

func (mr *MockTaskMockRecorder) SetPriority(arg0 any) *gomock.Call

SetPriority indicates an expected call of SetPriority.

func (*MockTaskMockRecorder) SetTaskID added in v1.3.0 

func (mr *MockTaskMockRecorder) SetTaskID(id any) *gomock.Call

SetTaskID indicates an expected call of SetTaskID.

func (*MockTaskMockRecorder) SetVersion added in v1.3.0 

func (mr *MockTaskMockRecorder) SetVersion(version any) *gomock.Call

SetVersion indicates an expected call of SetVersion.

func (*MockTaskMockRecorder) SetVisibilityTimestamp added in v1.3.0 

func (mr *MockTaskMockRecorder) SetVisibilityTimestamp(timestamp any) *gomock.Call

SetVisibilityTimestamp indicates an expected call of SetVisibilityTimestamp.

func (*MockTaskMockRecorder) State 

func (mr *MockTaskMockRecorder) State() *gomock.Call

State indicates an expected call of State.

func (*MockTaskMockRecorder) ToInternalReplicationTaskInfo added in v1.3.0 

func (mr *MockTaskMockRecorder) ToInternalReplicationTaskInfo() *gomock.Call

ToInternalReplicationTaskInfo indicates an expected call of ToInternalReplicationTaskInfo.

func (*MockTaskMockRecorder) ToTimerTaskInfo added in v1.3.0 

func (mr *MockTaskMockRecorder) ToTimerTaskInfo() *gomock.Call

ToTimerTaskInfo indicates an expected call of ToTimerTaskInfo.

func (*MockTaskMockRecorder) ToTransferTaskInfo added in v1.3.0 

func (mr *MockTaskMockRecorder) ToTransferTaskInfo() *gomock.Call

ToTransferTaskInfo indicates an expected call of ToTransferTaskInfo.

type PriorityAssigner 

type PriorityAssigner interface {
	Assign(Task) error
}

PriorityAssigner assigns priority to Tasks

func NewPriorityAssigner 

func NewPriorityAssigner(
	currentClusterName string,
	domainCache cache.DomainCache,
	activeClusterMgr activecluster.Manager,
	logger log.Logger,
	metricClient metrics.Client,
	config *config.Config,
) PriorityAssigner

NewPriorityAssigner creates a new task priority assigner

type Processor 

type Processor interface {
	common.Daemon
	Submit(Task) error
	TrySubmit(Task) (bool, error)
}

Processor is the worker pool for processing Tasks

func NewProcessor 

func NewProcessor(
	priorityAssigner PriorityAssigner,
	config *config.Config,
	logger log.Logger,
	metricsClient metrics.Client,
	timeSource clock.TimeSource,
	domainCache cache.DomainCache,
) (Processor, error)

NewProcessor creates a new task processor

func NewRateLimitedProcessor added in v1.2.18 

func NewRateLimitedProcessor(
	baseProcessor Processor,
	rateLimiter RateLimiter,
) Processor

type QueueType 

type QueueType int

QueueType is the type of task queue 

const (
	// QueueTypeActiveTransfer is the queue type for active transfer queue processor (TODO: remove this when history queue v1 is deprecated)
	QueueTypeActiveTransfer QueueType = iota + 1
	// QueueTypeStandbyTransfer is the queue type for standby transfer queue processor (TODO: remove this when history queue v1 is deprecated)
	QueueTypeStandbyTransfer
	// QueueTypeActiveTimer is the queue type for active timer queue processor (TODO: remove this when history queue v1 is deprecated)
	QueueTypeActiveTimer
	// QueueTypeStandbyTimer is the queue type for standby timer queue processor (TODO: remove this when history queue v1 is deprecated)
	QueueTypeStandbyTimer
	// QueueTypeReplication is the queue type for replication queue processor
	QueueTypeReplication
	// QueueTypeTransfer is the queue type for transfer queue processor
	QueueTypeTransfer
	// QueueTypeTimer is the queue type for timer queue processor
	QueueTypeTimer
)

type RateLimiter added in v1.2.18 

type RateLimiter interface {
	Allow(Task) bool
	Wait(context.Context, Task) error
}

func NewRateLimiter added in v1.2.18 

func NewRateLimiter(
	logger log.Logger,
	metricsClient metrics.Client,
	domainCache cache.DomainCache,
	config *config.Config,
	controller shard.Controller,
) RateLimiter

type Redispatcher added in v0.14.0 

type Redispatcher interface {
	common.Daemon
	AddTask(Task)
	Redispatch(targetSize int)
	RedispatchTask(Task, time.Time)
	Size() int
}

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,
	timeSource clock.TimeSource,
	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 dynamicproperties.DurationPropertyFn
}

RedispatcherOptions configs redispatch interval

type Rescheduler added in v1.3.5 

type Rescheduler interface {
	common.Daemon
	RescheduleTask(Task, time.Time)
	RescheduleDomains(domainIDs map[string]struct{})
	Size() int
}

func NewRescheduler added in v1.3.5 

func NewRescheduler(
	scheduler Processor,
	timeSource clock.TimeSource,
	logger log.Logger,
	metricsScope metrics.Scope,
) Rescheduler

type Task 

type Task interface {
	task.PriorityTask
	persistence.Task
	GetQueueType() QueueType
	GetShard() shard.Context
	GetAttempt() int
	GetInfo() persistence.Task
	SetInitialSubmitTime(time.Time)
}

Task is the interface for all tasks generated by history service

func NewHistoryTask added in v1.3.1 

func NewHistoryTask(
	shard shard.Context,
	taskInfo persistence.Task,
	queueType QueueType,
	logger log.Logger,
	taskFilter Filter,
	taskExecutor Executor,
	taskProcessor Processor,
	redispatcher Redispatcher,
	criticalRetryCount dynamicproperties.IntPropertyFn,
) Task

func NewHistoryTaskV2 added in v1.3.5 

func NewHistoryTaskV2(
	shard shard.Context,
	taskInfo persistence.Task,
	queueType QueueType,
	logger log.Logger,
	taskExecutor Executor,
	taskProcessor Processor,
	rescheduler Rescheduler,
	criticalRetryCount dynamicproperties.IntPropertyFn,
) Task

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.