Documentation ¶
Overview ¶
Package shard is a generated GoMock package.
Package shard is a generated GoMock package.
Package shard is a generated GoMock package.
Package shard is a generated GoMock package.
Package shard is a generated GoMock package.
Index ¶
- Variables
- func ConvertFromPersistenceTaskKey(key *persistencespb.TaskKey) tasks.Key
- func ConvertToPersistenceTaskKey(key tasks.Key) *persistencespb.TaskKey
- func IsShardOwnershipLostError(err error) bool
- func OperationPossiblySucceeded(err error) bool
- func ReplicationReaderIDFromClusterShardID(clusterID int64, shardID int32) int64
- func ReplicationReaderIDToClusterShardID(readerID int64) (int64, int32)
- type CloseCallback
- type Context
- type ContextFactory
- type ContextFactoryParams
- type ContextImpl
- func (s *ContextImpl) AddSpeculativeWorkflowTaskTimeoutTask(task *tasks.WorkflowTaskTimeoutTask) error
- func (s *ContextImpl) AddTasks(ctx context.Context, request *persistence.AddHistoryTasksRequest) error
- func (s *ContextImpl) AppendHistoryEvents(ctx context.Context, request *persistence.AppendHistoryNodesRequest, ...) (int, error)
- func (s *ContextImpl) AssertOwnership(ctx context.Context) error
- func (s *ContextImpl) ConflictResolveWorkflowExecution(ctx context.Context, ...) (*persistence.ConflictResolveWorkflowExecutionResponse, error)
- func (s *ContextImpl) CreateWorkflowExecution(ctx context.Context, request *persistence.CreateWorkflowExecutionRequest) (*persistence.CreateWorkflowExecutionResponse, error)
- func (s *ContextImpl) CurrentVectorClock() *clockspb.VectorClock
- func (s *ContextImpl) DeleteWorkflowExecution(ctx context.Context, key definition.WorkflowKey, branchToken []byte, ...) (retErr error)
- func (s *ContextImpl) FinishStop()
- func (s *ContextImpl) GenerateTaskID() (int64, error)
- func (s *ContextImpl) GenerateTaskIDs(number int) ([]int64, error)
- func (s *ContextImpl) GetArchivalMetadata() archiver.ArchivalMetadata
- func (s *ContextImpl) GetClusterMetadata() cluster.Metadata
- func (s *ContextImpl) GetConfig() *configs.Config
- func (s *ContextImpl) GetCurrentExecution(ctx context.Context, request *persistence.GetCurrentExecutionRequest) (*persistence.GetCurrentExecutionResponse, error)
- func (s *ContextImpl) GetCurrentTime(cluster string) time.Time
- func (s *ContextImpl) GetEngine(ctx context.Context) (Engine, error)
- func (s *ContextImpl) GetEventsCache() events.Cache
- func (s *ContextImpl) GetExecutionManager() persistence.ExecutionManager
- func (s *ContextImpl) GetHistoryClient() historyservice.HistoryServiceClient
- func (s *ContextImpl) GetLogger() log.Logger
- func (s *ContextImpl) GetMetricsHandler() metrics.Handler
- func (s *ContextImpl) GetNamespaceRegistry() namespace.Registry
- func (s *ContextImpl) GetOwner() string
- func (s *ContextImpl) GetPayloadSerializer() serialization.Serializer
- func (s *ContextImpl) GetPingChecks() []common.PingCheck
- func (s *ContextImpl) GetQueueExclusiveHighReadWatermark(category tasks.Category) tasks.Key
- func (s *ContextImpl) GetQueueState(category tasks.Category) (*persistencespb.QueueState, bool)
- func (s *ContextImpl) GetRangeID() int64
- func (s *ContextImpl) GetRemoteAdminClient(cluster string) (adminservice.AdminServiceClient, error)
- func (s *ContextImpl) GetReplicationStatus(clusterNames []string) (map[string]*historyservice.ShardReplicationStatusPerCluster, ...)
- func (s *ContextImpl) GetReplicatorDLQAckLevel(sourceCluster string) int64
- func (s *ContextImpl) GetSearchAttributesMapperProvider() searchattribute.MapperProvider
- func (s *ContextImpl) GetSearchAttributesProvider() searchattribute.Provider
- func (s *ContextImpl) GetShardID() int32
- func (s *ContextImpl) GetThrottledLogger() log.Logger
- func (s *ContextImpl) GetTimeSource() cclock.TimeSource
- func (s *ContextImpl) GetWorkflowExecution(ctx context.Context, request *persistence.GetWorkflowExecutionRequest) (*persistence.GetWorkflowExecutionResponse, error)
- func (s *ContextImpl) IsValid() bool
- func (s *ContextImpl) NewVectorClock() (*clockspb.VectorClock, error)
- func (s *ContextImpl) SetCurrentTime(cluster string, currentTime time.Time)
- func (s *ContextImpl) SetQueueState(category tasks.Category, state *persistencespb.QueueState) error
- func (s *ContextImpl) SetWorkflowExecution(ctx context.Context, request *persistence.SetWorkflowExecutionRequest) (*persistence.SetWorkflowExecutionResponse, error)
- func (s *ContextImpl) String() string
- func (s *ContextImpl) UnloadForOwnershipLost()
- func (s *ContextImpl) UpdateHandoverNamespace(ns *namespace.Namespace, deletedFromDb bool)
- func (s *ContextImpl) UpdateRemoteClusterInfo(clusterName string, ackTaskID int64, ackTimestamp time.Time)
- func (s *ContextImpl) UpdateRemoteReaderInfo(readerID int64, ackTaskID int64, ackTimestamp time.Time) error
- func (s *ContextImpl) UpdateReplicationQueueReaderState(readerID int64, readerState *persistencespb.QueueReaderState) error
- func (s *ContextImpl) UpdateReplicatorDLQAckLevel(sourceCluster string, ackLevel int64) error
- func (s *ContextImpl) UpdateWorkflowExecution(ctx context.Context, request *persistence.UpdateWorkflowExecutionRequest) (*persistence.UpdateWorkflowExecutionResponse, error)
- type ContextTest
- type ControllableContext
- type Controller
- type ControllerImpl
- func (c *ControllerImpl) CloseShardByID(shardID int32)
- func (c *ControllerImpl) GetPingChecks() []common.PingCheck
- func (c *ControllerImpl) GetShardByID(shardID int32) (Context, error)
- func (c *ControllerImpl) GetShardByNamespaceWorkflow(namespaceID namespace.ID, workflowID string) (Context, error)
- func (c *ControllerImpl) ShardIDs() []int32
- func (c *ControllerImpl) Start()
- func (c *ControllerImpl) Status() int32
- func (c *ControllerImpl) Stop()
- func (c *ControllerImpl) SubscribeShardCount() ShardCountSubscription
- type Engine
- type EngineFactory
- type LazyLoadedOwnershipBasedQuotaScaler
- type MockContext
- func (m *MockContext) AddSpeculativeWorkflowTaskTimeoutTask(task *tasks.WorkflowTaskTimeoutTask) error
- func (m *MockContext) AddTasks(ctx context.Context, request *persistence.AddHistoryTasksRequest) error
- func (m *MockContext) AppendHistoryEvents(ctx context.Context, request *persistence.AppendHistoryNodesRequest, ...) (int, error)
- func (m *MockContext) AssertOwnership(ctx context.Context) error
- func (m *MockContext) ConflictResolveWorkflowExecution(ctx context.Context, ...) (*persistence.ConflictResolveWorkflowExecutionResponse, error)
- func (m *MockContext) CreateWorkflowExecution(ctx context.Context, request *persistence.CreateWorkflowExecutionRequest) (*persistence.CreateWorkflowExecutionResponse, error)
- func (m *MockContext) CurrentVectorClock() *v11.VectorClock
- func (m *MockContext) DeleteWorkflowExecution(ctx context.Context, workflowKey definition.WorkflowKey, branchToken []byte, ...) error
- func (m *MockContext) EXPECT() *MockContextMockRecorder
- func (m *MockContext) GenerateTaskID() (int64, error)
- func (m *MockContext) GenerateTaskIDs(number int) ([]int64, error)
- func (m *MockContext) GetArchivalMetadata() archiver.ArchivalMetadata
- func (m *MockContext) GetClusterMetadata() cluster.Metadata
- func (m *MockContext) GetConfig() *configs.Config
- func (m *MockContext) GetCurrentExecution(ctx context.Context, request *persistence.GetCurrentExecutionRequest) (*persistence.GetCurrentExecutionResponse, error)
- func (m *MockContext) GetCurrentTime(cluster string) time.Time
- func (m *MockContext) GetEngine(ctx context.Context) (Engine, error)
- func (m *MockContext) GetEventsCache() events.Cache
- func (m *MockContext) GetExecutionManager() persistence.ExecutionManager
- func (m *MockContext) GetHistoryClient() v12.HistoryServiceClient
- func (m *MockContext) GetLogger() log.Logger
- func (m *MockContext) GetMetricsHandler() metrics.Handler
- func (m *MockContext) GetNamespaceRegistry() namespace.Registry
- func (m *MockContext) GetOwner() string
- func (m *MockContext) GetPayloadSerializer() serialization.Serializer
- func (m *MockContext) GetQueueExclusiveHighReadWatermark(category tasks.Category) tasks.Key
- func (m *MockContext) GetQueueState(category tasks.Category) (*v13.QueueState, bool)
- func (m *MockContext) GetRangeID() int64
- func (m *MockContext) GetRemoteAdminClient(arg0 string) (v10.AdminServiceClient, error)
- func (m *MockContext) GetReplicationStatus(cluster []string) (map[string]*v12.ShardReplicationStatusPerCluster, ...)
- func (m *MockContext) GetReplicatorDLQAckLevel(sourceCluster string) int64
- func (m *MockContext) GetSearchAttributesMapperProvider() searchattribute.MapperProvider
- func (m *MockContext) GetSearchAttributesProvider() searchattribute.Provider
- func (m *MockContext) GetShardID() int32
- func (m *MockContext) GetThrottledLogger() log.Logger
- func (m *MockContext) GetTimeSource() clock.TimeSource
- func (m *MockContext) GetWorkflowExecution(ctx context.Context, request *persistence.GetWorkflowExecutionRequest) (*persistence.GetWorkflowExecutionResponse, error)
- func (m *MockContext) NewVectorClock() (*v11.VectorClock, error)
- func (m *MockContext) SetCurrentTime(cluster string, currentTime time.Time)
- func (m *MockContext) SetQueueState(category tasks.Category, state *v13.QueueState) error
- func (m *MockContext) SetWorkflowExecution(ctx context.Context, request *persistence.SetWorkflowExecutionRequest) (*persistence.SetWorkflowExecutionResponse, error)
- func (m *MockContext) UnloadForOwnershipLost()
- func (m *MockContext) UpdateHandoverNamespace(ns *namespace.Namespace, deletedFromDb bool)
- func (m *MockContext) UpdateRemoteClusterInfo(cluster string, ackTaskID int64, ackTimestamp time.Time)
- func (m *MockContext) UpdateRemoteReaderInfo(readerID, ackTaskID int64, ackTimestamp time.Time) error
- func (m *MockContext) UpdateReplicationQueueReaderState(readerID int64, readerState *v13.QueueReaderState) error
- func (m *MockContext) UpdateReplicatorDLQAckLevel(sourCluster string, ackLevel int64) error
- func (m *MockContext) UpdateWorkflowExecution(ctx context.Context, request *persistence.UpdateWorkflowExecutionRequest) (*persistence.UpdateWorkflowExecutionResponse, error)
- type MockContextFactory
- type MockContextFactoryMockRecorder
- type MockContextMockRecorder
- func (mr *MockContextMockRecorder) AddSpeculativeWorkflowTaskTimeoutTask(task interface{}) *gomock.Call
- func (mr *MockContextMockRecorder) AddTasks(ctx, request interface{}) *gomock.Call
- func (mr *MockContextMockRecorder) AppendHistoryEvents(ctx, request, namespaceID, execution interface{}) *gomock.Call
- func (mr *MockContextMockRecorder) AssertOwnership(ctx interface{}) *gomock.Call
- func (mr *MockContextMockRecorder) ConflictResolveWorkflowExecution(ctx, request interface{}) *gomock.Call
- func (mr *MockContextMockRecorder) CreateWorkflowExecution(ctx, request interface{}) *gomock.Call
- func (mr *MockContextMockRecorder) CurrentVectorClock() *gomock.Call
- func (mr *MockContextMockRecorder) DeleteWorkflowExecution(ctx, workflowKey, branchToken, startTime, closeTime, ... interface{}) *gomock.Call
- func (mr *MockContextMockRecorder) GenerateTaskID() *gomock.Call
- func (mr *MockContextMockRecorder) GenerateTaskIDs(number interface{}) *gomock.Call
- func (mr *MockContextMockRecorder) GetArchivalMetadata() *gomock.Call
- func (mr *MockContextMockRecorder) GetClusterMetadata() *gomock.Call
- func (mr *MockContextMockRecorder) GetConfig() *gomock.Call
- func (mr *MockContextMockRecorder) GetCurrentExecution(ctx, request interface{}) *gomock.Call
- func (mr *MockContextMockRecorder) GetCurrentTime(cluster interface{}) *gomock.Call
- func (mr *MockContextMockRecorder) GetEngine(ctx interface{}) *gomock.Call
- func (mr *MockContextMockRecorder) GetEventsCache() *gomock.Call
- func (mr *MockContextMockRecorder) GetExecutionManager() *gomock.Call
- func (mr *MockContextMockRecorder) GetHistoryClient() *gomock.Call
- func (mr *MockContextMockRecorder) GetLogger() *gomock.Call
- func (mr *MockContextMockRecorder) GetMetricsHandler() *gomock.Call
- func (mr *MockContextMockRecorder) GetNamespaceRegistry() *gomock.Call
- func (mr *MockContextMockRecorder) GetOwner() *gomock.Call
- func (mr *MockContextMockRecorder) GetPayloadSerializer() *gomock.Call
- func (mr *MockContextMockRecorder) GetQueueExclusiveHighReadWatermark(category interface{}) *gomock.Call
- func (mr *MockContextMockRecorder) GetQueueState(category interface{}) *gomock.Call
- func (mr *MockContextMockRecorder) GetRangeID() *gomock.Call
- func (mr *MockContextMockRecorder) GetRemoteAdminClient(arg0 interface{}) *gomock.Call
- func (mr *MockContextMockRecorder) GetReplicationStatus(cluster interface{}) *gomock.Call
- func (mr *MockContextMockRecorder) GetReplicatorDLQAckLevel(sourceCluster interface{}) *gomock.Call
- func (mr *MockContextMockRecorder) GetSearchAttributesMapperProvider() *gomock.Call
- func (mr *MockContextMockRecorder) GetSearchAttributesProvider() *gomock.Call
- func (mr *MockContextMockRecorder) GetShardID() *gomock.Call
- func (mr *MockContextMockRecorder) GetThrottledLogger() *gomock.Call
- func (mr *MockContextMockRecorder) GetTimeSource() *gomock.Call
- func (mr *MockContextMockRecorder) GetWorkflowExecution(ctx, request interface{}) *gomock.Call
- func (mr *MockContextMockRecorder) NewVectorClock() *gomock.Call
- func (mr *MockContextMockRecorder) SetCurrentTime(cluster, currentTime interface{}) *gomock.Call
- func (mr *MockContextMockRecorder) SetQueueState(category, state interface{}) *gomock.Call
- func (mr *MockContextMockRecorder) SetWorkflowExecution(ctx, request interface{}) *gomock.Call
- func (mr *MockContextMockRecorder) UnloadForOwnershipLost() *gomock.Call
- func (mr *MockContextMockRecorder) UpdateHandoverNamespace(ns, deletedFromDb interface{}) *gomock.Call
- func (mr *MockContextMockRecorder) UpdateRemoteClusterInfo(cluster, ackTaskID, ackTimestamp interface{}) *gomock.Call
- func (mr *MockContextMockRecorder) UpdateRemoteReaderInfo(readerID, ackTaskID, ackTimestamp interface{}) *gomock.Call
- func (mr *MockContextMockRecorder) UpdateReplicationQueueReaderState(readerID, readerState interface{}) *gomock.Call
- func (mr *MockContextMockRecorder) UpdateReplicatorDLQAckLevel(sourCluster, ackLevel interface{}) *gomock.Call
- func (mr *MockContextMockRecorder) UpdateWorkflowExecution(ctx, request interface{}) *gomock.Call
- type MockControllableContext
- func (m *MockControllableContext) AddSpeculativeWorkflowTaskTimeoutTask(task *tasks.WorkflowTaskTimeoutTask) error
- func (m *MockControllableContext) AddTasks(ctx context.Context, request *persistence.AddHistoryTasksRequest) error
- func (m *MockControllableContext) AppendHistoryEvents(ctx context.Context, request *persistence.AppendHistoryNodesRequest, ...) (int, error)
- func (m *MockControllableContext) AssertOwnership(ctx context.Context) error
- func (m *MockControllableContext) ConflictResolveWorkflowExecution(ctx context.Context, ...) (*persistence.ConflictResolveWorkflowExecutionResponse, error)
- func (m *MockControllableContext) CreateWorkflowExecution(ctx context.Context, request *persistence.CreateWorkflowExecutionRequest) (*persistence.CreateWorkflowExecutionResponse, error)
- func (m *MockControllableContext) CurrentVectorClock() *v11.VectorClock
- func (m *MockControllableContext) DeleteWorkflowExecution(ctx context.Context, workflowKey definition.WorkflowKey, branchToken []byte, ...) error
- func (m *MockControllableContext) EXPECT() *MockControllableContextMockRecorder
- func (m *MockControllableContext) FinishStop()
- func (m *MockControllableContext) GenerateTaskID() (int64, error)
- func (m *MockControllableContext) GenerateTaskIDs(number int) ([]int64, error)
- func (m *MockControllableContext) GetArchivalMetadata() archiver.ArchivalMetadata
- func (m *MockControllableContext) GetClusterMetadata() cluster.Metadata
- func (m *MockControllableContext) GetConfig() *configs.Config
- func (m *MockControllableContext) GetCurrentExecution(ctx context.Context, request *persistence.GetCurrentExecutionRequest) (*persistence.GetCurrentExecutionResponse, error)
- func (m *MockControllableContext) GetCurrentTime(cluster string) time.Time
- func (m *MockControllableContext) GetEngine(ctx context.Context) (Engine, error)
- func (m *MockControllableContext) GetEventsCache() events.Cache
- func (m *MockControllableContext) GetExecutionManager() persistence.ExecutionManager
- func (m *MockControllableContext) GetHistoryClient() v12.HistoryServiceClient
- func (m *MockControllableContext) GetLogger() log.Logger
- func (m *MockControllableContext) GetMetricsHandler() metrics.Handler
- func (m *MockControllableContext) GetNamespaceRegistry() namespace.Registry
- func (m *MockControllableContext) GetOwner() string
- func (m *MockControllableContext) GetPayloadSerializer() serialization.Serializer
- func (m *MockControllableContext) GetPingChecks() []common.PingCheck
- func (m *MockControllableContext) GetQueueExclusiveHighReadWatermark(category tasks.Category) tasks.Key
- func (m *MockControllableContext) GetQueueState(category tasks.Category) (*v13.QueueState, bool)
- func (m *MockControllableContext) GetRangeID() int64
- func (m *MockControllableContext) GetRemoteAdminClient(arg0 string) (v10.AdminServiceClient, error)
- func (m *MockControllableContext) GetReplicationStatus(cluster []string) (map[string]*v12.ShardReplicationStatusPerCluster, ...)
- func (m *MockControllableContext) GetReplicatorDLQAckLevel(sourceCluster string) int64
- func (m *MockControllableContext) GetSearchAttributesMapperProvider() searchattribute.MapperProvider
- func (m *MockControllableContext) GetSearchAttributesProvider() searchattribute.Provider
- func (m *MockControllableContext) GetShardID() int32
- func (m *MockControllableContext) GetThrottledLogger() log.Logger
- func (m *MockControllableContext) GetTimeSource() clock.TimeSource
- func (m *MockControllableContext) GetWorkflowExecution(ctx context.Context, request *persistence.GetWorkflowExecutionRequest) (*persistence.GetWorkflowExecutionResponse, error)
- func (m *MockControllableContext) IsValid() bool
- func (m *MockControllableContext) NewVectorClock() (*v11.VectorClock, error)
- func (m *MockControllableContext) SetCurrentTime(cluster string, currentTime time.Time)
- func (m *MockControllableContext) SetQueueState(category tasks.Category, state *v13.QueueState) error
- func (m *MockControllableContext) SetWorkflowExecution(ctx context.Context, request *persistence.SetWorkflowExecutionRequest) (*persistence.SetWorkflowExecutionResponse, error)
- func (m *MockControllableContext) UnloadForOwnershipLost()
- func (m *MockControllableContext) UpdateHandoverNamespace(ns *namespace.Namespace, deletedFromDb bool)
- func (m *MockControllableContext) UpdateRemoteClusterInfo(cluster string, ackTaskID int64, ackTimestamp time.Time)
- func (m *MockControllableContext) UpdateRemoteReaderInfo(readerID, ackTaskID int64, ackTimestamp time.Time) error
- func (m *MockControllableContext) UpdateReplicationQueueReaderState(readerID int64, readerState *v13.QueueReaderState) error
- func (m *MockControllableContext) UpdateReplicatorDLQAckLevel(sourCluster string, ackLevel int64) error
- func (m *MockControllableContext) UpdateWorkflowExecution(ctx context.Context, request *persistence.UpdateWorkflowExecutionRequest) (*persistence.UpdateWorkflowExecutionResponse, error)
- type MockControllableContextMockRecorder
- func (mr *MockControllableContextMockRecorder) AddSpeculativeWorkflowTaskTimeoutTask(task interface{}) *gomock.Call
- func (mr *MockControllableContextMockRecorder) AddTasks(ctx, request interface{}) *gomock.Call
- func (mr *MockControllableContextMockRecorder) AppendHistoryEvents(ctx, request, namespaceID, execution interface{}) *gomock.Call
- func (mr *MockControllableContextMockRecorder) AssertOwnership(ctx interface{}) *gomock.Call
- func (mr *MockControllableContextMockRecorder) ConflictResolveWorkflowExecution(ctx, request interface{}) *gomock.Call
- func (mr *MockControllableContextMockRecorder) CreateWorkflowExecution(ctx, request interface{}) *gomock.Call
- func (mr *MockControllableContextMockRecorder) CurrentVectorClock() *gomock.Call
- func (mr *MockControllableContextMockRecorder) DeleteWorkflowExecution(ctx, workflowKey, branchToken, startTime, closeTime, ... interface{}) *gomock.Call
- func (mr *MockControllableContextMockRecorder) FinishStop() *gomock.Call
- func (mr *MockControllableContextMockRecorder) GenerateTaskID() *gomock.Call
- func (mr *MockControllableContextMockRecorder) GenerateTaskIDs(number interface{}) *gomock.Call
- func (mr *MockControllableContextMockRecorder) GetArchivalMetadata() *gomock.Call
- func (mr *MockControllableContextMockRecorder) GetClusterMetadata() *gomock.Call
- func (mr *MockControllableContextMockRecorder) GetConfig() *gomock.Call
- func (mr *MockControllableContextMockRecorder) GetCurrentExecution(ctx, request interface{}) *gomock.Call
- func (mr *MockControllableContextMockRecorder) GetCurrentTime(cluster interface{}) *gomock.Call
- func (mr *MockControllableContextMockRecorder) GetEngine(ctx interface{}) *gomock.Call
- func (mr *MockControllableContextMockRecorder) GetEventsCache() *gomock.Call
- func (mr *MockControllableContextMockRecorder) GetExecutionManager() *gomock.Call
- func (mr *MockControllableContextMockRecorder) GetHistoryClient() *gomock.Call
- func (mr *MockControllableContextMockRecorder) GetLogger() *gomock.Call
- func (mr *MockControllableContextMockRecorder) GetMetricsHandler() *gomock.Call
- func (mr *MockControllableContextMockRecorder) GetNamespaceRegistry() *gomock.Call
- func (mr *MockControllableContextMockRecorder) GetOwner() *gomock.Call
- func (mr *MockControllableContextMockRecorder) GetPayloadSerializer() *gomock.Call
- func (mr *MockControllableContextMockRecorder) GetPingChecks() *gomock.Call
- func (mr *MockControllableContextMockRecorder) GetQueueExclusiveHighReadWatermark(category interface{}) *gomock.Call
- func (mr *MockControllableContextMockRecorder) GetQueueState(category interface{}) *gomock.Call
- func (mr *MockControllableContextMockRecorder) GetRangeID() *gomock.Call
- func (mr *MockControllableContextMockRecorder) GetRemoteAdminClient(arg0 interface{}) *gomock.Call
- func (mr *MockControllableContextMockRecorder) GetReplicationStatus(cluster interface{}) *gomock.Call
- func (mr *MockControllableContextMockRecorder) GetReplicatorDLQAckLevel(sourceCluster interface{}) *gomock.Call
- func (mr *MockControllableContextMockRecorder) GetSearchAttributesMapperProvider() *gomock.Call
- func (mr *MockControllableContextMockRecorder) GetSearchAttributesProvider() *gomock.Call
- func (mr *MockControllableContextMockRecorder) GetShardID() *gomock.Call
- func (mr *MockControllableContextMockRecorder) GetThrottledLogger() *gomock.Call
- func (mr *MockControllableContextMockRecorder) GetTimeSource() *gomock.Call
- func (mr *MockControllableContextMockRecorder) GetWorkflowExecution(ctx, request interface{}) *gomock.Call
- func (mr *MockControllableContextMockRecorder) IsValid() *gomock.Call
- func (mr *MockControllableContextMockRecorder) NewVectorClock() *gomock.Call
- func (mr *MockControllableContextMockRecorder) SetCurrentTime(cluster, currentTime interface{}) *gomock.Call
- func (mr *MockControllableContextMockRecorder) SetQueueState(category, state interface{}) *gomock.Call
- func (mr *MockControllableContextMockRecorder) SetWorkflowExecution(ctx, request interface{}) *gomock.Call
- func (mr *MockControllableContextMockRecorder) UnloadForOwnershipLost() *gomock.Call
- func (mr *MockControllableContextMockRecorder) UpdateHandoverNamespace(ns, deletedFromDb interface{}) *gomock.Call
- func (mr *MockControllableContextMockRecorder) UpdateRemoteClusterInfo(cluster, ackTaskID, ackTimestamp interface{}) *gomock.Call
- func (mr *MockControllableContextMockRecorder) UpdateRemoteReaderInfo(readerID, ackTaskID, ackTimestamp interface{}) *gomock.Call
- func (mr *MockControllableContextMockRecorder) UpdateReplicationQueueReaderState(readerID, readerState interface{}) *gomock.Call
- func (mr *MockControllableContextMockRecorder) UpdateReplicatorDLQAckLevel(sourCluster, ackLevel interface{}) *gomock.Call
- func (mr *MockControllableContextMockRecorder) UpdateWorkflowExecution(ctx, request interface{}) *gomock.Call
- type MockController
- func (m *MockController) CloseShardByID(shardID int32)
- func (m *MockController) EXPECT() *MockControllerMockRecorder
- func (m *MockController) GetPingChecks() []common.PingCheck
- func (m *MockController) GetShardByID(shardID int32) (Context, error)
- func (m *MockController) GetShardByNamespaceWorkflow(namespaceID namespace.ID, workflowID string) (Context, error)
- func (m *MockController) ShardIDs() []int32
- func (m *MockController) Start()
- func (m *MockController) Stop()
- type MockControllerMockRecorder
- func (mr *MockControllerMockRecorder) CloseShardByID(shardID interface{}) *gomock.Call
- func (mr *MockControllerMockRecorder) GetPingChecks() *gomock.Call
- func (mr *MockControllerMockRecorder) GetShardByID(shardID interface{}) *gomock.Call
- func (mr *MockControllerMockRecorder) GetShardByNamespaceWorkflow(namespaceID, workflowID interface{}) *gomock.Call
- func (mr *MockControllerMockRecorder) ShardIDs() *gomock.Call
- func (mr *MockControllerMockRecorder) Start() *gomock.Call
- func (mr *MockControllerMockRecorder) Stop() *gomock.Call
- type MockEngine
- func (m *MockEngine) AddSpeculativeWorkflowTaskTimeoutTask(task *tasks.WorkflowTaskTimeoutTask)
- func (m *MockEngine) AddTasks(ctx context.Context, request *historyservice.AddTasksRequest) (*historyservice.AddTasksResponse, error)
- func (m *MockEngine) ConvertReplicationTask(ctx context.Context, task tasks.Task) (*repication.ReplicationTask, error)
- func (m *MockEngine) DeleteWorkflowExecution(ctx context.Context, ...) (*historyservice.DeleteWorkflowExecutionResponse, error)
- func (m *MockEngine) DescribeMutableState(ctx context.Context, request *historyservice.DescribeMutableStateRequest) (*historyservice.DescribeMutableStateResponse, error)
- func (m *MockEngine) DescribeWorkflowExecution(ctx context.Context, request *historyservice.DescribeWorkflowExecutionRequest) (*historyservice.DescribeWorkflowExecutionResponse, error)
- func (m *MockEngine) EXPECT() *MockEngineMockRecorder
- func (m *MockEngine) GenerateLastHistoryReplicationTasks(ctx context.Context, ...) (*historyservice.GenerateLastHistoryReplicationTasksResponse, error)
- func (m *MockEngine) GetDLQMessages(ctx context.Context, messagesRequest *historyservice.GetDLQMessagesRequest) (*historyservice.GetDLQMessagesResponse, error)
- func (m *MockEngine) GetDLQReplicationMessages(ctx context.Context, taskInfos []*repication.ReplicationTaskInfo) ([]*repication.ReplicationTask, error)
- func (m *MockEngine) GetMutableState(ctx context.Context, request *historyservice.GetMutableStateRequest) (*historyservice.GetMutableStateResponse, error)
- func (m *MockEngine) GetReplicationMessages(ctx context.Context, pollingCluster string, ackMessageID int64, ...) (*repication.ReplicationMessages, error)
- func (m *MockEngine) GetReplicationStatus(ctx context.Context, request *historyservice.GetReplicationStatusRequest) (*historyservice.ShardReplicationStatus, error)
- func (m *MockEngine) GetReplicationTasksIter(ctx context.Context, pollingCluster string, ...) (collection.Iterator[tasks.Task], error)
- func (m *MockEngine) GetWorkflowExecutionHistory(ctx context.Context, ...) (*historyservice.GetWorkflowExecutionHistoryResponse, error)
- func (m *MockEngine) GetWorkflowExecutionHistoryReverse(ctx context.Context, ...) (*historyservice.GetWorkflowExecutionHistoryReverseResponse, error)
- func (m *MockEngine) GetWorkflowExecutionRawHistoryV2(ctx context.Context, ...) (*historyservice.GetWorkflowExecutionRawHistoryV2Response, error)
- func (m *MockEngine) ImportWorkflowExecution(ctx context.Context, request *historyservice.ImportWorkflowExecutionRequest) (*historyservice.ImportWorkflowExecutionResponse, error)
- func (m *MockEngine) IsActivityTaskValid(ctx context.Context, request *historyservice.IsActivityTaskValidRequest) (*historyservice.IsActivityTaskValidResponse, error)
- func (m *MockEngine) IsWorkflowTaskValid(ctx context.Context, request *historyservice.IsWorkflowTaskValidRequest) (*historyservice.IsWorkflowTaskValidResponse, error)
- func (m *MockEngine) MergeDLQMessages(ctx context.Context, messagesRequest *historyservice.MergeDLQMessagesRequest) (*historyservice.MergeDLQMessagesResponse, error)
- func (m *MockEngine) NotifyNewHistoryEvent(event *events.Notification)
- func (m *MockEngine) NotifyNewTasks(tasks map[tasks.Category][]tasks.Task)
- func (m *MockEngine) PollMutableState(ctx context.Context, request *historyservice.PollMutableStateRequest) (*historyservice.PollMutableStateResponse, error)
- func (m *MockEngine) PollWorkflowExecutionUpdate(ctx context.Context, ...) (*historyservice.PollWorkflowExecutionUpdateResponse, error)
- func (m *MockEngine) PurgeDLQMessages(ctx context.Context, messagesRequest *historyservice.PurgeDLQMessagesRequest) (*historyservice.PurgeDLQMessagesResponse, error)
- func (m *MockEngine) QueryWorkflow(ctx context.Context, request *historyservice.QueryWorkflowRequest) (*historyservice.QueryWorkflowResponse, error)
- func (m *MockEngine) ReapplyEvents(ctx context.Context, namespaceUUID namespace.ID, workflowID, runID string, ...) error
- func (m *MockEngine) RebuildMutableState(ctx context.Context, namespaceUUID namespace.ID, ...) error
- func (m *MockEngine) RecordActivityTaskHeartbeat(ctx context.Context, ...) (*historyservice.RecordActivityTaskHeartbeatResponse, error)
- func (m *MockEngine) RecordActivityTaskStarted(ctx context.Context, request *historyservice.RecordActivityTaskStartedRequest) (*historyservice.RecordActivityTaskStartedResponse, error)
- func (m *MockEngine) RecordChildExecutionCompleted(ctx context.Context, ...) (*historyservice.RecordChildExecutionCompletedResponse, error)
- func (m *MockEngine) RecordWorkflowTaskStarted(ctx context.Context, request *historyservice.RecordWorkflowTaskStartedRequest) (*historyservice.RecordWorkflowTaskStartedResponse, error)
- func (m *MockEngine) RefreshWorkflowTasks(ctx context.Context, namespaceUUID namespace.ID, ...) error
- func (m *MockEngine) RemoveSignalMutableState(ctx context.Context, request *historyservice.RemoveSignalMutableStateRequest) (*historyservice.RemoveSignalMutableStateResponse, error)
- func (m *MockEngine) ReplicateEventsV2(ctx context.Context, request *historyservice.ReplicateEventsV2Request) error
- func (m *MockEngine) ReplicateHistoryEvents(ctx context.Context, workflowKey definition.WorkflowKey, ...) error
- func (m *MockEngine) ReplicateWorkflowState(ctx context.Context, request *historyservice.ReplicateWorkflowStateRequest) error
- func (m *MockEngine) RequestCancelWorkflowExecution(ctx context.Context, ...) (*historyservice.RequestCancelWorkflowExecutionResponse, error)
- func (m *MockEngine) ResetStickyTaskQueue(ctx context.Context, resetRequest *historyservice.ResetStickyTaskQueueRequest) (*historyservice.ResetStickyTaskQueueResponse, error)
- func (m *MockEngine) ResetWorkflowExecution(ctx context.Context, request *historyservice.ResetWorkflowExecutionRequest) (*historyservice.ResetWorkflowExecutionResponse, error)
- func (m *MockEngine) RespondActivityTaskCanceled(ctx context.Context, ...) (*historyservice.RespondActivityTaskCanceledResponse, error)
- func (m *MockEngine) RespondActivityTaskCompleted(ctx context.Context, ...) (*historyservice.RespondActivityTaskCompletedResponse, error)
- func (m *MockEngine) RespondActivityTaskFailed(ctx context.Context, request *historyservice.RespondActivityTaskFailedRequest) (*historyservice.RespondActivityTaskFailedResponse, error)
- func (m *MockEngine) RespondWorkflowTaskCompleted(ctx context.Context, ...) (*historyservice.RespondWorkflowTaskCompletedResponse, error)
- func (m *MockEngine) RespondWorkflowTaskFailed(ctx context.Context, request *historyservice.RespondWorkflowTaskFailedRequest) error
- func (m *MockEngine) ScheduleWorkflowTask(ctx context.Context, request *historyservice.ScheduleWorkflowTaskRequest) error
- func (m *MockEngine) SignalWithStartWorkflowExecution(ctx context.Context, ...) (*historyservice.SignalWithStartWorkflowExecutionResponse, error)
- func (m *MockEngine) SignalWorkflowExecution(ctx context.Context, request *historyservice.SignalWorkflowExecutionRequest) (*historyservice.SignalWorkflowExecutionResponse, error)
- func (m *MockEngine) Start()
- func (m *MockEngine) StartWorkflowExecution(ctx context.Context, request *historyservice.StartWorkflowExecutionRequest) (*historyservice.StartWorkflowExecutionResponse, error)
- func (m *MockEngine) Stop()
- func (m *MockEngine) SubscribeReplicationNotification() (<-chan struct{}, string)
- func (m *MockEngine) SyncActivity(ctx context.Context, request *historyservice.SyncActivityRequest) error
- func (m *MockEngine) SyncShardStatus(ctx context.Context, request *historyservice.SyncShardStatusRequest) error
- func (m *MockEngine) TerminateWorkflowExecution(ctx context.Context, request *historyservice.TerminateWorkflowExecutionRequest) (*historyservice.TerminateWorkflowExecutionResponse, error)
- func (m *MockEngine) UnsubscribeReplicationNotification(arg0 string)
- func (m *MockEngine) UpdateWorkflowExecution(ctx context.Context, request *historyservice.UpdateWorkflowExecutionRequest) (*historyservice.UpdateWorkflowExecutionResponse, error)
- func (m *MockEngine) VerifyChildExecutionCompletionRecorded(ctx context.Context, ...) (*historyservice.VerifyChildExecutionCompletionRecordedResponse, error)
- func (m *MockEngine) VerifyFirstWorkflowTaskScheduled(ctx context.Context, ...) error
- type MockEngineFactory
- type MockEngineFactoryMockRecorder
- type MockEngineMockRecorder
- func (mr *MockEngineMockRecorder) AddSpeculativeWorkflowTaskTimeoutTask(task interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) AddTasks(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) ConvertReplicationTask(ctx, task interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) DeleteWorkflowExecution(ctx, deleteRequest interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) DescribeMutableState(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) DescribeWorkflowExecution(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) GenerateLastHistoryReplicationTasks(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) GetDLQMessages(ctx, messagesRequest interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) GetDLQReplicationMessages(ctx, taskInfos interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) GetMutableState(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) GetReplicationMessages(ctx, pollingCluster, ackMessageID, ackTimestamp, queryMessageID interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) GetReplicationStatus(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) GetReplicationTasksIter(ctx, pollingCluster, minInclusiveTaskID, maxExclusiveTaskID interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) GetWorkflowExecutionHistory(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) GetWorkflowExecutionHistoryReverse(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) GetWorkflowExecutionRawHistoryV2(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) ImportWorkflowExecution(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) IsActivityTaskValid(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) IsWorkflowTaskValid(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) MergeDLQMessages(ctx, messagesRequest interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) NotifyNewHistoryEvent(event interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) NotifyNewTasks(tasks interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) PollMutableState(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) PollWorkflowExecutionUpdate(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) PurgeDLQMessages(ctx, messagesRequest interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) QueryWorkflow(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) ReapplyEvents(ctx, namespaceUUID, workflowID, runID, events interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) RebuildMutableState(ctx, namespaceUUID, execution interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) RecordActivityTaskHeartbeat(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) RecordActivityTaskStarted(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) RecordChildExecutionCompleted(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) RecordWorkflowTaskStarted(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) RefreshWorkflowTasks(ctx, namespaceUUID, execution interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) RemoveSignalMutableState(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) ReplicateEventsV2(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) ReplicateHistoryEvents(...) *gomock.Call
- func (mr *MockEngineMockRecorder) ReplicateWorkflowState(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) RequestCancelWorkflowExecution(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) ResetStickyTaskQueue(ctx, resetRequest interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) ResetWorkflowExecution(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) RespondActivityTaskCanceled(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) RespondActivityTaskCompleted(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) RespondActivityTaskFailed(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) RespondWorkflowTaskCompleted(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) RespondWorkflowTaskFailed(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) ScheduleWorkflowTask(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) SignalWithStartWorkflowExecution(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) SignalWorkflowExecution(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) Start() *gomock.Call
- func (mr *MockEngineMockRecorder) StartWorkflowExecution(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) Stop() *gomock.Call
- func (mr *MockEngineMockRecorder) SubscribeReplicationNotification() *gomock.Call
- func (mr *MockEngineMockRecorder) SyncActivity(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) SyncShardStatus(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) TerminateWorkflowExecution(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) UnsubscribeReplicationNotification(arg0 interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) UpdateWorkflowExecution(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) VerifyChildExecutionCompletionRecorded(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) VerifyFirstWorkflowTaskScheduled(ctx, request interface{}) *gomock.Call
- type MockReplicationStream
- func (m *MockReplicationStream) ConvertReplicationTask(ctx context.Context, task tasks.Task) (*repication.ReplicationTask, error)
- func (m *MockReplicationStream) EXPECT() *MockReplicationStreamMockRecorder
- func (m *MockReplicationStream) GetReplicationTasksIter(ctx context.Context, pollingCluster string, ...) (collection.Iterator[tasks.Task], error)
- func (m *MockReplicationStream) SubscribeReplicationNotification() (<-chan struct{}, string)
- func (m *MockReplicationStream) UnsubscribeReplicationNotification(arg0 string)
- type MockReplicationStreamMockRecorder
- func (mr *MockReplicationStreamMockRecorder) ConvertReplicationTask(ctx, task interface{}) *gomock.Call
- func (mr *MockReplicationStreamMockRecorder) GetReplicationTasksIter(ctx, pollingCluster, minInclusiveTaskID, maxExclusiveTaskID interface{}) *gomock.Call
- func (mr *MockReplicationStreamMockRecorder) SubscribeReplicationNotification() *gomock.Call
- func (mr *MockReplicationStreamMockRecorder) UnsubscribeReplicationNotification(arg0 interface{}) *gomock.Call
- type OwnershipAwareNamespaceQuotaCalculator
- type OwnershipAwareQuotaCalculator
- type OwnershipBasedQuotaScaler
- type OwnershipBasedQuotaScalerImpl
- type ReplicationStream
- type ShardCountSubscription
- type ShardCounter
Constants ¶
This section is empty.
Variables ¶
var (
ErrNonPositiveTotalNumShards = errors.New("totalNumShards must be greater than 0")
)
var ( // ErrShardStatusUnknown means we're not sure if we have the shard lock or not. This may be returned // during short windows at initialization and if we've lost the connection to the database. ErrShardStatusUnknown = serviceerror.NewUnavailable("shard status unknown") )
var Module = fx.Options( fx.Provide( ControllerProvider, func(impl *ControllerImpl) Controller { return impl }, ContextFactoryProvider, fx.Annotate( func(p Controller) common.Pingable { return p }, fx.ResultTags(`group:"deadlockDetectorRoots"`), ), ), ownershipBasedQuotaScalerModule, )
Functions ¶
func ConvertFromPersistenceTaskKey ¶ added in v1.21.0
func ConvertFromPersistenceTaskKey( key *persistencespb.TaskKey, ) tasks.Key
func ConvertToPersistenceTaskKey ¶ added in v1.21.0
func ConvertToPersistenceTaskKey( key tasks.Key, ) *persistencespb.TaskKey
func OperationPossiblySucceeded ¶ added in v1.17.0
func ReplicationReaderIDFromClusterShardID ¶ added in v1.21.0
ReplicationReaderIDFromClusterShardID convert from cluster ID & shard ID to reader ID NOTE: cluster metadata guarantee
- initial failover version <= int32 max
- failover increment <= int32 max
- initial failover version == cluster ID
func ReplicationReaderIDToClusterShardID ¶ added in v1.21.0
ReplicationReaderIDToClusterShardID convert from reader ID to cluster ID & shard ID NOTE: see ReplicationReaderIDFromClusterShardID
Types ¶
type CloseCallback ¶ added in v1.21.5
type CloseCallback func(ControllableContext)
type Context ¶
type Context interface { GetShardID() int32 GetRangeID() int64 GetOwner() string GetExecutionManager() persistence.ExecutionManager GetNamespaceRegistry() namespace.Registry GetClusterMetadata() cluster.Metadata GetConfig() *configs.Config GetEventsCache() events.Cache GetLogger() log.Logger GetThrottledLogger() log.Logger GetMetricsHandler() metrics.Handler GetTimeSource() clock.TimeSource GetRemoteAdminClient(string) (adminservice.AdminServiceClient, error) GetHistoryClient() historyservice.HistoryServiceClient GetPayloadSerializer() serialization.Serializer GetSearchAttributesProvider() searchattribute.Provider GetSearchAttributesMapperProvider() searchattribute.MapperProvider GetArchivalMetadata() archiver.ArchivalMetadata GetEngine(ctx context.Context) (Engine, error) AssertOwnership(ctx context.Context) error NewVectorClock() (*clockspb.VectorClock, error) CurrentVectorClock() *clockspb.VectorClock GenerateTaskID() (int64, error) GenerateTaskIDs(number int) ([]int64, error) GetQueueExclusiveHighReadWatermark(category tasks.Category) tasks.Key GetQueueState(category tasks.Category) (*persistencespb.QueueState, bool) SetQueueState(category tasks.Category, state *persistencespb.QueueState) error UpdateReplicationQueueReaderState(readerID int64, readerState *persistencespb.QueueReaderState) error GetReplicatorDLQAckLevel(sourceCluster string) int64 UpdateReplicatorDLQAckLevel(sourCluster string, ackLevel int64) error UpdateRemoteClusterInfo(cluster string, ackTaskID int64, ackTimestamp time.Time) UpdateRemoteReaderInfo(readerID int64, ackTaskID int64, ackTimestamp time.Time) error SetCurrentTime(cluster string, currentTime time.Time) GetCurrentTime(cluster string) time.Time GetReplicationStatus(cluster []string) (map[string]*historyservice.ShardReplicationStatusPerCluster, map[string]*historyservice.HandoverNamespaceInfo, error) UpdateHandoverNamespace(ns *namespace.Namespace, deletedFromDb bool) AppendHistoryEvents(ctx context.Context, request *persistence.AppendHistoryNodesRequest, namespaceID namespace.ID, execution *commonpb.WorkflowExecution) (int, error) AddTasks(ctx context.Context, request *persistence.AddHistoryTasksRequest) error AddSpeculativeWorkflowTaskTimeoutTask(task *tasks.WorkflowTaskTimeoutTask) error CreateWorkflowExecution(ctx context.Context, request *persistence.CreateWorkflowExecutionRequest) (*persistence.CreateWorkflowExecutionResponse, error) UpdateWorkflowExecution(ctx context.Context, request *persistence.UpdateWorkflowExecutionRequest) (*persistence.UpdateWorkflowExecutionResponse, error) ConflictResolveWorkflowExecution(ctx context.Context, request *persistence.ConflictResolveWorkflowExecutionRequest) (*persistence.ConflictResolveWorkflowExecutionResponse, error) SetWorkflowExecution(ctx context.Context, request *persistence.SetWorkflowExecutionRequest) (*persistence.SetWorkflowExecutionResponse, error) GetCurrentExecution(ctx context.Context, request *persistence.GetCurrentExecutionRequest) (*persistence.GetCurrentExecutionResponse, error) GetWorkflowExecution(ctx context.Context, request *persistence.GetWorkflowExecutionRequest) (*persistence.GetWorkflowExecutionResponse, error) // DeleteWorkflowExecution add task to delete visibility, current workflow execution, and deletes workflow execution. // If branchToken != nil, then delete history also, otherwise leave history. DeleteWorkflowExecution(ctx context.Context, workflowKey definition.WorkflowKey, branchToken []byte, startTime time.Time, closeTime time.Time, closeExecutionVisibilityTaskID int64, stage *tasks.DeleteWorkflowExecutionStage) error UnloadForOwnershipLost() }
Context represents a history engine shard
type ContextFactory ¶ added in v1.21.5
type ContextFactory interface {
CreateContext(shardID int32, closeCallback CloseCallback) (ControllableContext, error)
}
func ContextFactoryProvider ¶ added in v1.21.5
func ContextFactoryProvider(params ContextFactoryParams) ContextFactory
type ContextFactoryParams ¶ added in v1.21.5
type ContextFactoryParams struct { fx.In ArchivalMetadata archiver.ArchivalMetadata ClientBean client.Bean ClusterMetadata cluster.Metadata Config *configs.Config PersistenceConfig config.Persistence EngineFactory EngineFactory HistoryClient resource.HistoryClient HistoryServiceResolver membership.ServiceResolver HostInfoProvider membership.HostInfoProvider Logger log.Logger MetricsHandler metrics.Handler NamespaceRegistry namespace.Registry PayloadSerializer serialization.Serializer PersistenceExecutionManager persistence.ExecutionManager PersistenceShardManager persistence.ShardManager SaMapperProvider searchattribute.MapperProvider SaProvider searchattribute.Provider ThrottledLogger log.ThrottledLogger TimeSource clock.TimeSource TaskCategoryRegistry tasks.TaskCategoryRegistry }
type ContextImpl ¶
type ContextImpl struct {
// contains filtered or unexported fields
}
func (*ContextImpl) AddSpeculativeWorkflowTaskTimeoutTask ¶ added in v1.21.0
func (s *ContextImpl) AddSpeculativeWorkflowTaskTimeoutTask( task *tasks.WorkflowTaskTimeoutTask, ) error
func (*ContextImpl) AddTasks ¶ added in v1.5.0
func (s *ContextImpl) AddTasks( ctx context.Context, request *persistence.AddHistoryTasksRequest, ) error
func (*ContextImpl) AppendHistoryEvents ¶ added in v1.5.0
func (s *ContextImpl) AppendHistoryEvents( ctx context.Context, request *persistence.AppendHistoryNodesRequest, namespaceID namespace.ID, execution *commonpb.WorkflowExecution, ) (int, error)
func (*ContextImpl) AssertOwnership ¶ added in v1.17.0
func (s *ContextImpl) AssertOwnership( ctx context.Context, ) error
func (*ContextImpl) ConflictResolveWorkflowExecution ¶
func (s *ContextImpl) ConflictResolveWorkflowExecution( ctx context.Context, request *persistence.ConflictResolveWorkflowExecutionRequest, ) (*persistence.ConflictResolveWorkflowExecutionResponse, error)
func (*ContextImpl) CreateWorkflowExecution ¶
func (s *ContextImpl) CreateWorkflowExecution( ctx context.Context, request *persistence.CreateWorkflowExecutionRequest, ) (*persistence.CreateWorkflowExecutionResponse, error)
func (*ContextImpl) CurrentVectorClock ¶ added in v1.17.0
func (s *ContextImpl) CurrentVectorClock() *clockspb.VectorClock
func (*ContextImpl) DeleteWorkflowExecution ¶ added in v1.14.0
func (s *ContextImpl) DeleteWorkflowExecution( ctx context.Context, key definition.WorkflowKey, branchToken []byte, startTime time.Time, closeTime time.Time, closeVisibilityTaskId int64, stage *tasks.DeleteWorkflowExecutionStage, ) (retErr error)
func (*ContextImpl) FinishStop ¶ added in v1.21.5
func (s *ContextImpl) FinishStop()
FinishStop should only be called by the controller.
func (*ContextImpl) GenerateTaskID ¶ added in v1.16.0
func (s *ContextImpl) GenerateTaskID() (int64, error)
func (*ContextImpl) GenerateTaskIDs ¶ added in v1.16.0
func (s *ContextImpl) GenerateTaskIDs(number int) ([]int64, error)
func (*ContextImpl) GetArchivalMetadata ¶ added in v1.14.0
func (s *ContextImpl) GetArchivalMetadata() archiver.ArchivalMetadata
func (*ContextImpl) GetClusterMetadata ¶ added in v1.14.0
func (s *ContextImpl) GetClusterMetadata() cluster.Metadata
func (*ContextImpl) GetConfig ¶
func (s *ContextImpl) GetConfig() *configs.Config
func (*ContextImpl) GetCurrentExecution ¶ added in v1.16.0
func (s *ContextImpl) GetCurrentExecution( ctx context.Context, request *persistence.GetCurrentExecutionRequest, ) (*persistence.GetCurrentExecutionResponse, error)
func (*ContextImpl) GetCurrentTime ¶
func (s *ContextImpl) GetCurrentTime(cluster string) time.Time
func (*ContextImpl) GetEngine ¶
func (s *ContextImpl) GetEngine( ctx context.Context, ) (Engine, error)
func (*ContextImpl) GetEventsCache ¶
func (s *ContextImpl) GetEventsCache() events.Cache
func (*ContextImpl) GetExecutionManager ¶
func (s *ContextImpl) GetExecutionManager() persistence.ExecutionManager
func (*ContextImpl) GetHistoryClient ¶ added in v1.14.0
func (s *ContextImpl) GetHistoryClient() historyservice.HistoryServiceClient
func (*ContextImpl) GetLogger ¶
func (s *ContextImpl) GetLogger() log.Logger
func (*ContextImpl) GetMetricsHandler ¶ added in v1.17.3
func (s *ContextImpl) GetMetricsHandler() metrics.Handler
func (*ContextImpl) GetNamespaceRegistry ¶ added in v1.14.0
func (s *ContextImpl) GetNamespaceRegistry() namespace.Registry
func (*ContextImpl) GetOwner ¶ added in v1.21.0
func (s *ContextImpl) GetOwner() string
func (*ContextImpl) GetPayloadSerializer ¶ added in v1.14.0
func (s *ContextImpl) GetPayloadSerializer() serialization.Serializer
func (*ContextImpl) GetPingChecks ¶ added in v1.19.0
func (s *ContextImpl) GetPingChecks() []common.PingCheck
func (*ContextImpl) GetQueueExclusiveHighReadWatermark ¶ added in v1.17.3
func (s *ContextImpl) GetQueueExclusiveHighReadWatermark( category tasks.Category, ) tasks.Key
func (*ContextImpl) GetQueueState ¶ added in v1.17.3
func (s *ContextImpl) GetQueueState( category tasks.Category, ) (*persistencespb.QueueState, bool)
func (*ContextImpl) GetRangeID ¶ added in v1.21.0
func (s *ContextImpl) GetRangeID() int64
func (*ContextImpl) GetRemoteAdminClient ¶ added in v1.14.0
func (s *ContextImpl) GetRemoteAdminClient(cluster string) (adminservice.AdminServiceClient, error)
func (*ContextImpl) GetReplicationStatus ¶ added in v1.14.0
func (s *ContextImpl) GetReplicationStatus(clusterNames []string) (map[string]*historyservice.ShardReplicationStatusPerCluster, map[string]*historyservice.HandoverNamespaceInfo, error)
func (*ContextImpl) GetReplicatorDLQAckLevel ¶
func (s *ContextImpl) GetReplicatorDLQAckLevel(sourceCluster string) int64
func (*ContextImpl) GetSearchAttributesMapperProvider ¶ added in v1.20.0
func (s *ContextImpl) GetSearchAttributesMapperProvider() searchattribute.MapperProvider
func (*ContextImpl) GetSearchAttributesProvider ¶ added in v1.14.0
func (s *ContextImpl) GetSearchAttributesProvider() searchattribute.Provider
func (*ContextImpl) GetShardID ¶
func (s *ContextImpl) GetShardID() int32
func (*ContextImpl) GetThrottledLogger ¶
func (s *ContextImpl) GetThrottledLogger() log.Logger
func (*ContextImpl) GetTimeSource ¶ added in v1.14.0
func (s *ContextImpl) GetTimeSource() cclock.TimeSource
func (*ContextImpl) GetWorkflowExecution ¶ added in v1.16.0
func (s *ContextImpl) GetWorkflowExecution( ctx context.Context, request *persistence.GetWorkflowExecutionRequest, ) (*persistence.GetWorkflowExecutionResponse, error)
func (*ContextImpl) IsValid ¶ added in v1.21.0
func (s *ContextImpl) IsValid() bool
func (*ContextImpl) NewVectorClock ¶ added in v1.17.0
func (s *ContextImpl) NewVectorClock() (*clockspb.VectorClock, error)
func (*ContextImpl) SetCurrentTime ¶
func (s *ContextImpl) SetCurrentTime(cluster string, currentTime time.Time)
func (*ContextImpl) SetQueueState ¶ added in v1.21.0
func (s *ContextImpl) SetQueueState( category tasks.Category, state *persistencespb.QueueState, ) error
func (*ContextImpl) SetWorkflowExecution ¶ added in v1.16.0
func (s *ContextImpl) SetWorkflowExecution( ctx context.Context, request *persistence.SetWorkflowExecutionRequest, ) (*persistence.SetWorkflowExecutionResponse, error)
func (*ContextImpl) String ¶ added in v1.17.0
func (s *ContextImpl) String() string
func (*ContextImpl) UnloadForOwnershipLost ¶ added in v1.21.5
func (s *ContextImpl) UnloadForOwnershipLost()
func (*ContextImpl) UpdateHandoverNamespace ¶ added in v1.20.0
func (s *ContextImpl) UpdateHandoverNamespace(ns *namespace.Namespace, deletedFromDb bool)
func (*ContextImpl) UpdateRemoteClusterInfo ¶ added in v1.16.0
func (s *ContextImpl) UpdateRemoteClusterInfo( clusterName string, ackTaskID int64, ackTimestamp time.Time, )
UpdateRemoteClusterInfo deprecated Deprecated use UpdateRemoteReaderInfo in the future instead
func (*ContextImpl) UpdateRemoteReaderInfo ¶ added in v1.21.0
func (s *ContextImpl) UpdateRemoteReaderInfo( readerID int64, ackTaskID int64, ackTimestamp time.Time, ) error
UpdateRemoteReaderInfo do not use streaming replication until remoteClusterInfo is updated to allow both streaming & pull based replication
func (*ContextImpl) UpdateReplicationQueueReaderState ¶ added in v1.21.0
func (s *ContextImpl) UpdateReplicationQueueReaderState( readerID int64, readerState *persistencespb.QueueReaderState, ) error
func (*ContextImpl) UpdateReplicatorDLQAckLevel ¶
func (s *ContextImpl) UpdateReplicatorDLQAckLevel( sourceCluster string, ackLevel int64, ) error
func (*ContextImpl) UpdateWorkflowExecution ¶
func (s *ContextImpl) UpdateWorkflowExecution( ctx context.Context, request *persistence.UpdateWorkflowExecutionRequest, ) (*persistence.UpdateWorkflowExecutionResponse, error)
type ContextTest ¶
type ContextTest struct { *ContextImpl Resource *resourcetest.Test MockEventsCache *events.MockCache }
func NewTestContext ¶
func NewTestContext( ctrl *gomock.Controller, shardInfo *persistencespb.ShardInfo, config *configs.Config, ) *ContextTest
func NewTestContextWithTimeSource ¶ added in v1.14.0
func NewTestContextWithTimeSource( ctrl *gomock.Controller, shardInfo *persistencespb.ShardInfo, config *configs.Config, timeSource clock.TimeSource, ) *ContextTest
func (*ContextTest) SetEngineForTesting ¶ added in v1.14.0
func (s *ContextTest) SetEngineForTesting(engine Engine)
SetEngineForTest sets s.engine. Only used by tests.
func (*ContextTest) SetEventsCacheForTesting ¶ added in v1.14.0
func (s *ContextTest) SetEventsCacheForTesting(c events.Cache)
SetEventsCacheForTesting sets s.eventsCache. Only used by tests.
func (*ContextTest) SetHistoryClientForTesting ¶ added in v1.20.0
func (s *ContextTest) SetHistoryClientForTesting(client historyservice.HistoryServiceClient)
SetHistoryClientForTesting sets history client. Only used by tests.
func (*ContextTest) StopForTest ¶ added in v1.14.0
func (s *ContextTest) StopForTest()
StopForTest calls FinishStop(). In general only the controller should call that, but integration tests need to do it also to clean up any background acquireShard goroutines that may exist.
type ControllableContext ¶ added in v1.21.5
A ControllableContext is a Context plus other methods needed by the Controller.
type Controller ¶ added in v1.17.3
type ControllerImpl ¶
func ControllerProvider ¶ added in v1.17.3
func ControllerProvider( config *configs.Config, logger log.Logger, historyServiceResolver membership.ServiceResolver, metricsHandler metrics.Handler, hostInfoProvider membership.HostInfoProvider, contextFactory ContextFactory, ) *ControllerImpl
func (*ControllerImpl) CloseShardByID ¶ added in v1.14.0
func (c *ControllerImpl) CloseShardByID(shardID int32)
func (*ControllerImpl) GetPingChecks ¶ added in v1.19.0
func (c *ControllerImpl) GetPingChecks() []common.PingCheck
func (*ControllerImpl) GetShardByID ¶ added in v1.17.0
func (c *ControllerImpl) GetShardByID( shardID int32, ) (Context, error)
GetShardByID returns a shard context for the given shard id. The shard context may not have acquired a rangeid lease yet. Callers can use GetEngine on the shard to block on rangeid lease acquisition.
func (*ControllerImpl) GetShardByNamespaceWorkflow ¶ added in v1.17.0
func (c *ControllerImpl) GetShardByNamespaceWorkflow( namespaceID namespace.ID, workflowID string, ) (Context, error)
GetShardByID returns a shard context for the given namespace and workflow. The shard context may not have acquired a rangeid lease yet. Callers can use GetEngine on the shard to block on rangeid lease acquisition.
func (*ControllerImpl) ShardIDs ¶
func (c *ControllerImpl) ShardIDs() []int32
func (*ControllerImpl) Start ¶
func (c *ControllerImpl) Start()
func (*ControllerImpl) Status ¶
func (c *ControllerImpl) Status() int32
func (*ControllerImpl) Stop ¶
func (c *ControllerImpl) Stop()
func (*ControllerImpl) SubscribeShardCount ¶ added in v1.22.0
func (c *ControllerImpl) SubscribeShardCount() ShardCountSubscription
SubscribeShardCount returns a subscription to shard count updates with a 1-buffered channel. This method is thread-safe.
type Engine ¶
type Engine interface { StartWorkflowExecution(ctx context.Context, request *historyservice.StartWorkflowExecutionRequest) (*historyservice.StartWorkflowExecutionResponse, error) GetMutableState(ctx context.Context, request *historyservice.GetMutableStateRequest) (*historyservice.GetMutableStateResponse, error) PollMutableState(ctx context.Context, request *historyservice.PollMutableStateRequest) (*historyservice.PollMutableStateResponse, error) DescribeMutableState(ctx context.Context, request *historyservice.DescribeMutableStateRequest) (*historyservice.DescribeMutableStateResponse, error) ResetStickyTaskQueue(ctx context.Context, resetRequest *historyservice.ResetStickyTaskQueueRequest) (*historyservice.ResetStickyTaskQueueResponse, error) DescribeWorkflowExecution(ctx context.Context, request *historyservice.DescribeWorkflowExecutionRequest) (*historyservice.DescribeWorkflowExecutionResponse, error) RecordWorkflowTaskStarted(ctx context.Context, request *historyservice.RecordWorkflowTaskStartedRequest) (*historyservice.RecordWorkflowTaskStartedResponse, error) RecordActivityTaskStarted(ctx context.Context, request *historyservice.RecordActivityTaskStartedRequest) (*historyservice.RecordActivityTaskStartedResponse, error) RespondWorkflowTaskCompleted(ctx context.Context, request *historyservice.RespondWorkflowTaskCompletedRequest) (*historyservice.RespondWorkflowTaskCompletedResponse, error) RespondWorkflowTaskFailed(ctx context.Context, request *historyservice.RespondWorkflowTaskFailedRequest) error RespondActivityTaskCompleted(ctx context.Context, request *historyservice.RespondActivityTaskCompletedRequest) (*historyservice.RespondActivityTaskCompletedResponse, error) RespondActivityTaskFailed(ctx context.Context, request *historyservice.RespondActivityTaskFailedRequest) (*historyservice.RespondActivityTaskFailedResponse, error) RespondActivityTaskCanceled(ctx context.Context, request *historyservice.RespondActivityTaskCanceledRequest) (*historyservice.RespondActivityTaskCanceledResponse, error) RecordActivityTaskHeartbeat(ctx context.Context, request *historyservice.RecordActivityTaskHeartbeatRequest) (*historyservice.RecordActivityTaskHeartbeatResponse, error) RequestCancelWorkflowExecution(ctx context.Context, request *historyservice.RequestCancelWorkflowExecutionRequest) (*historyservice.RequestCancelWorkflowExecutionResponse, error) SignalWorkflowExecution(ctx context.Context, request *historyservice.SignalWorkflowExecutionRequest) (*historyservice.SignalWorkflowExecutionResponse, error) SignalWithStartWorkflowExecution(ctx context.Context, request *historyservice.SignalWithStartWorkflowExecutionRequest) (*historyservice.SignalWithStartWorkflowExecutionResponse, error) RemoveSignalMutableState(ctx context.Context, request *historyservice.RemoveSignalMutableStateRequest) (*historyservice.RemoveSignalMutableStateResponse, error) TerminateWorkflowExecution(ctx context.Context, request *historyservice.TerminateWorkflowExecutionRequest) (*historyservice.TerminateWorkflowExecutionResponse, error) DeleteWorkflowExecution(ctx context.Context, deleteRequest *historyservice.DeleteWorkflowExecutionRequest) (*historyservice.DeleteWorkflowExecutionResponse, error) ResetWorkflowExecution(ctx context.Context, request *historyservice.ResetWorkflowExecutionRequest) (*historyservice.ResetWorkflowExecutionResponse, error) ScheduleWorkflowTask(ctx context.Context, request *historyservice.ScheduleWorkflowTaskRequest) error IsActivityTaskValid(ctx context.Context, request *historyservice.IsActivityTaskValidRequest) (*historyservice.IsActivityTaskValidResponse, error) IsWorkflowTaskValid(ctx context.Context, request *historyservice.IsWorkflowTaskValidRequest) (*historyservice.IsWorkflowTaskValidResponse, error) VerifyFirstWorkflowTaskScheduled(ctx context.Context, request *historyservice.VerifyFirstWorkflowTaskScheduledRequest) error RecordChildExecutionCompleted(ctx context.Context, request *historyservice.RecordChildExecutionCompletedRequest) (*historyservice.RecordChildExecutionCompletedResponse, error) VerifyChildExecutionCompletionRecorded(ctx context.Context, request *historyservice.VerifyChildExecutionCompletionRecordedRequest) (*historyservice.VerifyChildExecutionCompletionRecordedResponse, error) // ReplicateHistoryEvents is for a WIP feature. Ultimately will replace the ReplicateEventsV2 API ReplicateHistoryEvents( ctx context.Context, workflowKey definition.WorkflowKey, baseExecutionInfo *workflowpb.BaseExecutionInfo, versionHistoryItems []*historyspb.VersionHistoryItem, historyEvents [][]*historypb.HistoryEvent, newEvents []*historypb.HistoryEvent, ) error ReplicateEventsV2(ctx context.Context, request *historyservice.ReplicateEventsV2Request) error ReplicateWorkflowState(ctx context.Context, request *historyservice.ReplicateWorkflowStateRequest) error SyncShardStatus(ctx context.Context, request *historyservice.SyncShardStatusRequest) error SyncActivity(ctx context.Context, request *historyservice.SyncActivityRequest) error GetReplicationMessages(ctx context.Context, pollingCluster string, ackMessageID int64, ackTimestamp time.Time, queryMessageID int64) (*replicationspb.ReplicationMessages, error) GetDLQReplicationMessages(ctx context.Context, taskInfos []*replicationspb.ReplicationTaskInfo) ([]*replicationspb.ReplicationTask, error) QueryWorkflow(ctx context.Context, request *historyservice.QueryWorkflowRequest) (*historyservice.QueryWorkflowResponse, error) ReapplyEvents(ctx context.Context, namespaceUUID namespace.ID, workflowID string, runID string, events []*historypb.HistoryEvent) error GetDLQMessages(ctx context.Context, messagesRequest *historyservice.GetDLQMessagesRequest) (*historyservice.GetDLQMessagesResponse, error) PurgeDLQMessages(ctx context.Context, messagesRequest *historyservice.PurgeDLQMessagesRequest) (*historyservice.PurgeDLQMessagesResponse, error) MergeDLQMessages(ctx context.Context, messagesRequest *historyservice.MergeDLQMessagesRequest) (*historyservice.MergeDLQMessagesResponse, error) RebuildMutableState(ctx context.Context, namespaceUUID namespace.ID, execution *commonpb.WorkflowExecution) error ImportWorkflowExecution(ctx context.Context, request *historyservice.ImportWorkflowExecutionRequest) (*historyservice.ImportWorkflowExecutionResponse, error) RefreshWorkflowTasks(ctx context.Context, namespaceUUID namespace.ID, execution *commonpb.WorkflowExecution) error GenerateLastHistoryReplicationTasks(ctx context.Context, request *historyservice.GenerateLastHistoryReplicationTasksRequest) (*historyservice.GenerateLastHistoryReplicationTasksResponse, error) GetReplicationStatus(ctx context.Context, request *historyservice.GetReplicationStatusRequest) (*historyservice.ShardReplicationStatus, error) UpdateWorkflowExecution(ctx context.Context, request *historyservice.UpdateWorkflowExecutionRequest) (*historyservice.UpdateWorkflowExecutionResponse, error) PollWorkflowExecutionUpdate(ctx context.Context, request *historyservice.PollWorkflowExecutionUpdateRequest) (*historyservice.PollWorkflowExecutionUpdateResponse, error) GetWorkflowExecutionHistory(ctx context.Context, request *historyservice.GetWorkflowExecutionHistoryRequest) (*historyservice.GetWorkflowExecutionHistoryResponse, error) GetWorkflowExecutionHistoryReverse(ctx context.Context, request *historyservice.GetWorkflowExecutionHistoryReverseRequest) (*historyservice.GetWorkflowExecutionHistoryReverseResponse, error) GetWorkflowExecutionRawHistoryV2(ctx context.Context, request *historyservice.GetWorkflowExecutionRawHistoryV2Request) (*historyservice.GetWorkflowExecutionRawHistoryV2Response, error) AddTasks(ctx context.Context, request *historyservice.AddTasksRequest) (*historyservice.AddTasksResponse, error) NotifyNewHistoryEvent(event *events.Notification) NotifyNewTasks(tasks map[tasks.Category][]tasks.Task) AddSpeculativeWorkflowTaskTimeoutTask(task *tasks.WorkflowTaskTimeoutTask) ReplicationStream Start() Stop() }
Engine represents an interface for managing workflow execution history.
type EngineFactory ¶
EngineFactory is used to create an instance of sharded history engine
type LazyLoadedOwnershipBasedQuotaScaler ¶ added in v1.23.0
type LazyLoadedOwnershipBasedQuotaScaler struct {
*atomic.Value // value type is OwnershipBasedQuotaScaler
}
func (LazyLoadedOwnershipBasedQuotaScaler) ScaleFactor ¶ added in v1.23.0
func (s LazyLoadedOwnershipBasedQuotaScaler) ScaleFactor() (float64, bool)
type MockContext ¶
type MockContext struct {
// contains filtered or unexported fields
}
MockContext is a mock of Context interface.
func NewMockContext ¶
func NewMockContext(ctrl *gomock.Controller) *MockContext
NewMockContext creates a new mock instance.
func (*MockContext) AddSpeculativeWorkflowTaskTimeoutTask ¶ added in v1.21.0
func (m *MockContext) AddSpeculativeWorkflowTaskTimeoutTask(task *tasks.WorkflowTaskTimeoutTask) error
AddSpeculativeWorkflowTaskTimeoutTask mocks base method.
func (*MockContext) AddTasks ¶ added in v1.5.0
func (m *MockContext) AddTasks(ctx context.Context, request *persistence.AddHistoryTasksRequest) error
AddTasks mocks base method.
func (*MockContext) AppendHistoryEvents ¶ added in v1.5.0
func (m *MockContext) AppendHistoryEvents(ctx context.Context, request *persistence.AppendHistoryNodesRequest, namespaceID namespace.ID, execution *v1.WorkflowExecution) (int, error)
AppendHistoryEvents mocks base method.
func (*MockContext) AssertOwnership ¶ added in v1.17.0
func (m *MockContext) AssertOwnership(ctx context.Context) error
AssertOwnership mocks base method.
func (*MockContext) ConflictResolveWorkflowExecution ¶
func (m *MockContext) ConflictResolveWorkflowExecution(ctx context.Context, request *persistence.ConflictResolveWorkflowExecutionRequest) (*persistence.ConflictResolveWorkflowExecutionResponse, error)
ConflictResolveWorkflowExecution mocks base method.
func (*MockContext) CreateWorkflowExecution ¶
func (m *MockContext) CreateWorkflowExecution(ctx context.Context, request *persistence.CreateWorkflowExecutionRequest) (*persistence.CreateWorkflowExecutionResponse, error)
CreateWorkflowExecution mocks base method.
func (*MockContext) CurrentVectorClock ¶ added in v1.17.0
func (m *MockContext) CurrentVectorClock() *v11.VectorClock
CurrentVectorClock mocks base method.
func (*MockContext) DeleteWorkflowExecution ¶ added in v1.14.0
func (m *MockContext) DeleteWorkflowExecution(ctx context.Context, workflowKey definition.WorkflowKey, branchToken []byte, startTime, closeTime time.Time, closeExecutionVisibilityTaskID int64, stage *tasks.DeleteWorkflowExecutionStage) error
DeleteWorkflowExecution mocks base method.
func (*MockContext) EXPECT ¶
func (m *MockContext) EXPECT() *MockContextMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockContext) GenerateTaskID ¶ added in v1.16.0
func (m *MockContext) GenerateTaskID() (int64, error)
GenerateTaskID mocks base method.
func (*MockContext) GenerateTaskIDs ¶ added in v1.16.0
func (m *MockContext) GenerateTaskIDs(number int) ([]int64, error)
GenerateTaskIDs mocks base method.
func (*MockContext) GetArchivalMetadata ¶ added in v1.14.0
func (m *MockContext) GetArchivalMetadata() archiver.ArchivalMetadata
GetArchivalMetadata mocks base method.
func (*MockContext) GetClusterMetadata ¶
func (m *MockContext) GetClusterMetadata() cluster.Metadata
GetClusterMetadata mocks base method.
func (*MockContext) GetConfig ¶
func (m *MockContext) GetConfig() *configs.Config
GetConfig mocks base method.
func (*MockContext) GetCurrentExecution ¶ added in v1.16.0
func (m *MockContext) GetCurrentExecution(ctx context.Context, request *persistence.GetCurrentExecutionRequest) (*persistence.GetCurrentExecutionResponse, error)
GetCurrentExecution mocks base method.
func (*MockContext) GetCurrentTime ¶
func (m *MockContext) GetCurrentTime(cluster string) time.Time
GetCurrentTime mocks base method.
func (*MockContext) GetEngine ¶
func (m *MockContext) GetEngine(ctx context.Context) (Engine, error)
GetEngine mocks base method.
func (*MockContext) GetEventsCache ¶
func (m *MockContext) GetEventsCache() events.Cache
GetEventsCache mocks base method.
func (*MockContext) GetExecutionManager ¶
func (m *MockContext) GetExecutionManager() persistence.ExecutionManager
GetExecutionManager mocks base method.
func (*MockContext) GetHistoryClient ¶ added in v1.14.0
func (m *MockContext) GetHistoryClient() v12.HistoryServiceClient
GetHistoryClient mocks base method.
func (*MockContext) GetLogger ¶
func (m *MockContext) GetLogger() log.Logger
GetLogger mocks base method.
func (*MockContext) GetMetricsHandler ¶ added in v1.17.3
func (m *MockContext) GetMetricsHandler() metrics.Handler
GetMetricsHandler mocks base method.
func (*MockContext) GetNamespaceRegistry ¶ added in v1.13.0
func (m *MockContext) GetNamespaceRegistry() namespace.Registry
GetNamespaceRegistry mocks base method.
func (*MockContext) GetOwner ¶ added in v1.21.0
func (m *MockContext) GetOwner() string
GetOwner mocks base method.
func (*MockContext) GetPayloadSerializer ¶ added in v1.14.0
func (m *MockContext) GetPayloadSerializer() serialization.Serializer
GetPayloadSerializer mocks base method.
func (*MockContext) GetQueueExclusiveHighReadWatermark ¶ added in v1.17.3
func (m *MockContext) GetQueueExclusiveHighReadWatermark(category tasks.Category) tasks.Key
GetQueueExclusiveHighReadWatermark mocks base method.
func (*MockContext) GetQueueState ¶ added in v1.17.3
func (m *MockContext) GetQueueState(category tasks.Category) (*v13.QueueState, bool)
GetQueueState mocks base method.
func (*MockContext) GetRangeID ¶ added in v1.21.0
func (m *MockContext) GetRangeID() int64
GetRangeID mocks base method.
func (*MockContext) GetRemoteAdminClient ¶ added in v1.14.0
func (m *MockContext) GetRemoteAdminClient(arg0 string) (v10.AdminServiceClient, error)
GetRemoteAdminClient mocks base method.
func (*MockContext) GetReplicationStatus ¶ added in v1.14.0
func (m *MockContext) GetReplicationStatus(cluster []string) (map[string]*v12.ShardReplicationStatusPerCluster, map[string]*v12.HandoverNamespaceInfo, error)
GetReplicationStatus mocks base method.
func (*MockContext) GetReplicatorDLQAckLevel ¶
func (m *MockContext) GetReplicatorDLQAckLevel(sourceCluster string) int64
GetReplicatorDLQAckLevel mocks base method.
func (*MockContext) GetSearchAttributesMapperProvider ¶ added in v1.20.0
func (m *MockContext) GetSearchAttributesMapperProvider() searchattribute.MapperProvider
GetSearchAttributesMapperProvider mocks base method.
func (*MockContext) GetSearchAttributesProvider ¶ added in v1.14.0
func (m *MockContext) GetSearchAttributesProvider() searchattribute.Provider
GetSearchAttributesProvider mocks base method.
func (*MockContext) GetShardID ¶
func (m *MockContext) GetShardID() int32
GetShardID mocks base method.
func (*MockContext) GetThrottledLogger ¶
func (m *MockContext) GetThrottledLogger() log.Logger
GetThrottledLogger mocks base method.
func (*MockContext) GetTimeSource ¶
func (m *MockContext) GetTimeSource() clock.TimeSource
GetTimeSource mocks base method.
func (*MockContext) GetWorkflowExecution ¶ added in v1.16.0
func (m *MockContext) GetWorkflowExecution(ctx context.Context, request *persistence.GetWorkflowExecutionRequest) (*persistence.GetWorkflowExecutionResponse, error)
GetWorkflowExecution mocks base method.
func (*MockContext) NewVectorClock ¶ added in v1.17.0
func (m *MockContext) NewVectorClock() (*v11.VectorClock, error)
NewVectorClock mocks base method.
func (*MockContext) SetCurrentTime ¶
func (m *MockContext) SetCurrentTime(cluster string, currentTime time.Time)
SetCurrentTime mocks base method.
func (*MockContext) SetQueueState ¶ added in v1.21.0
func (m *MockContext) SetQueueState(category tasks.Category, state *v13.QueueState) error
SetQueueState mocks base method.
func (*MockContext) SetWorkflowExecution ¶ added in v1.16.0
func (m *MockContext) SetWorkflowExecution(ctx context.Context, request *persistence.SetWorkflowExecutionRequest) (*persistence.SetWorkflowExecutionResponse, error)
SetWorkflowExecution mocks base method.
func (*MockContext) UnloadForOwnershipLost ¶ added in v1.21.5
func (m *MockContext) UnloadForOwnershipLost()
UnloadForOwnershipLost mocks base method.
func (*MockContext) UpdateHandoverNamespace ¶ added in v1.20.0
func (m *MockContext) UpdateHandoverNamespace(ns *namespace.Namespace, deletedFromDb bool)
UpdateHandoverNamespace mocks base method.
func (*MockContext) UpdateRemoteClusterInfo ¶ added in v1.16.0
func (m *MockContext) UpdateRemoteClusterInfo(cluster string, ackTaskID int64, ackTimestamp time.Time)
UpdateRemoteClusterInfo mocks base method.
func (*MockContext) UpdateRemoteReaderInfo ¶ added in v1.21.0
func (m *MockContext) UpdateRemoteReaderInfo(readerID, ackTaskID int64, ackTimestamp time.Time) error
UpdateRemoteReaderInfo mocks base method.
func (*MockContext) UpdateReplicationQueueReaderState ¶ added in v1.21.0
func (m *MockContext) UpdateReplicationQueueReaderState(readerID int64, readerState *v13.QueueReaderState) error
UpdateReplicationQueueReaderState mocks base method.
func (*MockContext) UpdateReplicatorDLQAckLevel ¶
func (m *MockContext) UpdateReplicatorDLQAckLevel(sourCluster string, ackLevel int64) error
UpdateReplicatorDLQAckLevel mocks base method.
func (*MockContext) UpdateWorkflowExecution ¶
func (m *MockContext) UpdateWorkflowExecution(ctx context.Context, request *persistence.UpdateWorkflowExecutionRequest) (*persistence.UpdateWorkflowExecutionResponse, error)
UpdateWorkflowExecution mocks base method.
type MockContextFactory ¶ added in v1.21.5
type MockContextFactory struct {
// contains filtered or unexported fields
}
MockContextFactory is a mock of ContextFactory interface.
func NewMockContextFactory ¶ added in v1.21.5
func NewMockContextFactory(ctrl *gomock.Controller) *MockContextFactory
NewMockContextFactory creates a new mock instance.
func (*MockContextFactory) CreateContext ¶ added in v1.21.5
func (m *MockContextFactory) CreateContext(shardID int32, closeCallback CloseCallback) (ControllableContext, error)
CreateContext mocks base method.
func (*MockContextFactory) EXPECT ¶ added in v1.21.5
func (m *MockContextFactory) EXPECT() *MockContextFactoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockContextFactoryMockRecorder ¶ added in v1.21.5
type MockContextFactoryMockRecorder struct {
// contains filtered or unexported fields
}
MockContextFactoryMockRecorder is the mock recorder for MockContextFactory.
func (*MockContextFactoryMockRecorder) CreateContext ¶ added in v1.21.5
func (mr *MockContextFactoryMockRecorder) CreateContext(shardID, closeCallback interface{}) *gomock.Call
CreateContext indicates an expected call of CreateContext.
type MockContextMockRecorder ¶
type MockContextMockRecorder struct {
// contains filtered or unexported fields
}
MockContextMockRecorder is the mock recorder for MockContext.
func (*MockContextMockRecorder) AddSpeculativeWorkflowTaskTimeoutTask ¶ added in v1.21.0
func (mr *MockContextMockRecorder) AddSpeculativeWorkflowTaskTimeoutTask(task interface{}) *gomock.Call
AddSpeculativeWorkflowTaskTimeoutTask indicates an expected call of AddSpeculativeWorkflowTaskTimeoutTask.
func (*MockContextMockRecorder) AddTasks ¶ added in v1.5.0
func (mr *MockContextMockRecorder) AddTasks(ctx, request interface{}) *gomock.Call
AddTasks indicates an expected call of AddTasks.
func (*MockContextMockRecorder) AppendHistoryEvents ¶ added in v1.5.0
func (mr *MockContextMockRecorder) AppendHistoryEvents(ctx, request, namespaceID, execution interface{}) *gomock.Call
AppendHistoryEvents indicates an expected call of AppendHistoryEvents.
func (*MockContextMockRecorder) AssertOwnership ¶ added in v1.17.0
func (mr *MockContextMockRecorder) AssertOwnership(ctx interface{}) *gomock.Call
AssertOwnership indicates an expected call of AssertOwnership.
func (*MockContextMockRecorder) ConflictResolveWorkflowExecution ¶
func (mr *MockContextMockRecorder) ConflictResolveWorkflowExecution(ctx, request interface{}) *gomock.Call
ConflictResolveWorkflowExecution indicates an expected call of ConflictResolveWorkflowExecution.
func (*MockContextMockRecorder) CreateWorkflowExecution ¶
func (mr *MockContextMockRecorder) CreateWorkflowExecution(ctx, request interface{}) *gomock.Call
CreateWorkflowExecution indicates an expected call of CreateWorkflowExecution.
func (*MockContextMockRecorder) CurrentVectorClock ¶ added in v1.17.0
func (mr *MockContextMockRecorder) CurrentVectorClock() *gomock.Call
CurrentVectorClock indicates an expected call of CurrentVectorClock.
func (*MockContextMockRecorder) DeleteWorkflowExecution ¶ added in v1.14.0
func (mr *MockContextMockRecorder) DeleteWorkflowExecution(ctx, workflowKey, branchToken, startTime, closeTime, closeExecutionVisibilityTaskID, stage interface{}) *gomock.Call
DeleteWorkflowExecution indicates an expected call of DeleteWorkflowExecution.
func (*MockContextMockRecorder) GenerateTaskID ¶ added in v1.16.0
func (mr *MockContextMockRecorder) GenerateTaskID() *gomock.Call
GenerateTaskID indicates an expected call of GenerateTaskID.
func (*MockContextMockRecorder) GenerateTaskIDs ¶ added in v1.16.0
func (mr *MockContextMockRecorder) GenerateTaskIDs(number interface{}) *gomock.Call
GenerateTaskIDs indicates an expected call of GenerateTaskIDs.
func (*MockContextMockRecorder) GetArchivalMetadata ¶ added in v1.14.0
func (mr *MockContextMockRecorder) GetArchivalMetadata() *gomock.Call
GetArchivalMetadata indicates an expected call of GetArchivalMetadata.
func (*MockContextMockRecorder) GetClusterMetadata ¶
func (mr *MockContextMockRecorder) GetClusterMetadata() *gomock.Call
GetClusterMetadata indicates an expected call of GetClusterMetadata.
func (*MockContextMockRecorder) GetConfig ¶
func (mr *MockContextMockRecorder) GetConfig() *gomock.Call
GetConfig indicates an expected call of GetConfig.
func (*MockContextMockRecorder) GetCurrentExecution ¶ added in v1.16.0
func (mr *MockContextMockRecorder) GetCurrentExecution(ctx, request interface{}) *gomock.Call
GetCurrentExecution indicates an expected call of GetCurrentExecution.
func (*MockContextMockRecorder) GetCurrentTime ¶
func (mr *MockContextMockRecorder) GetCurrentTime(cluster interface{}) *gomock.Call
GetCurrentTime indicates an expected call of GetCurrentTime.
func (*MockContextMockRecorder) GetEngine ¶
func (mr *MockContextMockRecorder) GetEngine(ctx interface{}) *gomock.Call
GetEngine indicates an expected call of GetEngine.
func (*MockContextMockRecorder) GetEventsCache ¶
func (mr *MockContextMockRecorder) GetEventsCache() *gomock.Call
GetEventsCache indicates an expected call of GetEventsCache.
func (*MockContextMockRecorder) GetExecutionManager ¶
func (mr *MockContextMockRecorder) GetExecutionManager() *gomock.Call
GetExecutionManager indicates an expected call of GetExecutionManager.
func (*MockContextMockRecorder) GetHistoryClient ¶ added in v1.14.0
func (mr *MockContextMockRecorder) GetHistoryClient() *gomock.Call
GetHistoryClient indicates an expected call of GetHistoryClient.
func (*MockContextMockRecorder) GetLogger ¶
func (mr *MockContextMockRecorder) GetLogger() *gomock.Call
GetLogger indicates an expected call of GetLogger.
func (*MockContextMockRecorder) GetMetricsHandler ¶ added in v1.17.3
func (mr *MockContextMockRecorder) GetMetricsHandler() *gomock.Call
GetMetricsHandler indicates an expected call of GetMetricsHandler.
func (*MockContextMockRecorder) GetNamespaceRegistry ¶ added in v1.13.0
func (mr *MockContextMockRecorder) GetNamespaceRegistry() *gomock.Call
GetNamespaceRegistry indicates an expected call of GetNamespaceRegistry.
func (*MockContextMockRecorder) GetOwner ¶ added in v1.21.0
func (mr *MockContextMockRecorder) GetOwner() *gomock.Call
GetOwner indicates an expected call of GetOwner.
func (*MockContextMockRecorder) GetPayloadSerializer ¶ added in v1.14.0
func (mr *MockContextMockRecorder) GetPayloadSerializer() *gomock.Call
GetPayloadSerializer indicates an expected call of GetPayloadSerializer.
func (*MockContextMockRecorder) GetQueueExclusiveHighReadWatermark ¶ added in v1.17.3
func (mr *MockContextMockRecorder) GetQueueExclusiveHighReadWatermark(category interface{}) *gomock.Call
GetQueueExclusiveHighReadWatermark indicates an expected call of GetQueueExclusiveHighReadWatermark.
func (*MockContextMockRecorder) GetQueueState ¶ added in v1.17.3
func (mr *MockContextMockRecorder) GetQueueState(category interface{}) *gomock.Call
GetQueueState indicates an expected call of GetQueueState.
func (*MockContextMockRecorder) GetRangeID ¶ added in v1.21.0
func (mr *MockContextMockRecorder) GetRangeID() *gomock.Call
GetRangeID indicates an expected call of GetRangeID.
func (*MockContextMockRecorder) GetRemoteAdminClient ¶ added in v1.14.0
func (mr *MockContextMockRecorder) GetRemoteAdminClient(arg0 interface{}) *gomock.Call
GetRemoteAdminClient indicates an expected call of GetRemoteAdminClient.
func (*MockContextMockRecorder) GetReplicationStatus ¶ added in v1.14.0
func (mr *MockContextMockRecorder) GetReplicationStatus(cluster interface{}) *gomock.Call
GetReplicationStatus indicates an expected call of GetReplicationStatus.
func (*MockContextMockRecorder) GetReplicatorDLQAckLevel ¶
func (mr *MockContextMockRecorder) GetReplicatorDLQAckLevel(sourceCluster interface{}) *gomock.Call
GetReplicatorDLQAckLevel indicates an expected call of GetReplicatorDLQAckLevel.
func (*MockContextMockRecorder) GetSearchAttributesMapperProvider ¶ added in v1.20.0
func (mr *MockContextMockRecorder) GetSearchAttributesMapperProvider() *gomock.Call
GetSearchAttributesMapperProvider indicates an expected call of GetSearchAttributesMapperProvider.
func (*MockContextMockRecorder) GetSearchAttributesProvider ¶ added in v1.14.0
func (mr *MockContextMockRecorder) GetSearchAttributesProvider() *gomock.Call
GetSearchAttributesProvider indicates an expected call of GetSearchAttributesProvider.
func (*MockContextMockRecorder) GetShardID ¶
func (mr *MockContextMockRecorder) GetShardID() *gomock.Call
GetShardID indicates an expected call of GetShardID.
func (*MockContextMockRecorder) GetThrottledLogger ¶
func (mr *MockContextMockRecorder) GetThrottledLogger() *gomock.Call
GetThrottledLogger indicates an expected call of GetThrottledLogger.
func (*MockContextMockRecorder) GetTimeSource ¶
func (mr *MockContextMockRecorder) GetTimeSource() *gomock.Call
GetTimeSource indicates an expected call of GetTimeSource.
func (*MockContextMockRecorder) GetWorkflowExecution ¶ added in v1.16.0
func (mr *MockContextMockRecorder) GetWorkflowExecution(ctx, request interface{}) *gomock.Call
GetWorkflowExecution indicates an expected call of GetWorkflowExecution.
func (*MockContextMockRecorder) NewVectorClock ¶ added in v1.17.0
func (mr *MockContextMockRecorder) NewVectorClock() *gomock.Call
NewVectorClock indicates an expected call of NewVectorClock.
func (*MockContextMockRecorder) SetCurrentTime ¶
func (mr *MockContextMockRecorder) SetCurrentTime(cluster, currentTime interface{}) *gomock.Call
SetCurrentTime indicates an expected call of SetCurrentTime.
func (*MockContextMockRecorder) SetQueueState ¶ added in v1.21.0
func (mr *MockContextMockRecorder) SetQueueState(category, state interface{}) *gomock.Call
SetQueueState indicates an expected call of SetQueueState.
func (*MockContextMockRecorder) SetWorkflowExecution ¶ added in v1.16.0
func (mr *MockContextMockRecorder) SetWorkflowExecution(ctx, request interface{}) *gomock.Call
SetWorkflowExecution indicates an expected call of SetWorkflowExecution.
func (*MockContextMockRecorder) UnloadForOwnershipLost ¶ added in v1.21.5
func (mr *MockContextMockRecorder) UnloadForOwnershipLost() *gomock.Call
UnloadForOwnershipLost indicates an expected call of UnloadForOwnershipLost.
func (*MockContextMockRecorder) UpdateHandoverNamespace ¶ added in v1.20.0
func (mr *MockContextMockRecorder) UpdateHandoverNamespace(ns, deletedFromDb interface{}) *gomock.Call
UpdateHandoverNamespace indicates an expected call of UpdateHandoverNamespace.
func (*MockContextMockRecorder) UpdateRemoteClusterInfo ¶ added in v1.16.0
func (mr *MockContextMockRecorder) UpdateRemoteClusterInfo(cluster, ackTaskID, ackTimestamp interface{}) *gomock.Call
UpdateRemoteClusterInfo indicates an expected call of UpdateRemoteClusterInfo.
func (*MockContextMockRecorder) UpdateRemoteReaderInfo ¶ added in v1.21.0
func (mr *MockContextMockRecorder) UpdateRemoteReaderInfo(readerID, ackTaskID, ackTimestamp interface{}) *gomock.Call
UpdateRemoteReaderInfo indicates an expected call of UpdateRemoteReaderInfo.
func (*MockContextMockRecorder) UpdateReplicationQueueReaderState ¶ added in v1.21.0
func (mr *MockContextMockRecorder) UpdateReplicationQueueReaderState(readerID, readerState interface{}) *gomock.Call
UpdateReplicationQueueReaderState indicates an expected call of UpdateReplicationQueueReaderState.
func (*MockContextMockRecorder) UpdateReplicatorDLQAckLevel ¶
func (mr *MockContextMockRecorder) UpdateReplicatorDLQAckLevel(sourCluster, ackLevel interface{}) *gomock.Call
UpdateReplicatorDLQAckLevel indicates an expected call of UpdateReplicatorDLQAckLevel.
func (*MockContextMockRecorder) UpdateWorkflowExecution ¶
func (mr *MockContextMockRecorder) UpdateWorkflowExecution(ctx, request interface{}) *gomock.Call
UpdateWorkflowExecution indicates an expected call of UpdateWorkflowExecution.
type MockControllableContext ¶ added in v1.21.5
type MockControllableContext struct {
// contains filtered or unexported fields
}
MockControllableContext is a mock of ControllableContext interface.
func NewMockControllableContext ¶ added in v1.21.5
func NewMockControllableContext(ctrl *gomock.Controller) *MockControllableContext
NewMockControllableContext creates a new mock instance.
func (*MockControllableContext) AddSpeculativeWorkflowTaskTimeoutTask ¶ added in v1.21.5
func (m *MockControllableContext) AddSpeculativeWorkflowTaskTimeoutTask(task *tasks.WorkflowTaskTimeoutTask) error
AddSpeculativeWorkflowTaskTimeoutTask mocks base method.
func (*MockControllableContext) AddTasks ¶ added in v1.21.5
func (m *MockControllableContext) AddTasks(ctx context.Context, request *persistence.AddHistoryTasksRequest) error
AddTasks mocks base method.
func (*MockControllableContext) AppendHistoryEvents ¶ added in v1.21.5
func (m *MockControllableContext) AppendHistoryEvents(ctx context.Context, request *persistence.AppendHistoryNodesRequest, namespaceID namespace.ID, execution *v1.WorkflowExecution) (int, error)
AppendHistoryEvents mocks base method.
func (*MockControllableContext) AssertOwnership ¶ added in v1.21.5
func (m *MockControllableContext) AssertOwnership(ctx context.Context) error
AssertOwnership mocks base method.
func (*MockControllableContext) ConflictResolveWorkflowExecution ¶ added in v1.21.5
func (m *MockControllableContext) ConflictResolveWorkflowExecution(ctx context.Context, request *persistence.ConflictResolveWorkflowExecutionRequest) (*persistence.ConflictResolveWorkflowExecutionResponse, error)
ConflictResolveWorkflowExecution mocks base method.
func (*MockControllableContext) CreateWorkflowExecution ¶ added in v1.21.5
func (m *MockControllableContext) CreateWorkflowExecution(ctx context.Context, request *persistence.CreateWorkflowExecutionRequest) (*persistence.CreateWorkflowExecutionResponse, error)
CreateWorkflowExecution mocks base method.
func (*MockControllableContext) CurrentVectorClock ¶ added in v1.21.5
func (m *MockControllableContext) CurrentVectorClock() *v11.VectorClock
CurrentVectorClock mocks base method.
func (*MockControllableContext) DeleteWorkflowExecution ¶ added in v1.21.5
func (m *MockControllableContext) DeleteWorkflowExecution(ctx context.Context, workflowKey definition.WorkflowKey, branchToken []byte, startTime, closeTime time.Time, closeExecutionVisibilityTaskID int64, stage *tasks.DeleteWorkflowExecutionStage) error
DeleteWorkflowExecution mocks base method.
func (*MockControllableContext) EXPECT ¶ added in v1.21.5
func (m *MockControllableContext) EXPECT() *MockControllableContextMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockControllableContext) FinishStop ¶ added in v1.21.5
func (m *MockControllableContext) FinishStop()
FinishStop mocks base method.
func (*MockControllableContext) GenerateTaskID ¶ added in v1.21.5
func (m *MockControllableContext) GenerateTaskID() (int64, error)
GenerateTaskID mocks base method.
func (*MockControllableContext) GenerateTaskIDs ¶ added in v1.21.5
func (m *MockControllableContext) GenerateTaskIDs(number int) ([]int64, error)
GenerateTaskIDs mocks base method.
func (*MockControllableContext) GetArchivalMetadata ¶ added in v1.21.5
func (m *MockControllableContext) GetArchivalMetadata() archiver.ArchivalMetadata
GetArchivalMetadata mocks base method.
func (*MockControllableContext) GetClusterMetadata ¶ added in v1.21.5
func (m *MockControllableContext) GetClusterMetadata() cluster.Metadata
GetClusterMetadata mocks base method.
func (*MockControllableContext) GetConfig ¶ added in v1.21.5
func (m *MockControllableContext) GetConfig() *configs.Config
GetConfig mocks base method.
func (*MockControllableContext) GetCurrentExecution ¶ added in v1.21.5
func (m *MockControllableContext) GetCurrentExecution(ctx context.Context, request *persistence.GetCurrentExecutionRequest) (*persistence.GetCurrentExecutionResponse, error)
GetCurrentExecution mocks base method.
func (*MockControllableContext) GetCurrentTime ¶ added in v1.21.5
func (m *MockControllableContext) GetCurrentTime(cluster string) time.Time
GetCurrentTime mocks base method.
func (*MockControllableContext) GetEngine ¶ added in v1.21.5
func (m *MockControllableContext) GetEngine(ctx context.Context) (Engine, error)
GetEngine mocks base method.
func (*MockControllableContext) GetEventsCache ¶ added in v1.21.5
func (m *MockControllableContext) GetEventsCache() events.Cache
GetEventsCache mocks base method.
func (*MockControllableContext) GetExecutionManager ¶ added in v1.21.5
func (m *MockControllableContext) GetExecutionManager() persistence.ExecutionManager
GetExecutionManager mocks base method.
func (*MockControllableContext) GetHistoryClient ¶ added in v1.21.5
func (m *MockControllableContext) GetHistoryClient() v12.HistoryServiceClient
GetHistoryClient mocks base method.
func (*MockControllableContext) GetLogger ¶ added in v1.21.5
func (m *MockControllableContext) GetLogger() log.Logger
GetLogger mocks base method.
func (*MockControllableContext) GetMetricsHandler ¶ added in v1.21.5
func (m *MockControllableContext) GetMetricsHandler() metrics.Handler
GetMetricsHandler mocks base method.
func (*MockControllableContext) GetNamespaceRegistry ¶ added in v1.21.5
func (m *MockControllableContext) GetNamespaceRegistry() namespace.Registry
GetNamespaceRegistry mocks base method.
func (*MockControllableContext) GetOwner ¶ added in v1.21.5
func (m *MockControllableContext) GetOwner() string
GetOwner mocks base method.
func (*MockControllableContext) GetPayloadSerializer ¶ added in v1.21.5
func (m *MockControllableContext) GetPayloadSerializer() serialization.Serializer
GetPayloadSerializer mocks base method.
func (*MockControllableContext) GetPingChecks ¶ added in v1.21.5
func (m *MockControllableContext) GetPingChecks() []common.PingCheck
GetPingChecks mocks base method.
func (*MockControllableContext) GetQueueExclusiveHighReadWatermark ¶ added in v1.23.0
func (m *MockControllableContext) GetQueueExclusiveHighReadWatermark(category tasks.Category) tasks.Key
GetQueueExclusiveHighReadWatermark mocks base method.
func (*MockControllableContext) GetQueueState ¶ added in v1.21.5
func (m *MockControllableContext) GetQueueState(category tasks.Category) (*v13.QueueState, bool)
GetQueueState mocks base method.
func (*MockControllableContext) GetRangeID ¶ added in v1.21.5
func (m *MockControllableContext) GetRangeID() int64
GetRangeID mocks base method.
func (*MockControllableContext) GetRemoteAdminClient ¶ added in v1.21.5
func (m *MockControllableContext) GetRemoteAdminClient(arg0 string) (v10.AdminServiceClient, error)
GetRemoteAdminClient mocks base method.
func (*MockControllableContext) GetReplicationStatus ¶ added in v1.21.5
func (m *MockControllableContext) GetReplicationStatus(cluster []string) (map[string]*v12.ShardReplicationStatusPerCluster, map[string]*v12.HandoverNamespaceInfo, error)
GetReplicationStatus mocks base method.
func (*MockControllableContext) GetReplicatorDLQAckLevel ¶ added in v1.21.5
func (m *MockControllableContext) GetReplicatorDLQAckLevel(sourceCluster string) int64
GetReplicatorDLQAckLevel mocks base method.
func (*MockControllableContext) GetSearchAttributesMapperProvider ¶ added in v1.21.5
func (m *MockControllableContext) GetSearchAttributesMapperProvider() searchattribute.MapperProvider
GetSearchAttributesMapperProvider mocks base method.
func (*MockControllableContext) GetSearchAttributesProvider ¶ added in v1.21.5
func (m *MockControllableContext) GetSearchAttributesProvider() searchattribute.Provider
GetSearchAttributesProvider mocks base method.
func (*MockControllableContext) GetShardID ¶ added in v1.21.5
func (m *MockControllableContext) GetShardID() int32
GetShardID mocks base method.
func (*MockControllableContext) GetThrottledLogger ¶ added in v1.21.5
func (m *MockControllableContext) GetThrottledLogger() log.Logger
GetThrottledLogger mocks base method.
func (*MockControllableContext) GetTimeSource ¶ added in v1.21.5
func (m *MockControllableContext) GetTimeSource() clock.TimeSource
GetTimeSource mocks base method.
func (*MockControllableContext) GetWorkflowExecution ¶ added in v1.21.5
func (m *MockControllableContext) GetWorkflowExecution(ctx context.Context, request *persistence.GetWorkflowExecutionRequest) (*persistence.GetWorkflowExecutionResponse, error)
GetWorkflowExecution mocks base method.
func (*MockControllableContext) IsValid ¶ added in v1.21.5
func (m *MockControllableContext) IsValid() bool
IsValid mocks base method.
func (*MockControllableContext) NewVectorClock ¶ added in v1.21.5
func (m *MockControllableContext) NewVectorClock() (*v11.VectorClock, error)
NewVectorClock mocks base method.
func (*MockControllableContext) SetCurrentTime ¶ added in v1.21.5
func (m *MockControllableContext) SetCurrentTime(cluster string, currentTime time.Time)
SetCurrentTime mocks base method.
func (*MockControllableContext) SetQueueState ¶ added in v1.21.5
func (m *MockControllableContext) SetQueueState(category tasks.Category, state *v13.QueueState) error
SetQueueState mocks base method.
func (*MockControllableContext) SetWorkflowExecution ¶ added in v1.21.5
func (m *MockControllableContext) SetWorkflowExecution(ctx context.Context, request *persistence.SetWorkflowExecutionRequest) (*persistence.SetWorkflowExecutionResponse, error)
SetWorkflowExecution mocks base method.
func (*MockControllableContext) UnloadForOwnershipLost ¶ added in v1.21.5
func (m *MockControllableContext) UnloadForOwnershipLost()
UnloadForOwnershipLost mocks base method.
func (*MockControllableContext) UpdateHandoverNamespace ¶ added in v1.21.5
func (m *MockControllableContext) UpdateHandoverNamespace(ns *namespace.Namespace, deletedFromDb bool)
UpdateHandoverNamespace mocks base method.
func (*MockControllableContext) UpdateRemoteClusterInfo ¶ added in v1.21.5
func (m *MockControllableContext) UpdateRemoteClusterInfo(cluster string, ackTaskID int64, ackTimestamp time.Time)
UpdateRemoteClusterInfo mocks base method.
func (*MockControllableContext) UpdateRemoteReaderInfo ¶ added in v1.21.5
func (m *MockControllableContext) UpdateRemoteReaderInfo(readerID, ackTaskID int64, ackTimestamp time.Time) error
UpdateRemoteReaderInfo mocks base method.
func (*MockControllableContext) UpdateReplicationQueueReaderState ¶ added in v1.21.5
func (m *MockControllableContext) UpdateReplicationQueueReaderState(readerID int64, readerState *v13.QueueReaderState) error
UpdateReplicationQueueReaderState mocks base method.
func (*MockControllableContext) UpdateReplicatorDLQAckLevel ¶ added in v1.21.5
func (m *MockControllableContext) UpdateReplicatorDLQAckLevel(sourCluster string, ackLevel int64) error
UpdateReplicatorDLQAckLevel mocks base method.
func (*MockControllableContext) UpdateWorkflowExecution ¶ added in v1.21.5
func (m *MockControllableContext) UpdateWorkflowExecution(ctx context.Context, request *persistence.UpdateWorkflowExecutionRequest) (*persistence.UpdateWorkflowExecutionResponse, error)
UpdateWorkflowExecution mocks base method.
type MockControllableContextMockRecorder ¶ added in v1.21.5
type MockControllableContextMockRecorder struct {
// contains filtered or unexported fields
}
MockControllableContextMockRecorder is the mock recorder for MockControllableContext.
func (*MockControllableContextMockRecorder) AddSpeculativeWorkflowTaskTimeoutTask ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) AddSpeculativeWorkflowTaskTimeoutTask(task interface{}) *gomock.Call
AddSpeculativeWorkflowTaskTimeoutTask indicates an expected call of AddSpeculativeWorkflowTaskTimeoutTask.
func (*MockControllableContextMockRecorder) AddTasks ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) AddTasks(ctx, request interface{}) *gomock.Call
AddTasks indicates an expected call of AddTasks.
func (*MockControllableContextMockRecorder) AppendHistoryEvents ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) AppendHistoryEvents(ctx, request, namespaceID, execution interface{}) *gomock.Call
AppendHistoryEvents indicates an expected call of AppendHistoryEvents.
func (*MockControllableContextMockRecorder) AssertOwnership ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) AssertOwnership(ctx interface{}) *gomock.Call
AssertOwnership indicates an expected call of AssertOwnership.
func (*MockControllableContextMockRecorder) ConflictResolveWorkflowExecution ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) ConflictResolveWorkflowExecution(ctx, request interface{}) *gomock.Call
ConflictResolveWorkflowExecution indicates an expected call of ConflictResolveWorkflowExecution.
func (*MockControllableContextMockRecorder) CreateWorkflowExecution ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) CreateWorkflowExecution(ctx, request interface{}) *gomock.Call
CreateWorkflowExecution indicates an expected call of CreateWorkflowExecution.
func (*MockControllableContextMockRecorder) CurrentVectorClock ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) CurrentVectorClock() *gomock.Call
CurrentVectorClock indicates an expected call of CurrentVectorClock.
func (*MockControllableContextMockRecorder) DeleteWorkflowExecution ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) DeleteWorkflowExecution(ctx, workflowKey, branchToken, startTime, closeTime, closeExecutionVisibilityTaskID, stage interface{}) *gomock.Call
DeleteWorkflowExecution indicates an expected call of DeleteWorkflowExecution.
func (*MockControllableContextMockRecorder) FinishStop ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) FinishStop() *gomock.Call
FinishStop indicates an expected call of FinishStop.
func (*MockControllableContextMockRecorder) GenerateTaskID ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) GenerateTaskID() *gomock.Call
GenerateTaskID indicates an expected call of GenerateTaskID.
func (*MockControllableContextMockRecorder) GenerateTaskIDs ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) GenerateTaskIDs(number interface{}) *gomock.Call
GenerateTaskIDs indicates an expected call of GenerateTaskIDs.
func (*MockControllableContextMockRecorder) GetArchivalMetadata ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) GetArchivalMetadata() *gomock.Call
GetArchivalMetadata indicates an expected call of GetArchivalMetadata.
func (*MockControllableContextMockRecorder) GetClusterMetadata ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) GetClusterMetadata() *gomock.Call
GetClusterMetadata indicates an expected call of GetClusterMetadata.
func (*MockControllableContextMockRecorder) GetConfig ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) GetConfig() *gomock.Call
GetConfig indicates an expected call of GetConfig.
func (*MockControllableContextMockRecorder) GetCurrentExecution ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) GetCurrentExecution(ctx, request interface{}) *gomock.Call
GetCurrentExecution indicates an expected call of GetCurrentExecution.
func (*MockControllableContextMockRecorder) GetCurrentTime ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) GetCurrentTime(cluster interface{}) *gomock.Call
GetCurrentTime indicates an expected call of GetCurrentTime.
func (*MockControllableContextMockRecorder) GetEngine ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) GetEngine(ctx interface{}) *gomock.Call
GetEngine indicates an expected call of GetEngine.
func (*MockControllableContextMockRecorder) GetEventsCache ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) GetEventsCache() *gomock.Call
GetEventsCache indicates an expected call of GetEventsCache.
func (*MockControllableContextMockRecorder) GetExecutionManager ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) GetExecutionManager() *gomock.Call
GetExecutionManager indicates an expected call of GetExecutionManager.
func (*MockControllableContextMockRecorder) GetHistoryClient ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) GetHistoryClient() *gomock.Call
GetHistoryClient indicates an expected call of GetHistoryClient.
func (*MockControllableContextMockRecorder) GetLogger ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) GetLogger() *gomock.Call
GetLogger indicates an expected call of GetLogger.
func (*MockControllableContextMockRecorder) GetMetricsHandler ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) GetMetricsHandler() *gomock.Call
GetMetricsHandler indicates an expected call of GetMetricsHandler.
func (*MockControllableContextMockRecorder) GetNamespaceRegistry ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) GetNamespaceRegistry() *gomock.Call
GetNamespaceRegistry indicates an expected call of GetNamespaceRegistry.
func (*MockControllableContextMockRecorder) GetOwner ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) GetOwner() *gomock.Call
GetOwner indicates an expected call of GetOwner.
func (*MockControllableContextMockRecorder) GetPayloadSerializer ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) GetPayloadSerializer() *gomock.Call
GetPayloadSerializer indicates an expected call of GetPayloadSerializer.
func (*MockControllableContextMockRecorder) GetPingChecks ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) GetPingChecks() *gomock.Call
GetPingChecks indicates an expected call of GetPingChecks.
func (*MockControllableContextMockRecorder) GetQueueExclusiveHighReadWatermark ¶ added in v1.23.0
func (mr *MockControllableContextMockRecorder) GetQueueExclusiveHighReadWatermark(category interface{}) *gomock.Call
GetQueueExclusiveHighReadWatermark indicates an expected call of GetQueueExclusiveHighReadWatermark.
func (*MockControllableContextMockRecorder) GetQueueState ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) GetQueueState(category interface{}) *gomock.Call
GetQueueState indicates an expected call of GetQueueState.
func (*MockControllableContextMockRecorder) GetRangeID ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) GetRangeID() *gomock.Call
GetRangeID indicates an expected call of GetRangeID.
func (*MockControllableContextMockRecorder) GetRemoteAdminClient ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) GetRemoteAdminClient(arg0 interface{}) *gomock.Call
GetRemoteAdminClient indicates an expected call of GetRemoteAdminClient.
func (*MockControllableContextMockRecorder) GetReplicationStatus ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) GetReplicationStatus(cluster interface{}) *gomock.Call
GetReplicationStatus indicates an expected call of GetReplicationStatus.
func (*MockControllableContextMockRecorder) GetReplicatorDLQAckLevel ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) GetReplicatorDLQAckLevel(sourceCluster interface{}) *gomock.Call
GetReplicatorDLQAckLevel indicates an expected call of GetReplicatorDLQAckLevel.
func (*MockControllableContextMockRecorder) GetSearchAttributesMapperProvider ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) GetSearchAttributesMapperProvider() *gomock.Call
GetSearchAttributesMapperProvider indicates an expected call of GetSearchAttributesMapperProvider.
func (*MockControllableContextMockRecorder) GetSearchAttributesProvider ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) GetSearchAttributesProvider() *gomock.Call
GetSearchAttributesProvider indicates an expected call of GetSearchAttributesProvider.
func (*MockControllableContextMockRecorder) GetShardID ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) GetShardID() *gomock.Call
GetShardID indicates an expected call of GetShardID.
func (*MockControllableContextMockRecorder) GetThrottledLogger ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) GetThrottledLogger() *gomock.Call
GetThrottledLogger indicates an expected call of GetThrottledLogger.
func (*MockControllableContextMockRecorder) GetTimeSource ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) GetTimeSource() *gomock.Call
GetTimeSource indicates an expected call of GetTimeSource.
func (*MockControllableContextMockRecorder) GetWorkflowExecution ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) GetWorkflowExecution(ctx, request interface{}) *gomock.Call
GetWorkflowExecution indicates an expected call of GetWorkflowExecution.
func (*MockControllableContextMockRecorder) IsValid ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) IsValid() *gomock.Call
IsValid indicates an expected call of IsValid.
func (*MockControllableContextMockRecorder) NewVectorClock ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) NewVectorClock() *gomock.Call
NewVectorClock indicates an expected call of NewVectorClock.
func (*MockControllableContextMockRecorder) SetCurrentTime ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) SetCurrentTime(cluster, currentTime interface{}) *gomock.Call
SetCurrentTime indicates an expected call of SetCurrentTime.
func (*MockControllableContextMockRecorder) SetQueueState ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) SetQueueState(category, state interface{}) *gomock.Call
SetQueueState indicates an expected call of SetQueueState.
func (*MockControllableContextMockRecorder) SetWorkflowExecution ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) SetWorkflowExecution(ctx, request interface{}) *gomock.Call
SetWorkflowExecution indicates an expected call of SetWorkflowExecution.
func (*MockControllableContextMockRecorder) UnloadForOwnershipLost ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) UnloadForOwnershipLost() *gomock.Call
UnloadForOwnershipLost indicates an expected call of UnloadForOwnershipLost.
func (*MockControllableContextMockRecorder) UpdateHandoverNamespace ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) UpdateHandoverNamespace(ns, deletedFromDb interface{}) *gomock.Call
UpdateHandoverNamespace indicates an expected call of UpdateHandoverNamespace.
func (*MockControllableContextMockRecorder) UpdateRemoteClusterInfo ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) UpdateRemoteClusterInfo(cluster, ackTaskID, ackTimestamp interface{}) *gomock.Call
UpdateRemoteClusterInfo indicates an expected call of UpdateRemoteClusterInfo.
func (*MockControllableContextMockRecorder) UpdateRemoteReaderInfo ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) UpdateRemoteReaderInfo(readerID, ackTaskID, ackTimestamp interface{}) *gomock.Call
UpdateRemoteReaderInfo indicates an expected call of UpdateRemoteReaderInfo.
func (*MockControllableContextMockRecorder) UpdateReplicationQueueReaderState ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) UpdateReplicationQueueReaderState(readerID, readerState interface{}) *gomock.Call
UpdateReplicationQueueReaderState indicates an expected call of UpdateReplicationQueueReaderState.
func (*MockControllableContextMockRecorder) UpdateReplicatorDLQAckLevel ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) UpdateReplicatorDLQAckLevel(sourCluster, ackLevel interface{}) *gomock.Call
UpdateReplicatorDLQAckLevel indicates an expected call of UpdateReplicatorDLQAckLevel.
func (*MockControllableContextMockRecorder) UpdateWorkflowExecution ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) UpdateWorkflowExecution(ctx, request interface{}) *gomock.Call
UpdateWorkflowExecution indicates an expected call of UpdateWorkflowExecution.
type MockController ¶ added in v1.17.3
type MockController struct {
// contains filtered or unexported fields
}
MockController is a mock of Controller interface.
func NewMockController ¶ added in v1.17.3
func NewMockController(ctrl *gomock.Controller) *MockController
NewMockController creates a new mock instance.
func (*MockController) CloseShardByID ¶ added in v1.17.3
func (m *MockController) CloseShardByID(shardID int32)
CloseShardByID mocks base method.
func (*MockController) EXPECT ¶ added in v1.17.3
func (m *MockController) EXPECT() *MockControllerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockController) GetPingChecks ¶ added in v1.19.0
func (m *MockController) GetPingChecks() []common.PingCheck
GetPingChecks mocks base method.
func (*MockController) GetShardByID ¶ added in v1.17.3
func (m *MockController) GetShardByID(shardID int32) (Context, error)
GetShardByID mocks base method.
func (*MockController) GetShardByNamespaceWorkflow ¶ added in v1.17.3
func (m *MockController) GetShardByNamespaceWorkflow(namespaceID namespace.ID, workflowID string) (Context, error)
GetShardByNamespaceWorkflow mocks base method.
func (*MockController) ShardIDs ¶ added in v1.17.3
func (m *MockController) ShardIDs() []int32
ShardIDs mocks base method.
func (*MockController) Start ¶ added in v1.17.3
func (m *MockController) Start()
Start mocks base method.
func (*MockController) Stop ¶ added in v1.17.3
func (m *MockController) Stop()
Stop mocks base method.
type MockControllerMockRecorder ¶ added in v1.17.3
type MockControllerMockRecorder struct {
// contains filtered or unexported fields
}
MockControllerMockRecorder is the mock recorder for MockController.
func (*MockControllerMockRecorder) CloseShardByID ¶ added in v1.17.3
func (mr *MockControllerMockRecorder) CloseShardByID(shardID interface{}) *gomock.Call
CloseShardByID indicates an expected call of CloseShardByID.
func (*MockControllerMockRecorder) GetPingChecks ¶ added in v1.19.0
func (mr *MockControllerMockRecorder) GetPingChecks() *gomock.Call
GetPingChecks indicates an expected call of GetPingChecks.
func (*MockControllerMockRecorder) GetShardByID ¶ added in v1.17.3
func (mr *MockControllerMockRecorder) GetShardByID(shardID interface{}) *gomock.Call
GetShardByID indicates an expected call of GetShardByID.
func (*MockControllerMockRecorder) GetShardByNamespaceWorkflow ¶ added in v1.17.3
func (mr *MockControllerMockRecorder) GetShardByNamespaceWorkflow(namespaceID, workflowID interface{}) *gomock.Call
GetShardByNamespaceWorkflow indicates an expected call of GetShardByNamespaceWorkflow.
func (*MockControllerMockRecorder) ShardIDs ¶ added in v1.17.3
func (mr *MockControllerMockRecorder) ShardIDs() *gomock.Call
ShardIDs indicates an expected call of ShardIDs.
func (*MockControllerMockRecorder) Start ¶ added in v1.17.3
func (mr *MockControllerMockRecorder) Start() *gomock.Call
Start indicates an expected call of Start.
func (*MockControllerMockRecorder) Stop ¶ added in v1.17.3
func (mr *MockControllerMockRecorder) Stop() *gomock.Call
Stop indicates an expected call of Stop.
type MockEngine ¶
type MockEngine struct {
// contains filtered or unexported fields
}
MockEngine is a mock of Engine interface.
func NewMockEngine ¶
func NewMockEngine(ctrl *gomock.Controller) *MockEngine
NewMockEngine creates a new mock instance.
func (*MockEngine) AddSpeculativeWorkflowTaskTimeoutTask ¶ added in v1.21.0
func (m *MockEngine) AddSpeculativeWorkflowTaskTimeoutTask(task *tasks.WorkflowTaskTimeoutTask)
AddSpeculativeWorkflowTaskTimeoutTask mocks base method.
func (*MockEngine) AddTasks ¶ added in v1.23.0
func (m *MockEngine) AddTasks(ctx context.Context, request *historyservice.AddTasksRequest) (*historyservice.AddTasksResponse, error)
AddTasks mocks base method.
func (*MockEngine) ConvertReplicationTask ¶ added in v1.21.0
func (m *MockEngine) ConvertReplicationTask(ctx context.Context, task tasks.Task) (*repication.ReplicationTask, error)
ConvertReplicationTask mocks base method.
func (*MockEngine) DeleteWorkflowExecution ¶ added in v1.15.0
func (m *MockEngine) DeleteWorkflowExecution(ctx context.Context, deleteRequest *historyservice.DeleteWorkflowExecutionRequest) (*historyservice.DeleteWorkflowExecutionResponse, error)
DeleteWorkflowExecution mocks base method.
func (*MockEngine) DescribeMutableState ¶
func (m *MockEngine) DescribeMutableState(ctx context.Context, request *historyservice.DescribeMutableStateRequest) (*historyservice.DescribeMutableStateResponse, error)
DescribeMutableState mocks base method.
func (*MockEngine) DescribeWorkflowExecution ¶
func (m *MockEngine) DescribeWorkflowExecution(ctx context.Context, request *historyservice.DescribeWorkflowExecutionRequest) (*historyservice.DescribeWorkflowExecutionResponse, error)
DescribeWorkflowExecution mocks base method.
func (*MockEngine) EXPECT ¶
func (m *MockEngine) EXPECT() *MockEngineMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockEngine) GenerateLastHistoryReplicationTasks ¶ added in v1.14.0
func (m *MockEngine) GenerateLastHistoryReplicationTasks(ctx context.Context, request *historyservice.GenerateLastHistoryReplicationTasksRequest) (*historyservice.GenerateLastHistoryReplicationTasksResponse, error)
GenerateLastHistoryReplicationTasks mocks base method.
func (*MockEngine) GetDLQMessages ¶
func (m *MockEngine) GetDLQMessages(ctx context.Context, messagesRequest *historyservice.GetDLQMessagesRequest) (*historyservice.GetDLQMessagesResponse, error)
GetDLQMessages mocks base method.
func (*MockEngine) GetDLQReplicationMessages ¶
func (m *MockEngine) GetDLQReplicationMessages(ctx context.Context, taskInfos []*repication.ReplicationTaskInfo) ([]*repication.ReplicationTask, error)
GetDLQReplicationMessages mocks base method.
func (*MockEngine) GetMutableState ¶
func (m *MockEngine) GetMutableState(ctx context.Context, request *historyservice.GetMutableStateRequest) (*historyservice.GetMutableStateResponse, error)
GetMutableState mocks base method.
func (*MockEngine) GetReplicationMessages ¶
func (m *MockEngine) GetReplicationMessages(ctx context.Context, pollingCluster string, ackMessageID int64, ackTimestamp time.Time, queryMessageID int64) (*repication.ReplicationMessages, error)
GetReplicationMessages mocks base method.
func (*MockEngine) GetReplicationStatus ¶ added in v1.14.0
func (m *MockEngine) GetReplicationStatus(ctx context.Context, request *historyservice.GetReplicationStatusRequest) (*historyservice.ShardReplicationStatus, error)
GetReplicationStatus mocks base method.
func (*MockEngine) GetReplicationTasksIter ¶ added in v1.21.0
func (m *MockEngine) GetReplicationTasksIter(ctx context.Context, pollingCluster string, minInclusiveTaskID, maxExclusiveTaskID int64) (collection.Iterator[tasks.Task], error)
GetReplicationTasksIter mocks base method.
func (*MockEngine) GetWorkflowExecutionHistory ¶ added in v1.23.0
func (m *MockEngine) GetWorkflowExecutionHistory(ctx context.Context, request *historyservice.GetWorkflowExecutionHistoryRequest) (*historyservice.GetWorkflowExecutionHistoryResponse, error)
GetWorkflowExecutionHistory mocks base method.
func (*MockEngine) GetWorkflowExecutionHistoryReverse ¶ added in v1.23.0
func (m *MockEngine) GetWorkflowExecutionHistoryReverse(ctx context.Context, request *historyservice.GetWorkflowExecutionHistoryReverseRequest) (*historyservice.GetWorkflowExecutionHistoryReverseResponse, error)
GetWorkflowExecutionHistoryReverse mocks base method.
func (*MockEngine) GetWorkflowExecutionRawHistoryV2 ¶ added in v1.23.0
func (m *MockEngine) GetWorkflowExecutionRawHistoryV2(ctx context.Context, request *historyservice.GetWorkflowExecutionRawHistoryV2Request) (*historyservice.GetWorkflowExecutionRawHistoryV2Response, error)
GetWorkflowExecutionRawHistoryV2 mocks base method.
func (*MockEngine) ImportWorkflowExecution ¶ added in v1.23.0
func (m *MockEngine) ImportWorkflowExecution(ctx context.Context, request *historyservice.ImportWorkflowExecutionRequest) (*historyservice.ImportWorkflowExecutionResponse, error)
ImportWorkflowExecution mocks base method.
func (*MockEngine) IsActivityTaskValid ¶ added in v1.22.0
func (m *MockEngine) IsActivityTaskValid(ctx context.Context, request *historyservice.IsActivityTaskValidRequest) (*historyservice.IsActivityTaskValidResponse, error)
IsActivityTaskValid mocks base method.
func (*MockEngine) IsWorkflowTaskValid ¶ added in v1.22.0
func (m *MockEngine) IsWorkflowTaskValid(ctx context.Context, request *historyservice.IsWorkflowTaskValidRequest) (*historyservice.IsWorkflowTaskValidResponse, error)
IsWorkflowTaskValid mocks base method.
func (*MockEngine) MergeDLQMessages ¶
func (m *MockEngine) MergeDLQMessages(ctx context.Context, messagesRequest *historyservice.MergeDLQMessagesRequest) (*historyservice.MergeDLQMessagesResponse, error)
MergeDLQMessages mocks base method.
func (*MockEngine) NotifyNewHistoryEvent ¶
func (m *MockEngine) NotifyNewHistoryEvent(event *events.Notification)
NotifyNewHistoryEvent mocks base method.
func (*MockEngine) NotifyNewTasks ¶ added in v1.16.0
func (m *MockEngine) NotifyNewTasks(tasks map[tasks.Category][]tasks.Task)
NotifyNewTasks mocks base method.
func (*MockEngine) PollMutableState ¶
func (m *MockEngine) PollMutableState(ctx context.Context, request *historyservice.PollMutableStateRequest) (*historyservice.PollMutableStateResponse, error)
PollMutableState mocks base method.
func (*MockEngine) PollWorkflowExecutionUpdate ¶ added in v1.21.0
func (m *MockEngine) PollWorkflowExecutionUpdate(ctx context.Context, request *historyservice.PollWorkflowExecutionUpdateRequest) (*historyservice.PollWorkflowExecutionUpdateResponse, error)
PollWorkflowExecutionUpdate mocks base method.
func (*MockEngine) PurgeDLQMessages ¶
func (m *MockEngine) PurgeDLQMessages(ctx context.Context, messagesRequest *historyservice.PurgeDLQMessagesRequest) (*historyservice.PurgeDLQMessagesResponse, error)
PurgeDLQMessages mocks base method.
func (*MockEngine) QueryWorkflow ¶
func (m *MockEngine) QueryWorkflow(ctx context.Context, request *historyservice.QueryWorkflowRequest) (*historyservice.QueryWorkflowResponse, error)
QueryWorkflow mocks base method.
func (*MockEngine) ReapplyEvents ¶
func (m *MockEngine) ReapplyEvents(ctx context.Context, namespaceUUID namespace.ID, workflowID, runID string, events []*history.HistoryEvent) error
ReapplyEvents mocks base method.
func (*MockEngine) RebuildMutableState ¶ added in v1.16.0
func (m *MockEngine) RebuildMutableState(ctx context.Context, namespaceUUID namespace.ID, execution *common.WorkflowExecution) error
RebuildMutableState mocks base method.
func (*MockEngine) RecordActivityTaskHeartbeat ¶
func (m *MockEngine) RecordActivityTaskHeartbeat(ctx context.Context, request *historyservice.RecordActivityTaskHeartbeatRequest) (*historyservice.RecordActivityTaskHeartbeatResponse, error)
RecordActivityTaskHeartbeat mocks base method.
func (*MockEngine) RecordActivityTaskStarted ¶
func (m *MockEngine) RecordActivityTaskStarted(ctx context.Context, request *historyservice.RecordActivityTaskStartedRequest) (*historyservice.RecordActivityTaskStartedResponse, error)
RecordActivityTaskStarted mocks base method.
func (*MockEngine) RecordChildExecutionCompleted ¶
func (m *MockEngine) RecordChildExecutionCompleted(ctx context.Context, request *historyservice.RecordChildExecutionCompletedRequest) (*historyservice.RecordChildExecutionCompletedResponse, error)
RecordChildExecutionCompleted mocks base method.
func (*MockEngine) RecordWorkflowTaskStarted ¶
func (m *MockEngine) RecordWorkflowTaskStarted(ctx context.Context, request *historyservice.RecordWorkflowTaskStartedRequest) (*historyservice.RecordWorkflowTaskStartedResponse, error)
RecordWorkflowTaskStarted mocks base method.
func (*MockEngine) RefreshWorkflowTasks ¶
func (m *MockEngine) RefreshWorkflowTasks(ctx context.Context, namespaceUUID namespace.ID, execution *common.WorkflowExecution) error
RefreshWorkflowTasks mocks base method.
func (*MockEngine) RemoveSignalMutableState ¶
func (m *MockEngine) RemoveSignalMutableState(ctx context.Context, request *historyservice.RemoveSignalMutableStateRequest) (*historyservice.RemoveSignalMutableStateResponse, error)
RemoveSignalMutableState mocks base method.
func (*MockEngine) ReplicateEventsV2 ¶
func (m *MockEngine) ReplicateEventsV2(ctx context.Context, request *historyservice.ReplicateEventsV2Request) error
ReplicateEventsV2 mocks base method.
func (*MockEngine) ReplicateHistoryEvents ¶ added in v1.23.0
func (m *MockEngine) ReplicateHistoryEvents(ctx context.Context, workflowKey definition.WorkflowKey, baseExecutionInfo *workflow.BaseExecutionInfo, versionHistoryItems []*history0.VersionHistoryItem, historyEvents [][]*history.HistoryEvent, newEvents []*history.HistoryEvent) error
ReplicateHistoryEvents mocks base method.
func (*MockEngine) ReplicateWorkflowState ¶ added in v1.17.0
func (m *MockEngine) ReplicateWorkflowState(ctx context.Context, request *historyservice.ReplicateWorkflowStateRequest) error
ReplicateWorkflowState mocks base method.
func (*MockEngine) RequestCancelWorkflowExecution ¶
func (m *MockEngine) RequestCancelWorkflowExecution(ctx context.Context, request *historyservice.RequestCancelWorkflowExecutionRequest) (*historyservice.RequestCancelWorkflowExecutionResponse, error)
RequestCancelWorkflowExecution mocks base method.
func (*MockEngine) ResetStickyTaskQueue ¶
func (m *MockEngine) ResetStickyTaskQueue(ctx context.Context, resetRequest *historyservice.ResetStickyTaskQueueRequest) (*historyservice.ResetStickyTaskQueueResponse, error)
ResetStickyTaskQueue mocks base method.
func (*MockEngine) ResetWorkflowExecution ¶
func (m *MockEngine) ResetWorkflowExecution(ctx context.Context, request *historyservice.ResetWorkflowExecutionRequest) (*historyservice.ResetWorkflowExecutionResponse, error)
ResetWorkflowExecution mocks base method.
func (*MockEngine) RespondActivityTaskCanceled ¶
func (m *MockEngine) RespondActivityTaskCanceled(ctx context.Context, request *historyservice.RespondActivityTaskCanceledRequest) (*historyservice.RespondActivityTaskCanceledResponse, error)
RespondActivityTaskCanceled mocks base method.
func (*MockEngine) RespondActivityTaskCompleted ¶
func (m *MockEngine) RespondActivityTaskCompleted(ctx context.Context, request *historyservice.RespondActivityTaskCompletedRequest) (*historyservice.RespondActivityTaskCompletedResponse, error)
RespondActivityTaskCompleted mocks base method.
func (*MockEngine) RespondActivityTaskFailed ¶
func (m *MockEngine) RespondActivityTaskFailed(ctx context.Context, request *historyservice.RespondActivityTaskFailedRequest) (*historyservice.RespondActivityTaskFailedResponse, error)
RespondActivityTaskFailed mocks base method.
func (*MockEngine) RespondWorkflowTaskCompleted ¶
func (m *MockEngine) RespondWorkflowTaskCompleted(ctx context.Context, request *historyservice.RespondWorkflowTaskCompletedRequest) (*historyservice.RespondWorkflowTaskCompletedResponse, error)
RespondWorkflowTaskCompleted mocks base method.
func (*MockEngine) RespondWorkflowTaskFailed ¶
func (m *MockEngine) RespondWorkflowTaskFailed(ctx context.Context, request *historyservice.RespondWorkflowTaskFailedRequest) error
RespondWorkflowTaskFailed mocks base method.
func (*MockEngine) ScheduleWorkflowTask ¶
func (m *MockEngine) ScheduleWorkflowTask(ctx context.Context, request *historyservice.ScheduleWorkflowTaskRequest) error
ScheduleWorkflowTask mocks base method.
func (*MockEngine) SignalWithStartWorkflowExecution ¶
func (m *MockEngine) SignalWithStartWorkflowExecution(ctx context.Context, request *historyservice.SignalWithStartWorkflowExecutionRequest) (*historyservice.SignalWithStartWorkflowExecutionResponse, error)
SignalWithStartWorkflowExecution mocks base method.
func (*MockEngine) SignalWorkflowExecution ¶
func (m *MockEngine) SignalWorkflowExecution(ctx context.Context, request *historyservice.SignalWorkflowExecutionRequest) (*historyservice.SignalWorkflowExecutionResponse, error)
SignalWorkflowExecution mocks base method.
func (*MockEngine) StartWorkflowExecution ¶
func (m *MockEngine) StartWorkflowExecution(ctx context.Context, request *historyservice.StartWorkflowExecutionRequest) (*historyservice.StartWorkflowExecutionResponse, error)
StartWorkflowExecution mocks base method.
func (*MockEngine) SubscribeReplicationNotification ¶ added in v1.21.0
func (m *MockEngine) SubscribeReplicationNotification() (<-chan struct{}, string)
SubscribeReplicationNotification mocks base method.
func (*MockEngine) SyncActivity ¶
func (m *MockEngine) SyncActivity(ctx context.Context, request *historyservice.SyncActivityRequest) error
SyncActivity mocks base method.
func (*MockEngine) SyncShardStatus ¶
func (m *MockEngine) SyncShardStatus(ctx context.Context, request *historyservice.SyncShardStatusRequest) error
SyncShardStatus mocks base method.
func (*MockEngine) TerminateWorkflowExecution ¶
func (m *MockEngine) TerminateWorkflowExecution(ctx context.Context, request *historyservice.TerminateWorkflowExecutionRequest) (*historyservice.TerminateWorkflowExecutionResponse, error)
TerminateWorkflowExecution mocks base method.
func (*MockEngine) UnsubscribeReplicationNotification ¶ added in v1.21.0
func (m *MockEngine) UnsubscribeReplicationNotification(arg0 string)
UnsubscribeReplicationNotification mocks base method.
func (*MockEngine) UpdateWorkflowExecution ¶ added in v1.20.0
func (m *MockEngine) UpdateWorkflowExecution(ctx context.Context, request *historyservice.UpdateWorkflowExecutionRequest) (*historyservice.UpdateWorkflowExecutionResponse, error)
UpdateWorkflowExecution mocks base method.
func (*MockEngine) VerifyChildExecutionCompletionRecorded ¶ added in v1.17.0
func (m *MockEngine) VerifyChildExecutionCompletionRecorded(ctx context.Context, request *historyservice.VerifyChildExecutionCompletionRecordedRequest) (*historyservice.VerifyChildExecutionCompletionRecordedResponse, error)
VerifyChildExecutionCompletionRecorded mocks base method.
func (*MockEngine) VerifyFirstWorkflowTaskScheduled ¶ added in v1.17.0
func (m *MockEngine) VerifyFirstWorkflowTaskScheduled(ctx context.Context, request *historyservice.VerifyFirstWorkflowTaskScheduledRequest) error
VerifyFirstWorkflowTaskScheduled mocks base method.
type MockEngineFactory ¶
type MockEngineFactory struct {
// contains filtered or unexported fields
}
MockEngineFactory is a mock of EngineFactory interface.
func NewMockEngineFactory ¶
func NewMockEngineFactory(ctrl *gomock.Controller) *MockEngineFactory
NewMockEngineFactory creates a new mock instance.
func (*MockEngineFactory) CreateEngine ¶
func (m *MockEngineFactory) CreateEngine(context Context) Engine
CreateEngine mocks base method.
func (*MockEngineFactory) EXPECT ¶
func (m *MockEngineFactory) EXPECT() *MockEngineFactoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockEngineFactoryMockRecorder ¶
type MockEngineFactoryMockRecorder struct {
// contains filtered or unexported fields
}
MockEngineFactoryMockRecorder is the mock recorder for MockEngineFactory.
func (*MockEngineFactoryMockRecorder) CreateEngine ¶
func (mr *MockEngineFactoryMockRecorder) CreateEngine(context interface{}) *gomock.Call
CreateEngine indicates an expected call of CreateEngine.
type MockEngineMockRecorder ¶
type MockEngineMockRecorder struct {
// contains filtered or unexported fields
}
MockEngineMockRecorder is the mock recorder for MockEngine.
func (*MockEngineMockRecorder) AddSpeculativeWorkflowTaskTimeoutTask ¶ added in v1.21.0
func (mr *MockEngineMockRecorder) AddSpeculativeWorkflowTaskTimeoutTask(task interface{}) *gomock.Call
AddSpeculativeWorkflowTaskTimeoutTask indicates an expected call of AddSpeculativeWorkflowTaskTimeoutTask.
func (*MockEngineMockRecorder) AddTasks ¶ added in v1.23.0
func (mr *MockEngineMockRecorder) AddTasks(ctx, request interface{}) *gomock.Call
AddTasks indicates an expected call of AddTasks.
func (*MockEngineMockRecorder) ConvertReplicationTask ¶ added in v1.21.0
func (mr *MockEngineMockRecorder) ConvertReplicationTask(ctx, task interface{}) *gomock.Call
ConvertReplicationTask indicates an expected call of ConvertReplicationTask.
func (*MockEngineMockRecorder) DeleteWorkflowExecution ¶ added in v1.15.0
func (mr *MockEngineMockRecorder) DeleteWorkflowExecution(ctx, deleteRequest interface{}) *gomock.Call
DeleteWorkflowExecution indicates an expected call of DeleteWorkflowExecution.
func (*MockEngineMockRecorder) DescribeMutableState ¶
func (mr *MockEngineMockRecorder) DescribeMutableState(ctx, request interface{}) *gomock.Call
DescribeMutableState indicates an expected call of DescribeMutableState.
func (*MockEngineMockRecorder) DescribeWorkflowExecution ¶
func (mr *MockEngineMockRecorder) DescribeWorkflowExecution(ctx, request interface{}) *gomock.Call
DescribeWorkflowExecution indicates an expected call of DescribeWorkflowExecution.
func (*MockEngineMockRecorder) GenerateLastHistoryReplicationTasks ¶ added in v1.14.0
func (mr *MockEngineMockRecorder) GenerateLastHistoryReplicationTasks(ctx, request interface{}) *gomock.Call
GenerateLastHistoryReplicationTasks indicates an expected call of GenerateLastHistoryReplicationTasks.
func (*MockEngineMockRecorder) GetDLQMessages ¶
func (mr *MockEngineMockRecorder) GetDLQMessages(ctx, messagesRequest interface{}) *gomock.Call
GetDLQMessages indicates an expected call of GetDLQMessages.
func (*MockEngineMockRecorder) GetDLQReplicationMessages ¶
func (mr *MockEngineMockRecorder) GetDLQReplicationMessages(ctx, taskInfos interface{}) *gomock.Call
GetDLQReplicationMessages indicates an expected call of GetDLQReplicationMessages.
func (*MockEngineMockRecorder) GetMutableState ¶
func (mr *MockEngineMockRecorder) GetMutableState(ctx, request interface{}) *gomock.Call
GetMutableState indicates an expected call of GetMutableState.
func (*MockEngineMockRecorder) GetReplicationMessages ¶
func (mr *MockEngineMockRecorder) GetReplicationMessages(ctx, pollingCluster, ackMessageID, ackTimestamp, queryMessageID interface{}) *gomock.Call
GetReplicationMessages indicates an expected call of GetReplicationMessages.
func (*MockEngineMockRecorder) GetReplicationStatus ¶ added in v1.14.0
func (mr *MockEngineMockRecorder) GetReplicationStatus(ctx, request interface{}) *gomock.Call
GetReplicationStatus indicates an expected call of GetReplicationStatus.
func (*MockEngineMockRecorder) GetReplicationTasksIter ¶ added in v1.21.0
func (mr *MockEngineMockRecorder) GetReplicationTasksIter(ctx, pollingCluster, minInclusiveTaskID, maxExclusiveTaskID interface{}) *gomock.Call
GetReplicationTasksIter indicates an expected call of GetReplicationTasksIter.
func (*MockEngineMockRecorder) GetWorkflowExecutionHistory ¶ added in v1.23.0
func (mr *MockEngineMockRecorder) GetWorkflowExecutionHistory(ctx, request interface{}) *gomock.Call
GetWorkflowExecutionHistory indicates an expected call of GetWorkflowExecutionHistory.
func (*MockEngineMockRecorder) GetWorkflowExecutionHistoryReverse ¶ added in v1.23.0
func (mr *MockEngineMockRecorder) GetWorkflowExecutionHistoryReverse(ctx, request interface{}) *gomock.Call
GetWorkflowExecutionHistoryReverse indicates an expected call of GetWorkflowExecutionHistoryReverse.
func (*MockEngineMockRecorder) GetWorkflowExecutionRawHistoryV2 ¶ added in v1.23.0
func (mr *MockEngineMockRecorder) GetWorkflowExecutionRawHistoryV2(ctx, request interface{}) *gomock.Call
GetWorkflowExecutionRawHistoryV2 indicates an expected call of GetWorkflowExecutionRawHistoryV2.
func (*MockEngineMockRecorder) ImportWorkflowExecution ¶ added in v1.23.0
func (mr *MockEngineMockRecorder) ImportWorkflowExecution(ctx, request interface{}) *gomock.Call
ImportWorkflowExecution indicates an expected call of ImportWorkflowExecution.
func (*MockEngineMockRecorder) IsActivityTaskValid ¶ added in v1.22.0
func (mr *MockEngineMockRecorder) IsActivityTaskValid(ctx, request interface{}) *gomock.Call
IsActivityTaskValid indicates an expected call of IsActivityTaskValid.
func (*MockEngineMockRecorder) IsWorkflowTaskValid ¶ added in v1.22.0
func (mr *MockEngineMockRecorder) IsWorkflowTaskValid(ctx, request interface{}) *gomock.Call
IsWorkflowTaskValid indicates an expected call of IsWorkflowTaskValid.
func (*MockEngineMockRecorder) MergeDLQMessages ¶
func (mr *MockEngineMockRecorder) MergeDLQMessages(ctx, messagesRequest interface{}) *gomock.Call
MergeDLQMessages indicates an expected call of MergeDLQMessages.
func (*MockEngineMockRecorder) NotifyNewHistoryEvent ¶
func (mr *MockEngineMockRecorder) NotifyNewHistoryEvent(event interface{}) *gomock.Call
NotifyNewHistoryEvent indicates an expected call of NotifyNewHistoryEvent.
func (*MockEngineMockRecorder) NotifyNewTasks ¶ added in v1.16.0
func (mr *MockEngineMockRecorder) NotifyNewTasks(tasks interface{}) *gomock.Call
NotifyNewTasks indicates an expected call of NotifyNewTasks.
func (*MockEngineMockRecorder) PollMutableState ¶
func (mr *MockEngineMockRecorder) PollMutableState(ctx, request interface{}) *gomock.Call
PollMutableState indicates an expected call of PollMutableState.
func (*MockEngineMockRecorder) PollWorkflowExecutionUpdate ¶ added in v1.21.0
func (mr *MockEngineMockRecorder) PollWorkflowExecutionUpdate(ctx, request interface{}) *gomock.Call
PollWorkflowExecutionUpdate indicates an expected call of PollWorkflowExecutionUpdate.
func (*MockEngineMockRecorder) PurgeDLQMessages ¶
func (mr *MockEngineMockRecorder) PurgeDLQMessages(ctx, messagesRequest interface{}) *gomock.Call
PurgeDLQMessages indicates an expected call of PurgeDLQMessages.
func (*MockEngineMockRecorder) QueryWorkflow ¶
func (mr *MockEngineMockRecorder) QueryWorkflow(ctx, request interface{}) *gomock.Call
QueryWorkflow indicates an expected call of QueryWorkflow.
func (*MockEngineMockRecorder) ReapplyEvents ¶
func (mr *MockEngineMockRecorder) ReapplyEvents(ctx, namespaceUUID, workflowID, runID, events interface{}) *gomock.Call
ReapplyEvents indicates an expected call of ReapplyEvents.
func (*MockEngineMockRecorder) RebuildMutableState ¶ added in v1.16.0
func (mr *MockEngineMockRecorder) RebuildMutableState(ctx, namespaceUUID, execution interface{}) *gomock.Call
RebuildMutableState indicates an expected call of RebuildMutableState.
func (*MockEngineMockRecorder) RecordActivityTaskHeartbeat ¶
func (mr *MockEngineMockRecorder) RecordActivityTaskHeartbeat(ctx, request interface{}) *gomock.Call
RecordActivityTaskHeartbeat indicates an expected call of RecordActivityTaskHeartbeat.
func (*MockEngineMockRecorder) RecordActivityTaskStarted ¶
func (mr *MockEngineMockRecorder) RecordActivityTaskStarted(ctx, request interface{}) *gomock.Call
RecordActivityTaskStarted indicates an expected call of RecordActivityTaskStarted.
func (*MockEngineMockRecorder) RecordChildExecutionCompleted ¶
func (mr *MockEngineMockRecorder) RecordChildExecutionCompleted(ctx, request interface{}) *gomock.Call
RecordChildExecutionCompleted indicates an expected call of RecordChildExecutionCompleted.
func (*MockEngineMockRecorder) RecordWorkflowTaskStarted ¶
func (mr *MockEngineMockRecorder) RecordWorkflowTaskStarted(ctx, request interface{}) *gomock.Call
RecordWorkflowTaskStarted indicates an expected call of RecordWorkflowTaskStarted.
func (*MockEngineMockRecorder) RefreshWorkflowTasks ¶
func (mr *MockEngineMockRecorder) RefreshWorkflowTasks(ctx, namespaceUUID, execution interface{}) *gomock.Call
RefreshWorkflowTasks indicates an expected call of RefreshWorkflowTasks.
func (*MockEngineMockRecorder) RemoveSignalMutableState ¶
func (mr *MockEngineMockRecorder) RemoveSignalMutableState(ctx, request interface{}) *gomock.Call
RemoveSignalMutableState indicates an expected call of RemoveSignalMutableState.
func (*MockEngineMockRecorder) ReplicateEventsV2 ¶
func (mr *MockEngineMockRecorder) ReplicateEventsV2(ctx, request interface{}) *gomock.Call
ReplicateEventsV2 indicates an expected call of ReplicateEventsV2.
func (*MockEngineMockRecorder) ReplicateHistoryEvents ¶ added in v1.23.0
func (mr *MockEngineMockRecorder) ReplicateHistoryEvents(ctx, workflowKey, baseExecutionInfo, versionHistoryItems, historyEvents, newEvents interface{}) *gomock.Call
ReplicateHistoryEvents indicates an expected call of ReplicateHistoryEvents.
func (*MockEngineMockRecorder) ReplicateWorkflowState ¶ added in v1.17.0
func (mr *MockEngineMockRecorder) ReplicateWorkflowState(ctx, request interface{}) *gomock.Call
ReplicateWorkflowState indicates an expected call of ReplicateWorkflowState.
func (*MockEngineMockRecorder) RequestCancelWorkflowExecution ¶
func (mr *MockEngineMockRecorder) RequestCancelWorkflowExecution(ctx, request interface{}) *gomock.Call
RequestCancelWorkflowExecution indicates an expected call of RequestCancelWorkflowExecution.
func (*MockEngineMockRecorder) ResetStickyTaskQueue ¶
func (mr *MockEngineMockRecorder) ResetStickyTaskQueue(ctx, resetRequest interface{}) *gomock.Call
ResetStickyTaskQueue indicates an expected call of ResetStickyTaskQueue.
func (*MockEngineMockRecorder) ResetWorkflowExecution ¶
func (mr *MockEngineMockRecorder) ResetWorkflowExecution(ctx, request interface{}) *gomock.Call
ResetWorkflowExecution indicates an expected call of ResetWorkflowExecution.
func (*MockEngineMockRecorder) RespondActivityTaskCanceled ¶
func (mr *MockEngineMockRecorder) RespondActivityTaskCanceled(ctx, request interface{}) *gomock.Call
RespondActivityTaskCanceled indicates an expected call of RespondActivityTaskCanceled.
func (*MockEngineMockRecorder) RespondActivityTaskCompleted ¶
func (mr *MockEngineMockRecorder) RespondActivityTaskCompleted(ctx, request interface{}) *gomock.Call
RespondActivityTaskCompleted indicates an expected call of RespondActivityTaskCompleted.
func (*MockEngineMockRecorder) RespondActivityTaskFailed ¶
func (mr *MockEngineMockRecorder) RespondActivityTaskFailed(ctx, request interface{}) *gomock.Call
RespondActivityTaskFailed indicates an expected call of RespondActivityTaskFailed.
func (*MockEngineMockRecorder) RespondWorkflowTaskCompleted ¶
func (mr *MockEngineMockRecorder) RespondWorkflowTaskCompleted(ctx, request interface{}) *gomock.Call
RespondWorkflowTaskCompleted indicates an expected call of RespondWorkflowTaskCompleted.
func (*MockEngineMockRecorder) RespondWorkflowTaskFailed ¶
func (mr *MockEngineMockRecorder) RespondWorkflowTaskFailed(ctx, request interface{}) *gomock.Call
RespondWorkflowTaskFailed indicates an expected call of RespondWorkflowTaskFailed.
func (*MockEngineMockRecorder) ScheduleWorkflowTask ¶
func (mr *MockEngineMockRecorder) ScheduleWorkflowTask(ctx, request interface{}) *gomock.Call
ScheduleWorkflowTask indicates an expected call of ScheduleWorkflowTask.
func (*MockEngineMockRecorder) SignalWithStartWorkflowExecution ¶
func (mr *MockEngineMockRecorder) SignalWithStartWorkflowExecution(ctx, request interface{}) *gomock.Call
SignalWithStartWorkflowExecution indicates an expected call of SignalWithStartWorkflowExecution.
func (*MockEngineMockRecorder) SignalWorkflowExecution ¶
func (mr *MockEngineMockRecorder) SignalWorkflowExecution(ctx, request interface{}) *gomock.Call
SignalWorkflowExecution indicates an expected call of SignalWorkflowExecution.
func (*MockEngineMockRecorder) Start ¶
func (mr *MockEngineMockRecorder) Start() *gomock.Call
Start indicates an expected call of Start.
func (*MockEngineMockRecorder) StartWorkflowExecution ¶
func (mr *MockEngineMockRecorder) StartWorkflowExecution(ctx, request interface{}) *gomock.Call
StartWorkflowExecution indicates an expected call of StartWorkflowExecution.
func (*MockEngineMockRecorder) Stop ¶
func (mr *MockEngineMockRecorder) Stop() *gomock.Call
Stop indicates an expected call of Stop.
func (*MockEngineMockRecorder) SubscribeReplicationNotification ¶ added in v1.21.0
func (mr *MockEngineMockRecorder) SubscribeReplicationNotification() *gomock.Call
SubscribeReplicationNotification indicates an expected call of SubscribeReplicationNotification.
func (*MockEngineMockRecorder) SyncActivity ¶
func (mr *MockEngineMockRecorder) SyncActivity(ctx, request interface{}) *gomock.Call
SyncActivity indicates an expected call of SyncActivity.
func (*MockEngineMockRecorder) SyncShardStatus ¶
func (mr *MockEngineMockRecorder) SyncShardStatus(ctx, request interface{}) *gomock.Call
SyncShardStatus indicates an expected call of SyncShardStatus.
func (*MockEngineMockRecorder) TerminateWorkflowExecution ¶
func (mr *MockEngineMockRecorder) TerminateWorkflowExecution(ctx, request interface{}) *gomock.Call
TerminateWorkflowExecution indicates an expected call of TerminateWorkflowExecution.
func (*MockEngineMockRecorder) UnsubscribeReplicationNotification ¶ added in v1.21.0
func (mr *MockEngineMockRecorder) UnsubscribeReplicationNotification(arg0 interface{}) *gomock.Call
UnsubscribeReplicationNotification indicates an expected call of UnsubscribeReplicationNotification.
func (*MockEngineMockRecorder) UpdateWorkflowExecution ¶ added in v1.20.0
func (mr *MockEngineMockRecorder) UpdateWorkflowExecution(ctx, request interface{}) *gomock.Call
UpdateWorkflowExecution indicates an expected call of UpdateWorkflowExecution.
func (*MockEngineMockRecorder) VerifyChildExecutionCompletionRecorded ¶ added in v1.17.0
func (mr *MockEngineMockRecorder) VerifyChildExecutionCompletionRecorded(ctx, request interface{}) *gomock.Call
VerifyChildExecutionCompletionRecorded indicates an expected call of VerifyChildExecutionCompletionRecorded.
func (*MockEngineMockRecorder) VerifyFirstWorkflowTaskScheduled ¶ added in v1.17.0
func (mr *MockEngineMockRecorder) VerifyFirstWorkflowTaskScheduled(ctx, request interface{}) *gomock.Call
VerifyFirstWorkflowTaskScheduled indicates an expected call of VerifyFirstWorkflowTaskScheduled.
type MockReplicationStream ¶ added in v1.21.0
type MockReplicationStream struct {
// contains filtered or unexported fields
}
MockReplicationStream is a mock of ReplicationStream interface.
func NewMockReplicationStream ¶ added in v1.21.0
func NewMockReplicationStream(ctrl *gomock.Controller) *MockReplicationStream
NewMockReplicationStream creates a new mock instance.
func (*MockReplicationStream) ConvertReplicationTask ¶ added in v1.21.0
func (m *MockReplicationStream) ConvertReplicationTask(ctx context.Context, task tasks.Task) (*repication.ReplicationTask, error)
ConvertReplicationTask mocks base method.
func (*MockReplicationStream) EXPECT ¶ added in v1.21.0
func (m *MockReplicationStream) EXPECT() *MockReplicationStreamMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockReplicationStream) GetReplicationTasksIter ¶ added in v1.21.0
func (m *MockReplicationStream) GetReplicationTasksIter(ctx context.Context, pollingCluster string, minInclusiveTaskID, maxExclusiveTaskID int64) (collection.Iterator[tasks.Task], error)
GetReplicationTasksIter mocks base method.
func (*MockReplicationStream) SubscribeReplicationNotification ¶ added in v1.21.0
func (m *MockReplicationStream) SubscribeReplicationNotification() (<-chan struct{}, string)
SubscribeReplicationNotification mocks base method.
func (*MockReplicationStream) UnsubscribeReplicationNotification ¶ added in v1.21.0
func (m *MockReplicationStream) UnsubscribeReplicationNotification(arg0 string)
UnsubscribeReplicationNotification mocks base method.
type MockReplicationStreamMockRecorder ¶ added in v1.21.0
type MockReplicationStreamMockRecorder struct {
// contains filtered or unexported fields
}
MockReplicationStreamMockRecorder is the mock recorder for MockReplicationStream.
func (*MockReplicationStreamMockRecorder) ConvertReplicationTask ¶ added in v1.21.0
func (mr *MockReplicationStreamMockRecorder) ConvertReplicationTask(ctx, task interface{}) *gomock.Call
ConvertReplicationTask indicates an expected call of ConvertReplicationTask.
func (*MockReplicationStreamMockRecorder) GetReplicationTasksIter ¶ added in v1.21.0
func (mr *MockReplicationStreamMockRecorder) GetReplicationTasksIter(ctx, pollingCluster, minInclusiveTaskID, maxExclusiveTaskID interface{}) *gomock.Call
GetReplicationTasksIter indicates an expected call of GetReplicationTasksIter.
func (*MockReplicationStreamMockRecorder) SubscribeReplicationNotification ¶ added in v1.21.0
func (mr *MockReplicationStreamMockRecorder) SubscribeReplicationNotification() *gomock.Call
SubscribeReplicationNotification indicates an expected call of SubscribeReplicationNotification.
func (*MockReplicationStreamMockRecorder) UnsubscribeReplicationNotification ¶ added in v1.21.0
func (mr *MockReplicationStreamMockRecorder) UnsubscribeReplicationNotification(arg0 interface{}) *gomock.Call
UnsubscribeReplicationNotification indicates an expected call of UnsubscribeReplicationNotification.
type OwnershipAwareNamespaceQuotaCalculator ¶ added in v1.23.0
type OwnershipAwareNamespaceQuotaCalculator struct { quotas.ClusterAwareNamespaceSpecificQuotaCalculator // contains filtered or unexported fields }
func NewOwnershipAwareNamespaceQuotaCalculator ¶ added in v1.23.0
func NewOwnershipAwareNamespaceQuotaCalculator( scaler OwnershipBasedQuotaScaler, memberCounter quotas.MemberCounter, perInstanceQuota func(namespace string) int, globalQuota func(namespace string) int, ) *OwnershipAwareNamespaceQuotaCalculator
func (*OwnershipAwareNamespaceQuotaCalculator) GetQuota ¶ added in v1.23.0
func (c *OwnershipAwareNamespaceQuotaCalculator) GetQuota(namespace string) float64
type OwnershipAwareQuotaCalculator ¶ added in v1.23.0
type OwnershipAwareQuotaCalculator struct { quotas.ClusterAwareQuotaCalculator // contains filtered or unexported fields }
func NewOwnershipAwareQuotaCalculator ¶ added in v1.23.0
func NewOwnershipAwareQuotaCalculator( scaler OwnershipBasedQuotaScaler, memberCounter quotas.MemberCounter, perInstanceQuota func() int, globalQuota func() int, ) *OwnershipAwareQuotaCalculator
func (*OwnershipAwareQuotaCalculator) GetQuota ¶ added in v1.23.0
func (c *OwnershipAwareQuotaCalculator) GetQuota() float64
type OwnershipBasedQuotaScaler ¶ added in v1.22.0
type OwnershipBasedQuotaScalerImpl ¶ added in v1.23.0
type OwnershipBasedQuotaScalerImpl struct {
// contains filtered or unexported fields
}
OwnershipBasedQuotaScalerImpl scales rate-limiting quotas linearly with the fraction of the total shards in the cluster owned by this host. The purpose is to allocate more quota to hosts with a higher workload. This object can be obtained from the fx Module within this package.
func NewOwnershipBasedQuotaScaler ¶ added in v1.22.0
func NewOwnershipBasedQuotaScaler( shardCounter ShardCounter, totalNumShards int, updateAppliedCallback chan struct{}, ) (*OwnershipBasedQuotaScalerImpl, error)
NewOwnershipBasedQuotaScaler returns an OwnershipBasedQuotaScaler. The updateAppliedCallback field is a channel which is sent to in a blocking fashion when the shard count updates are applied. This is useful for testing. In production, you should pass in nil, which will cause the callback to be ignored. If totalNumShards is non-positive, then an error is returned.
func (*OwnershipBasedQuotaScalerImpl) Close ¶ added in v1.23.0
func (s *OwnershipBasedQuotaScalerImpl) Close()
func (*OwnershipBasedQuotaScalerImpl) ScaleFactor ¶ added in v1.23.0
func (s *OwnershipBasedQuotaScalerImpl) ScaleFactor() (float64, bool)
type ReplicationStream ¶ added in v1.21.0
type ReplicationStream interface { SubscribeReplicationNotification() (<-chan struct{}, string) UnsubscribeReplicationNotification(string) ConvertReplicationTask( ctx context.Context, task tasks.Task, ) (*replicationspb.ReplicationTask, error) GetReplicationTasksIter( ctx context.Context, pollingCluster string, minInclusiveTaskID int64, maxExclusiveTaskID int64, ) (collection.Iterator[tasks.Task], error) }
type ShardCountSubscription ¶ added in v1.22.0
type ShardCountSubscription interface { // ShardCount returns a channel that receives shard count updates. ShardCount() <-chan int // Unsubscribe unsubscribes from the shard counter. This closes the ShardCount channel. Unsubscribe() }
ShardCountSubscription is a subscription to a ShardCounter. It provides a channel that receives the shard count updates and an Unsubscribe method that unsubscribes from the counter.
type ShardCounter ¶ added in v1.22.0
type ShardCounter interface { // SubscribeShardCount returns a ShardCountSubscription for receiving shard count updates. SubscribeShardCount() ShardCountSubscription }
ShardCounter is an observable object that emits the current shard count.
Source Files ¶
- context.go
- context_factory.go
- context_factory_mock.go
- context_impl.go
- context_mock.go
- context_testutil.go
- context_util.go
- controller.go
- controller_impl.go
- controller_mock.go
- engine.go
- engine_factory.go
- engine_factory_mock.go
- engine_mock.go
- fx.go
- ownership.go
- ownership_based_quota_calculator.go
- ownership_based_quota_scaler.go
- task_key_generator.go
- task_key_manager.go
- task_request_tracker.go