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 BackfillHistoryEventsRequest
- type CloseCallback
- type Context
- type ContextConfigOverrides
- 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) GetFinalizer() *finalizer.Finalizer
- 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() []pingable.Check
- 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, tasksCompleted int, state *persistencespb.QueueState) error
- func (s *ContextImpl) SetWorkflowExecution(ctx context.Context, request *persistence.SetWorkflowExecutionRequest) (*persistence.SetWorkflowExecutionResponse, error)
- func (s *ContextImpl) StateMachineRegistry() *hsm.Registry
- 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
- func (s *ContextTest) SetEngineForTesting(engine Engine)
- func (s *ContextTest) SetEventsCacheForTesting(c events.Cache)
- func (s *ContextTest) SetHistoryClientForTesting(client historyservice.HistoryServiceClient)
- func (s *ContextTest) SetLoggers(l log.Logger)
- func (s *ContextTest) SetMetricsHandler(h metrics.Handler)
- func (s *ContextTest) SetStateMachineRegistry(reg *hsm.Registry)
- func (s *ContextTest) StopForTest()
- type ControllableContext
- type Controller
- type ControllerImpl
- func (c *ControllerImpl) CloseShardByID(shardID int32)
- func (c *ControllerImpl) GetPingChecks() []pingable.Check
- 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 *persistence0.AddHistoryTasksRequest) error
- func (m *MockContext) AppendHistoryEvents(ctx context.Context, request *persistence0.AppendHistoryNodesRequest, ...) (int, error)
- func (m *MockContext) AssertOwnership(ctx context.Context) error
- func (m *MockContext) ConflictResolveWorkflowExecution(ctx context.Context, ...) (*persistence0.ConflictResolveWorkflowExecutionResponse, error)
- func (m *MockContext) CreateWorkflowExecution(ctx context.Context, request *persistence0.CreateWorkflowExecutionRequest) (*persistence0.CreateWorkflowExecutionResponse, error)
- func (m *MockContext) CurrentVectorClock() *clock.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 *persistence0.GetCurrentExecutionRequest) (*persistence0.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() persistence0.ExecutionManager
- func (m *MockContext) GetFinalizer() *finalizer.Finalizer
- func (m *MockContext) GetHistoryClient() historyservice.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) (*persistence.QueueState, bool)
- func (m *MockContext) GetRangeID() int64
- func (m *MockContext) GetRemoteAdminClient(arg0 string) (adminservice.AdminServiceClient, error)
- func (m *MockContext) GetReplicationStatus(cluster []string) (map[string]*historyservice.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() clock0.TimeSource
- func (m *MockContext) GetWorkflowExecution(ctx context.Context, request *persistence0.GetWorkflowExecutionRequest) (*persistence0.GetWorkflowExecutionResponse, error)
- func (m *MockContext) NewVectorClock() (*clock.VectorClock, error)
- func (m *MockContext) SetCurrentTime(cluster string, currentTime time.Time)
- func (m *MockContext) SetQueueState(category tasks.Category, tasksCompleted int, state *persistence.QueueState) error
- func (m *MockContext) SetWorkflowExecution(ctx context.Context, request *persistence0.SetWorkflowExecutionRequest) (*persistence0.SetWorkflowExecutionResponse, error)
- func (m *MockContext) StateMachineRegistry() *hsm.Registry
- 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 *persistence.QueueReaderState) error
- func (m *MockContext) UpdateReplicatorDLQAckLevel(sourCluster string, ackLevel int64) error
- func (m *MockContext) UpdateWorkflowExecution(ctx context.Context, request *persistence0.UpdateWorkflowExecutionRequest) (*persistence0.UpdateWorkflowExecutionResponse, error)
- type MockContextFactory
- type MockContextFactoryMockRecorder
- type MockContextMockRecorder
- func (mr *MockContextMockRecorder) AddSpeculativeWorkflowTaskTimeoutTask(task any) *gomock.Call
- func (mr *MockContextMockRecorder) AddTasks(ctx, request any) *gomock.Call
- func (mr *MockContextMockRecorder) AppendHistoryEvents(ctx, request, namespaceID, execution any) *gomock.Call
- func (mr *MockContextMockRecorder) AssertOwnership(ctx any) *gomock.Call
- func (mr *MockContextMockRecorder) ConflictResolveWorkflowExecution(ctx, request any) *gomock.Call
- func (mr *MockContextMockRecorder) CreateWorkflowExecution(ctx, request any) *gomock.Call
- func (mr *MockContextMockRecorder) CurrentVectorClock() *gomock.Call
- func (mr *MockContextMockRecorder) DeleteWorkflowExecution(ctx, workflowKey, branchToken, closeExecutionVisibilityTaskID, ... any) *gomock.Call
- func (mr *MockContextMockRecorder) GenerateTaskID() *gomock.Call
- func (mr *MockContextMockRecorder) GenerateTaskIDs(number any) *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 any) *gomock.Call
- func (mr *MockContextMockRecorder) GetCurrentTime(cluster any) *gomock.Call
- func (mr *MockContextMockRecorder) GetEngine(ctx any) *gomock.Call
- func (mr *MockContextMockRecorder) GetEventsCache() *gomock.Call
- func (mr *MockContextMockRecorder) GetExecutionManager() *gomock.Call
- func (mr *MockContextMockRecorder) GetFinalizer() *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 any) *gomock.Call
- func (mr *MockContextMockRecorder) GetQueueState(category any) *gomock.Call
- func (mr *MockContextMockRecorder) GetRangeID() *gomock.Call
- func (mr *MockContextMockRecorder) GetRemoteAdminClient(arg0 any) *gomock.Call
- func (mr *MockContextMockRecorder) GetReplicationStatus(cluster any) *gomock.Call
- func (mr *MockContextMockRecorder) GetReplicatorDLQAckLevel(sourceCluster any) *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 any) *gomock.Call
- func (mr *MockContextMockRecorder) NewVectorClock() *gomock.Call
- func (mr *MockContextMockRecorder) SetCurrentTime(cluster, currentTime any) *gomock.Call
- func (mr *MockContextMockRecorder) SetQueueState(category, tasksCompleted, state any) *gomock.Call
- func (mr *MockContextMockRecorder) SetWorkflowExecution(ctx, request any) *gomock.Call
- func (mr *MockContextMockRecorder) StateMachineRegistry() *gomock.Call
- func (mr *MockContextMockRecorder) UnloadForOwnershipLost() *gomock.Call
- func (mr *MockContextMockRecorder) UpdateHandoverNamespace(ns, deletedFromDb any) *gomock.Call
- func (mr *MockContextMockRecorder) UpdateRemoteClusterInfo(cluster, ackTaskID, ackTimestamp any) *gomock.Call
- func (mr *MockContextMockRecorder) UpdateRemoteReaderInfo(readerID, ackTaskID, ackTimestamp any) *gomock.Call
- func (mr *MockContextMockRecorder) UpdateReplicationQueueReaderState(readerID, readerState any) *gomock.Call
- func (mr *MockContextMockRecorder) UpdateReplicatorDLQAckLevel(sourCluster, ackLevel any) *gomock.Call
- func (mr *MockContextMockRecorder) UpdateWorkflowExecution(ctx, request any) *gomock.Call
- type MockControllableContext
- func (m *MockControllableContext) AddSpeculativeWorkflowTaskTimeoutTask(task *tasks.WorkflowTaskTimeoutTask) error
- func (m *MockControllableContext) AddTasks(ctx context.Context, request *persistence0.AddHistoryTasksRequest) error
- func (m *MockControllableContext) AppendHistoryEvents(ctx context.Context, request *persistence0.AppendHistoryNodesRequest, ...) (int, error)
- func (m *MockControllableContext) AssertOwnership(ctx context.Context) error
- func (m *MockControllableContext) ConflictResolveWorkflowExecution(ctx context.Context, ...) (*persistence0.ConflictResolveWorkflowExecutionResponse, error)
- func (m *MockControllableContext) CreateWorkflowExecution(ctx context.Context, request *persistence0.CreateWorkflowExecutionRequest) (*persistence0.CreateWorkflowExecutionResponse, error)
- func (m *MockControllableContext) CurrentVectorClock() *clock.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 *persistence0.GetCurrentExecutionRequest) (*persistence0.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() persistence0.ExecutionManager
- func (m *MockControllableContext) GetFinalizer() *finalizer.Finalizer
- func (m *MockControllableContext) GetHistoryClient() historyservice.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() []pingable.Check
- func (m *MockControllableContext) GetQueueExclusiveHighReadWatermark(category tasks.Category) tasks.Key
- func (m *MockControllableContext) GetQueueState(category tasks.Category) (*persistence.QueueState, bool)
- func (m *MockControllableContext) GetRangeID() int64
- func (m *MockControllableContext) GetRemoteAdminClient(arg0 string) (adminservice.AdminServiceClient, error)
- func (m *MockControllableContext) GetReplicationStatus(cluster []string) (map[string]*historyservice.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() clock0.TimeSource
- func (m *MockControllableContext) GetWorkflowExecution(ctx context.Context, request *persistence0.GetWorkflowExecutionRequest) (*persistence0.GetWorkflowExecutionResponse, error)
- func (m *MockControllableContext) IsValid() bool
- func (m *MockControllableContext) NewVectorClock() (*clock.VectorClock, error)
- func (m *MockControllableContext) SetCurrentTime(cluster string, currentTime time.Time)
- func (m *MockControllableContext) SetQueueState(category tasks.Category, tasksCompleted int, state *persistence.QueueState) error
- func (m *MockControllableContext) SetWorkflowExecution(ctx context.Context, request *persistence0.SetWorkflowExecutionRequest) (*persistence0.SetWorkflowExecutionResponse, error)
- func (m *MockControllableContext) StateMachineRegistry() *hsm.Registry
- 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 *persistence.QueueReaderState) error
- func (m *MockControllableContext) UpdateReplicatorDLQAckLevel(sourCluster string, ackLevel int64) error
- func (m *MockControllableContext) UpdateWorkflowExecution(ctx context.Context, request *persistence0.UpdateWorkflowExecutionRequest) (*persistence0.UpdateWorkflowExecutionResponse, error)
- type MockControllableContextMockRecorder
- func (mr *MockControllableContextMockRecorder) AddSpeculativeWorkflowTaskTimeoutTask(task any) *gomock.Call
- func (mr *MockControllableContextMockRecorder) AddTasks(ctx, request any) *gomock.Call
- func (mr *MockControllableContextMockRecorder) AppendHistoryEvents(ctx, request, namespaceID, execution any) *gomock.Call
- func (mr *MockControllableContextMockRecorder) AssertOwnership(ctx any) *gomock.Call
- func (mr *MockControllableContextMockRecorder) ConflictResolveWorkflowExecution(ctx, request any) *gomock.Call
- func (mr *MockControllableContextMockRecorder) CreateWorkflowExecution(ctx, request any) *gomock.Call
- func (mr *MockControllableContextMockRecorder) CurrentVectorClock() *gomock.Call
- func (mr *MockControllableContextMockRecorder) DeleteWorkflowExecution(ctx, workflowKey, branchToken, closeExecutionVisibilityTaskID, ... any) *gomock.Call
- func (mr *MockControllableContextMockRecorder) FinishStop() *gomock.Call
- func (mr *MockControllableContextMockRecorder) GenerateTaskID() *gomock.Call
- func (mr *MockControllableContextMockRecorder) GenerateTaskIDs(number any) *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 any) *gomock.Call
- func (mr *MockControllableContextMockRecorder) GetCurrentTime(cluster any) *gomock.Call
- func (mr *MockControllableContextMockRecorder) GetEngine(ctx any) *gomock.Call
- func (mr *MockControllableContextMockRecorder) GetEventsCache() *gomock.Call
- func (mr *MockControllableContextMockRecorder) GetExecutionManager() *gomock.Call
- func (mr *MockControllableContextMockRecorder) GetFinalizer() *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 any) *gomock.Call
- func (mr *MockControllableContextMockRecorder) GetQueueState(category any) *gomock.Call
- func (mr *MockControllableContextMockRecorder) GetRangeID() *gomock.Call
- func (mr *MockControllableContextMockRecorder) GetRemoteAdminClient(arg0 any) *gomock.Call
- func (mr *MockControllableContextMockRecorder) GetReplicationStatus(cluster any) *gomock.Call
- func (mr *MockControllableContextMockRecorder) GetReplicatorDLQAckLevel(sourceCluster any) *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 any) *gomock.Call
- func (mr *MockControllableContextMockRecorder) IsValid() *gomock.Call
- func (mr *MockControllableContextMockRecorder) NewVectorClock() *gomock.Call
- func (mr *MockControllableContextMockRecorder) SetCurrentTime(cluster, currentTime any) *gomock.Call
- func (mr *MockControllableContextMockRecorder) SetQueueState(category, tasksCompleted, state any) *gomock.Call
- func (mr *MockControllableContextMockRecorder) SetWorkflowExecution(ctx, request any) *gomock.Call
- func (mr *MockControllableContextMockRecorder) StateMachineRegistry() *gomock.Call
- func (mr *MockControllableContextMockRecorder) UnloadForOwnershipLost() *gomock.Call
- func (mr *MockControllableContextMockRecorder) UpdateHandoverNamespace(ns, deletedFromDb any) *gomock.Call
- func (mr *MockControllableContextMockRecorder) UpdateRemoteClusterInfo(cluster, ackTaskID, ackTimestamp any) *gomock.Call
- func (mr *MockControllableContextMockRecorder) UpdateRemoteReaderInfo(readerID, ackTaskID, ackTimestamp any) *gomock.Call
- func (mr *MockControllableContextMockRecorder) UpdateReplicationQueueReaderState(readerID, readerState any) *gomock.Call
- func (mr *MockControllableContextMockRecorder) UpdateReplicatorDLQAckLevel(sourCluster, ackLevel any) *gomock.Call
- func (mr *MockControllableContextMockRecorder) UpdateWorkflowExecution(ctx, request any) *gomock.Call
- type MockController
- func (m *MockController) CloseShardByID(shardID int32)
- func (m *MockController) EXPECT() *MockControllerMockRecorder
- func (m *MockController) GetPingChecks() []pingable.Check
- 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 any) *gomock.Call
- func (mr *MockControllerMockRecorder) GetPingChecks() *gomock.Call
- func (mr *MockControllerMockRecorder) GetShardByID(shardID any) *gomock.Call
- func (mr *MockControllerMockRecorder) GetShardByNamespaceWorkflow(namespaceID, workflowID any) *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) AddTasks(ctx context.Context, request *historyservice.AddTasksRequest) (*historyservice.AddTasksResponse, error)
- func (m *MockEngine) BackfillHistoryEvents(ctx context.Context, request *BackfillHistoryEventsRequest) error
- func (m *MockEngine) ConvertReplicationTask(ctx context.Context, task tasks.Task, clusterID int32) (*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) ExecuteMultiOperation(ctx context.Context, request *historyservice.ExecuteMultiOperationRequest) (*historyservice.ExecuteMultiOperationResponse, error)
- 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) GetMaxReplicationTaskInfo() (int64, time.Time)
- 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) GetWorkflowExecutionRawHistory(ctx context.Context, ...) (*historyservice.GetWorkflowExecutionRawHistoryResponse, 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) ListTasks(ctx context.Context, request *historyservice.ListTasksRequest) (*historyservice.ListTasksResponse, 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) ReplicateVersionedTransition(ctx context.Context, artifact *repication.VersionedTransitionArtifact, ...) 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) StateMachineEnvironment() hsm.Environment
- func (m *MockEngine) Stop()
- func (m *MockEngine) SubscribeReplicationNotification() (<-chan struct{}, string)
- func (m *MockEngine) SyncActivities(ctx context.Context, request *historyservice.SyncActivitiesRequest) error
- func (m *MockEngine) SyncActivity(ctx context.Context, request *historyservice.SyncActivityRequest) error
- func (m *MockEngine) SyncHSM(ctx context.Context, request *SyncHSMRequest) error
- func (m *MockEngine) SyncShardStatus(ctx context.Context, request *historyservice.SyncShardStatusRequest) error
- func (m *MockEngine) SyncWorkflowState(ctx context.Context, request *historyservice.SyncWorkflowStateRequest) (*historyservice.SyncWorkflowStateResponse, 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) AddTasks(ctx, request any) *gomock.Call
- func (mr *MockEngineMockRecorder) BackfillHistoryEvents(ctx, request any) *gomock.Call
- func (mr *MockEngineMockRecorder) ConvertReplicationTask(ctx, task, clusterID any) *gomock.Call
- func (mr *MockEngineMockRecorder) DeleteWorkflowExecution(ctx, deleteRequest any) *gomock.Call
- func (mr *MockEngineMockRecorder) DescribeMutableState(ctx, request any) *gomock.Call
- func (mr *MockEngineMockRecorder) DescribeWorkflowExecution(ctx, request any) *gomock.Call
- func (mr *MockEngineMockRecorder) ExecuteMultiOperation(ctx, request any) *gomock.Call
- func (mr *MockEngineMockRecorder) GenerateLastHistoryReplicationTasks(ctx, request any) *gomock.Call
- func (mr *MockEngineMockRecorder) GetDLQMessages(ctx, messagesRequest any) *gomock.Call
- func (mr *MockEngineMockRecorder) GetDLQReplicationMessages(ctx, taskInfos any) *gomock.Call
- func (mr *MockEngineMockRecorder) GetMaxReplicationTaskInfo() *gomock.Call
- func (mr *MockEngineMockRecorder) GetMutableState(ctx, request any) *gomock.Call
- func (mr *MockEngineMockRecorder) GetReplicationMessages(ctx, pollingCluster, ackMessageID, ackTimestamp, queryMessageID any) *gomock.Call
- func (mr *MockEngineMockRecorder) GetReplicationStatus(ctx, request any) *gomock.Call
- func (mr *MockEngineMockRecorder) GetReplicationTasksIter(ctx, pollingCluster, minInclusiveTaskID, maxExclusiveTaskID any) *gomock.Call
- func (mr *MockEngineMockRecorder) GetWorkflowExecutionHistory(ctx, request any) *gomock.Call
- func (mr *MockEngineMockRecorder) GetWorkflowExecutionHistoryReverse(ctx, request any) *gomock.Call
- func (mr *MockEngineMockRecorder) GetWorkflowExecutionRawHistory(ctx, request any) *gomock.Call
- func (mr *MockEngineMockRecorder) GetWorkflowExecutionRawHistoryV2(ctx, request any) *gomock.Call
- func (mr *MockEngineMockRecorder) ImportWorkflowExecution(ctx, request any) *gomock.Call
- func (mr *MockEngineMockRecorder) IsActivityTaskValid(ctx, request any) *gomock.Call
- func (mr *MockEngineMockRecorder) IsWorkflowTaskValid(ctx, request any) *gomock.Call
- func (mr *MockEngineMockRecorder) ListTasks(ctx, request any) *gomock.Call
- func (mr *MockEngineMockRecorder) MergeDLQMessages(ctx, messagesRequest any) *gomock.Call
- func (mr *MockEngineMockRecorder) NotifyNewHistoryEvent(event any) *gomock.Call
- func (mr *MockEngineMockRecorder) NotifyNewTasks(tasks any) *gomock.Call
- func (mr *MockEngineMockRecorder) PollMutableState(ctx, request any) *gomock.Call
- func (mr *MockEngineMockRecorder) PollWorkflowExecutionUpdate(ctx, request any) *gomock.Call
- func (mr *MockEngineMockRecorder) PurgeDLQMessages(ctx, messagesRequest any) *gomock.Call
- func (mr *MockEngineMockRecorder) QueryWorkflow(ctx, request any) *gomock.Call
- func (mr *MockEngineMockRecorder) ReapplyEvents(ctx, namespaceUUID, workflowID, runID, events any) *gomock.Call
- func (mr *MockEngineMockRecorder) RebuildMutableState(ctx, namespaceUUID, execution any) *gomock.Call
- func (mr *MockEngineMockRecorder) RecordActivityTaskHeartbeat(ctx, request any) *gomock.Call
- func (mr *MockEngineMockRecorder) RecordActivityTaskStarted(ctx, request any) *gomock.Call
- func (mr *MockEngineMockRecorder) RecordChildExecutionCompleted(ctx, request any) *gomock.Call
- func (mr *MockEngineMockRecorder) RecordWorkflowTaskStarted(ctx, request any) *gomock.Call
- func (mr *MockEngineMockRecorder) RefreshWorkflowTasks(ctx, namespaceUUID, execution any) *gomock.Call
- func (mr *MockEngineMockRecorder) RemoveSignalMutableState(ctx, request any) *gomock.Call
- func (mr *MockEngineMockRecorder) ReplicateEventsV2(ctx, request any) *gomock.Call
- func (mr *MockEngineMockRecorder) ReplicateHistoryEvents(...) *gomock.Call
- func (mr *MockEngineMockRecorder) ReplicateVersionedTransition(ctx, artifact, sourceClusterName any) *gomock.Call
- func (mr *MockEngineMockRecorder) ReplicateWorkflowState(ctx, request any) *gomock.Call
- func (mr *MockEngineMockRecorder) RequestCancelWorkflowExecution(ctx, request any) *gomock.Call
- func (mr *MockEngineMockRecorder) ResetStickyTaskQueue(ctx, resetRequest any) *gomock.Call
- func (mr *MockEngineMockRecorder) ResetWorkflowExecution(ctx, request any) *gomock.Call
- func (mr *MockEngineMockRecorder) RespondActivityTaskCanceled(ctx, request any) *gomock.Call
- func (mr *MockEngineMockRecorder) RespondActivityTaskCompleted(ctx, request any) *gomock.Call
- func (mr *MockEngineMockRecorder) RespondActivityTaskFailed(ctx, request any) *gomock.Call
- func (mr *MockEngineMockRecorder) RespondWorkflowTaskCompleted(ctx, request any) *gomock.Call
- func (mr *MockEngineMockRecorder) RespondWorkflowTaskFailed(ctx, request any) *gomock.Call
- func (mr *MockEngineMockRecorder) ScheduleWorkflowTask(ctx, request any) *gomock.Call
- func (mr *MockEngineMockRecorder) SignalWithStartWorkflowExecution(ctx, request any) *gomock.Call
- func (mr *MockEngineMockRecorder) SignalWorkflowExecution(ctx, request any) *gomock.Call
- func (mr *MockEngineMockRecorder) Start() *gomock.Call
- func (mr *MockEngineMockRecorder) StartWorkflowExecution(ctx, request any) *gomock.Call
- func (mr *MockEngineMockRecorder) StateMachineEnvironment() *gomock.Call
- func (mr *MockEngineMockRecorder) Stop() *gomock.Call
- func (mr *MockEngineMockRecorder) SubscribeReplicationNotification() *gomock.Call
- func (mr *MockEngineMockRecorder) SyncActivities(ctx, request any) *gomock.Call
- func (mr *MockEngineMockRecorder) SyncActivity(ctx, request any) *gomock.Call
- func (mr *MockEngineMockRecorder) SyncHSM(ctx, request any) *gomock.Call
- func (mr *MockEngineMockRecorder) SyncShardStatus(ctx, request any) *gomock.Call
- func (mr *MockEngineMockRecorder) SyncWorkflowState(ctx, request any) *gomock.Call
- func (mr *MockEngineMockRecorder) TerminateWorkflowExecution(ctx, request any) *gomock.Call
- func (mr *MockEngineMockRecorder) UnsubscribeReplicationNotification(arg0 any) *gomock.Call
- func (mr *MockEngineMockRecorder) UpdateWorkflowExecution(ctx, request any) *gomock.Call
- func (mr *MockEngineMockRecorder) VerifyChildExecutionCompletionRecorded(ctx, request any) *gomock.Call
- func (mr *MockEngineMockRecorder) VerifyFirstWorkflowTaskScheduled(ctx, request any) *gomock.Call
- type MockReplicationStream
- func (m *MockReplicationStream) ConvertReplicationTask(ctx context.Context, task tasks.Task, clusterID int32) (*repication.ReplicationTask, error)
- func (m *MockReplicationStream) EXPECT() *MockReplicationStreamMockRecorder
- func (m *MockReplicationStream) GetMaxReplicationTaskInfo() (int64, time.Time)
- 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, clusterID any) *gomock.Call
- func (mr *MockReplicationStreamMockRecorder) GetMaxReplicationTaskInfo() *gomock.Call
- func (mr *MockReplicationStreamMockRecorder) GetReplicationTasksIter(ctx, pollingCluster, minInclusiveTaskID, maxExclusiveTaskID any) *gomock.Call
- func (mr *MockReplicationStreamMockRecorder) SubscribeReplicationNotification() *gomock.Call
- func (mr *MockReplicationStreamMockRecorder) UnsubscribeReplicationNotification(arg0 any) *gomock.Call
- type OwnershipAwareNamespaceQuotaCalculator
- type OwnershipAwareQuotaCalculator
- type OwnershipBasedQuotaScaler
- type OwnershipBasedQuotaScalerImpl
- type ReplicationStream
- type ShardCountSubscription
- type ShardCounter
- type StubContext
- type SyncHSMRequest
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) pingable.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 BackfillHistoryEventsRequest ¶ added in v1.25.0
type BackfillHistoryEventsRequest struct { definition.WorkflowKey SourceClusterName string VersionedHistory *persistencespb.VersionedTransition BaseExecutionInfo *workflowpb.BaseExecutionInfo VersionHistoryItems []*historyspb.VersionHistoryItem Events [][]*historypb.HistoryEvent NewEvents []*historypb.HistoryEvent NewRunID string }
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, tasksCompleted int, 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, closeExecutionVisibilityTaskID int64, workflowCloseTime time.Time, stage *tasks.DeleteWorkflowExecutionStage) error UnloadForOwnershipLost() StateMachineRegistry() *hsm.Registry GetFinalizer() *finalizer.Finalizer }
Context represents a history engine shard
type ContextConfigOverrides ¶ added in v1.24.0
type ContextConfigOverrides struct { ShardInfo *persistencespb.ShardInfo Config *configs.Config Registry namespace.Registry ClusterMetadata cluster.Metadata ExecutionManager persistence.ExecutionManager }
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 EventsCache events.Cache StateMachineRegistry *hsm.Registry }
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, closeVisibilityTaskId int64, workflowCloseTime time.Time, 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) GetFinalizer ¶ added in v1.25.0
func (s *ContextImpl) GetFinalizer() *finalizer.Finalizer
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() []pingable.Check
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, tasksCompleted int, 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) StateMachineRegistry ¶ added in v1.24.0
func (s *ContextImpl) StateMachineRegistry() *hsm.Registry
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) SetLoggers ¶ added in v1.25.0
func (s *ContextTest) SetLoggers(l log.Logger)
SetLoggers sets both s.throttledLogger and s.contextTaggedLogger. Only used by tests.
func (*ContextTest) SetMetricsHandler ¶ added in v1.25.0
func (s *ContextTest) SetMetricsHandler(h metrics.Handler)
SetMetricsHandler sets s.metricsHandler. Only used by tests.
func (*ContextTest) SetStateMachineRegistry ¶ added in v1.24.0
func (s *ContextTest) SetStateMachineRegistry(reg *hsm.Registry)
SetStateMachineRegistry sets the state machine registry on this shard.
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() []pingable.Check
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) ExecuteMultiOperation(ctx context.Context, request *historyservice.ExecuteMultiOperationRequest) (*historyservice.ExecuteMultiOperationResponse, 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( ctx context.Context, workflowKey definition.WorkflowKey, baseExecutionInfo *workflowpb.BaseExecutionInfo, versionHistoryItems []*historyspb.VersionHistoryItem, historyEvents [][]*historypb.HistoryEvent, newEvents []*historypb.HistoryEvent, newRunID string, ) error ReplicateEventsV2(ctx context.Context, request *historyservice.ReplicateEventsV2Request) error ReplicateWorkflowState(ctx context.Context, request *historyservice.ReplicateWorkflowStateRequest) error ReplicateVersionedTransition(ctx context.Context, artifact *replicationspb.VersionedTransitionArtifact, sourceClusterName string) error SyncShardStatus(ctx context.Context, request *historyservice.SyncShardStatusRequest) error SyncActivity(ctx context.Context, request *historyservice.SyncActivityRequest) error SyncActivities(ctx context.Context, request *historyservice.SyncActivitiesRequest) error SyncHSM(ctx context.Context, request *SyncHSMRequest) error BackfillHistoryEvents(ctx context.Context, request *BackfillHistoryEventsRequest) 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) GetWorkflowExecutionRawHistory(ctx context.Context, request *historyservice.GetWorkflowExecutionRawHistoryRequest) (*historyservice.GetWorkflowExecutionRawHistoryResponse, error) GetWorkflowExecutionRawHistoryV2(ctx context.Context, request *historyservice.GetWorkflowExecutionRawHistoryV2Request) (*historyservice.GetWorkflowExecutionRawHistoryV2Response, error) AddTasks(ctx context.Context, request *historyservice.AddTasksRequest) (*historyservice.AddTasksResponse, error) ListTasks(ctx context.Context, request *historyservice.ListTasksRequest) (*historyservice.ListTasksResponse, error) SyncWorkflowState(ctx context.Context, request *historyservice.SyncWorkflowStateRequest) (*historyservice.SyncWorkflowStateResponse, error) NotifyNewHistoryEvent(event *events.Notification) NotifyNewTasks(tasks map[tasks.Category][]tasks.Task) // TODO(bergundy): This Environment should be host level once shard level workflow cache is deprecated. StateMachineEnvironment() hsm.Environment 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 *persistence0.AddHistoryTasksRequest) error
AddTasks mocks base method.
func (*MockContext) AppendHistoryEvents ¶ added in v1.5.0
func (m *MockContext) AppendHistoryEvents(ctx context.Context, request *persistence0.AppendHistoryNodesRequest, namespaceID namespace.ID, execution *common.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 *persistence0.ConflictResolveWorkflowExecutionRequest) (*persistence0.ConflictResolveWorkflowExecutionResponse, error)
ConflictResolveWorkflowExecution mocks base method.
func (*MockContext) CreateWorkflowExecution ¶
func (m *MockContext) CreateWorkflowExecution(ctx context.Context, request *persistence0.CreateWorkflowExecutionRequest) (*persistence0.CreateWorkflowExecutionResponse, error)
CreateWorkflowExecution mocks base method.
func (*MockContext) CurrentVectorClock ¶ added in v1.17.0
func (m *MockContext) CurrentVectorClock() *clock.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, closeExecutionVisibilityTaskID int64, workflowCloseTime time.Time, 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 *persistence0.GetCurrentExecutionRequest) (*persistence0.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() persistence0.ExecutionManager
GetExecutionManager mocks base method.
func (*MockContext) GetFinalizer ¶ added in v1.25.0
func (m *MockContext) GetFinalizer() *finalizer.Finalizer
GetFinalizer mocks base method.
func (*MockContext) GetHistoryClient ¶ added in v1.14.0
func (m *MockContext) GetHistoryClient() historyservice.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) (*persistence.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) (adminservice.AdminServiceClient, error)
GetRemoteAdminClient mocks base method.
func (*MockContext) GetReplicationStatus ¶ added in v1.14.0
func (m *MockContext) GetReplicationStatus(cluster []string) (map[string]*historyservice.ShardReplicationStatusPerCluster, map[string]*historyservice.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() clock0.TimeSource
GetTimeSource mocks base method.
func (*MockContext) GetWorkflowExecution ¶ added in v1.16.0
func (m *MockContext) GetWorkflowExecution(ctx context.Context, request *persistence0.GetWorkflowExecutionRequest) (*persistence0.GetWorkflowExecutionResponse, error)
GetWorkflowExecution mocks base method.
func (*MockContext) NewVectorClock ¶ added in v1.17.0
func (m *MockContext) NewVectorClock() (*clock.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, tasksCompleted int, state *persistence.QueueState) error
SetQueueState mocks base method.
func (*MockContext) SetWorkflowExecution ¶ added in v1.16.0
func (m *MockContext) SetWorkflowExecution(ctx context.Context, request *persistence0.SetWorkflowExecutionRequest) (*persistence0.SetWorkflowExecutionResponse, error)
SetWorkflowExecution mocks base method.
func (*MockContext) StateMachineRegistry ¶ added in v1.24.0
func (m *MockContext) StateMachineRegistry() *hsm.Registry
StateMachineRegistry 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 *persistence.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 *persistence0.UpdateWorkflowExecutionRequest) (*persistence0.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 any) *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 any) *gomock.Call
AddSpeculativeWorkflowTaskTimeoutTask indicates an expected call of AddSpeculativeWorkflowTaskTimeoutTask.
func (*MockContextMockRecorder) AddTasks ¶ added in v1.5.0
func (mr *MockContextMockRecorder) AddTasks(ctx, request any) *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 any) *gomock.Call
AppendHistoryEvents indicates an expected call of AppendHistoryEvents.
func (*MockContextMockRecorder) AssertOwnership ¶ added in v1.17.0
func (mr *MockContextMockRecorder) AssertOwnership(ctx any) *gomock.Call
AssertOwnership indicates an expected call of AssertOwnership.
func (*MockContextMockRecorder) ConflictResolveWorkflowExecution ¶
func (mr *MockContextMockRecorder) ConflictResolveWorkflowExecution(ctx, request any) *gomock.Call
ConflictResolveWorkflowExecution indicates an expected call of ConflictResolveWorkflowExecution.
func (*MockContextMockRecorder) CreateWorkflowExecution ¶
func (mr *MockContextMockRecorder) CreateWorkflowExecution(ctx, request any) *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, closeExecutionVisibilityTaskID, workflowCloseTime, stage any) *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 any) *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 any) *gomock.Call
GetCurrentExecution indicates an expected call of GetCurrentExecution.
func (*MockContextMockRecorder) GetCurrentTime ¶
func (mr *MockContextMockRecorder) GetCurrentTime(cluster any) *gomock.Call
GetCurrentTime indicates an expected call of GetCurrentTime.
func (*MockContextMockRecorder) GetEngine ¶
func (mr *MockContextMockRecorder) GetEngine(ctx any) *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) GetFinalizer ¶ added in v1.25.0
func (mr *MockContextMockRecorder) GetFinalizer() *gomock.Call
GetFinalizer indicates an expected call of GetFinalizer.
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 any) *gomock.Call
GetQueueExclusiveHighReadWatermark indicates an expected call of GetQueueExclusiveHighReadWatermark.
func (*MockContextMockRecorder) GetQueueState ¶ added in v1.17.3
func (mr *MockContextMockRecorder) GetQueueState(category any) *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 any) *gomock.Call
GetRemoteAdminClient indicates an expected call of GetRemoteAdminClient.
func (*MockContextMockRecorder) GetReplicationStatus ¶ added in v1.14.0
func (mr *MockContextMockRecorder) GetReplicationStatus(cluster any) *gomock.Call
GetReplicationStatus indicates an expected call of GetReplicationStatus.
func (*MockContextMockRecorder) GetReplicatorDLQAckLevel ¶
func (mr *MockContextMockRecorder) GetReplicatorDLQAckLevel(sourceCluster any) *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 any) *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 any) *gomock.Call
SetCurrentTime indicates an expected call of SetCurrentTime.
func (*MockContextMockRecorder) SetQueueState ¶ added in v1.21.0
func (mr *MockContextMockRecorder) SetQueueState(category, tasksCompleted, state any) *gomock.Call
SetQueueState indicates an expected call of SetQueueState.
func (*MockContextMockRecorder) SetWorkflowExecution ¶ added in v1.16.0
func (mr *MockContextMockRecorder) SetWorkflowExecution(ctx, request any) *gomock.Call
SetWorkflowExecution indicates an expected call of SetWorkflowExecution.
func (*MockContextMockRecorder) StateMachineRegistry ¶ added in v1.24.0
func (mr *MockContextMockRecorder) StateMachineRegistry() *gomock.Call
StateMachineRegistry indicates an expected call of StateMachineRegistry.
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 any) *gomock.Call
UpdateHandoverNamespace indicates an expected call of UpdateHandoverNamespace.
func (*MockContextMockRecorder) UpdateRemoteClusterInfo ¶ added in v1.16.0
func (mr *MockContextMockRecorder) UpdateRemoteClusterInfo(cluster, ackTaskID, ackTimestamp any) *gomock.Call
UpdateRemoteClusterInfo indicates an expected call of UpdateRemoteClusterInfo.
func (*MockContextMockRecorder) UpdateRemoteReaderInfo ¶ added in v1.21.0
func (mr *MockContextMockRecorder) UpdateRemoteReaderInfo(readerID, ackTaskID, ackTimestamp any) *gomock.Call
UpdateRemoteReaderInfo indicates an expected call of UpdateRemoteReaderInfo.
func (*MockContextMockRecorder) UpdateReplicationQueueReaderState ¶ added in v1.21.0
func (mr *MockContextMockRecorder) UpdateReplicationQueueReaderState(readerID, readerState any) *gomock.Call
UpdateReplicationQueueReaderState indicates an expected call of UpdateReplicationQueueReaderState.
func (*MockContextMockRecorder) UpdateReplicatorDLQAckLevel ¶
func (mr *MockContextMockRecorder) UpdateReplicatorDLQAckLevel(sourCluster, ackLevel any) *gomock.Call
UpdateReplicatorDLQAckLevel indicates an expected call of UpdateReplicatorDLQAckLevel.
func (*MockContextMockRecorder) UpdateWorkflowExecution ¶
func (mr *MockContextMockRecorder) UpdateWorkflowExecution(ctx, request any) *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 *persistence0.AddHistoryTasksRequest) error
AddTasks mocks base method.
func (*MockControllableContext) AppendHistoryEvents ¶ added in v1.21.5
func (m *MockControllableContext) AppendHistoryEvents(ctx context.Context, request *persistence0.AppendHistoryNodesRequest, namespaceID namespace.ID, execution *common.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 *persistence0.ConflictResolveWorkflowExecutionRequest) (*persistence0.ConflictResolveWorkflowExecutionResponse, error)
ConflictResolveWorkflowExecution mocks base method.
func (*MockControllableContext) CreateWorkflowExecution ¶ added in v1.21.5
func (m *MockControllableContext) CreateWorkflowExecution(ctx context.Context, request *persistence0.CreateWorkflowExecutionRequest) (*persistence0.CreateWorkflowExecutionResponse, error)
CreateWorkflowExecution mocks base method.
func (*MockControllableContext) CurrentVectorClock ¶ added in v1.21.5
func (m *MockControllableContext) CurrentVectorClock() *clock.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, closeExecutionVisibilityTaskID int64, workflowCloseTime time.Time, 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 *persistence0.GetCurrentExecutionRequest) (*persistence0.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() persistence0.ExecutionManager
GetExecutionManager mocks base method.
func (*MockControllableContext) GetFinalizer ¶ added in v1.25.0
func (m *MockControllableContext) GetFinalizer() *finalizer.Finalizer
GetFinalizer mocks base method.
func (*MockControllableContext) GetHistoryClient ¶ added in v1.21.5
func (m *MockControllableContext) GetHistoryClient() historyservice.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() []pingable.Check
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) (*persistence.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) (adminservice.AdminServiceClient, error)
GetRemoteAdminClient mocks base method.
func (*MockControllableContext) GetReplicationStatus ¶ added in v1.21.5
func (m *MockControllableContext) GetReplicationStatus(cluster []string) (map[string]*historyservice.ShardReplicationStatusPerCluster, map[string]*historyservice.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() clock0.TimeSource
GetTimeSource mocks base method.
func (*MockControllableContext) GetWorkflowExecution ¶ added in v1.21.5
func (m *MockControllableContext) GetWorkflowExecution(ctx context.Context, request *persistence0.GetWorkflowExecutionRequest) (*persistence0.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() (*clock.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, tasksCompleted int, state *persistence.QueueState) error
SetQueueState mocks base method.
func (*MockControllableContext) SetWorkflowExecution ¶ added in v1.21.5
func (m *MockControllableContext) SetWorkflowExecution(ctx context.Context, request *persistence0.SetWorkflowExecutionRequest) (*persistence0.SetWorkflowExecutionResponse, error)
SetWorkflowExecution mocks base method.
func (*MockControllableContext) StateMachineRegistry ¶ added in v1.24.0
func (m *MockControllableContext) StateMachineRegistry() *hsm.Registry
StateMachineRegistry 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 *persistence.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 *persistence0.UpdateWorkflowExecutionRequest) (*persistence0.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 any) *gomock.Call
AddSpeculativeWorkflowTaskTimeoutTask indicates an expected call of AddSpeculativeWorkflowTaskTimeoutTask.
func (*MockControllableContextMockRecorder) AddTasks ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) AddTasks(ctx, request any) *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 any) *gomock.Call
AppendHistoryEvents indicates an expected call of AppendHistoryEvents.
func (*MockControllableContextMockRecorder) AssertOwnership ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) AssertOwnership(ctx any) *gomock.Call
AssertOwnership indicates an expected call of AssertOwnership.
func (*MockControllableContextMockRecorder) ConflictResolveWorkflowExecution ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) ConflictResolveWorkflowExecution(ctx, request any) *gomock.Call
ConflictResolveWorkflowExecution indicates an expected call of ConflictResolveWorkflowExecution.
func (*MockControllableContextMockRecorder) CreateWorkflowExecution ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) CreateWorkflowExecution(ctx, request any) *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, closeExecutionVisibilityTaskID, workflowCloseTime, stage any) *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 any) *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 any) *gomock.Call
GetCurrentExecution indicates an expected call of GetCurrentExecution.
func (*MockControllableContextMockRecorder) GetCurrentTime ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) GetCurrentTime(cluster any) *gomock.Call
GetCurrentTime indicates an expected call of GetCurrentTime.
func (*MockControllableContextMockRecorder) GetEngine ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) GetEngine(ctx any) *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) GetFinalizer ¶ added in v1.25.0
func (mr *MockControllableContextMockRecorder) GetFinalizer() *gomock.Call
GetFinalizer indicates an expected call of GetFinalizer.
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 any) *gomock.Call
GetQueueExclusiveHighReadWatermark indicates an expected call of GetQueueExclusiveHighReadWatermark.
func (*MockControllableContextMockRecorder) GetQueueState ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) GetQueueState(category any) *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 any) *gomock.Call
GetRemoteAdminClient indicates an expected call of GetRemoteAdminClient.
func (*MockControllableContextMockRecorder) GetReplicationStatus ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) GetReplicationStatus(cluster any) *gomock.Call
GetReplicationStatus indicates an expected call of GetReplicationStatus.
func (*MockControllableContextMockRecorder) GetReplicatorDLQAckLevel ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) GetReplicatorDLQAckLevel(sourceCluster any) *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 any) *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 any) *gomock.Call
SetCurrentTime indicates an expected call of SetCurrentTime.
func (*MockControllableContextMockRecorder) SetQueueState ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) SetQueueState(category, tasksCompleted, state any) *gomock.Call
SetQueueState indicates an expected call of SetQueueState.
func (*MockControllableContextMockRecorder) SetWorkflowExecution ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) SetWorkflowExecution(ctx, request any) *gomock.Call
SetWorkflowExecution indicates an expected call of SetWorkflowExecution.
func (*MockControllableContextMockRecorder) StateMachineRegistry ¶ added in v1.24.0
func (mr *MockControllableContextMockRecorder) StateMachineRegistry() *gomock.Call
StateMachineRegistry indicates an expected call of StateMachineRegistry.
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 any) *gomock.Call
UpdateHandoverNamespace indicates an expected call of UpdateHandoverNamespace.
func (*MockControllableContextMockRecorder) UpdateRemoteClusterInfo ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) UpdateRemoteClusterInfo(cluster, ackTaskID, ackTimestamp any) *gomock.Call
UpdateRemoteClusterInfo indicates an expected call of UpdateRemoteClusterInfo.
func (*MockControllableContextMockRecorder) UpdateRemoteReaderInfo ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) UpdateRemoteReaderInfo(readerID, ackTaskID, ackTimestamp any) *gomock.Call
UpdateRemoteReaderInfo indicates an expected call of UpdateRemoteReaderInfo.
func (*MockControllableContextMockRecorder) UpdateReplicationQueueReaderState ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) UpdateReplicationQueueReaderState(readerID, readerState any) *gomock.Call
UpdateReplicationQueueReaderState indicates an expected call of UpdateReplicationQueueReaderState.
func (*MockControllableContextMockRecorder) UpdateReplicatorDLQAckLevel ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) UpdateReplicatorDLQAckLevel(sourCluster, ackLevel any) *gomock.Call
UpdateReplicatorDLQAckLevel indicates an expected call of UpdateReplicatorDLQAckLevel.
func (*MockControllableContextMockRecorder) UpdateWorkflowExecution ¶ added in v1.21.5
func (mr *MockControllableContextMockRecorder) UpdateWorkflowExecution(ctx, request any) *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() []pingable.Check
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 any) *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 any) *gomock.Call
GetShardByID indicates an expected call of GetShardByID.
func (*MockControllerMockRecorder) GetShardByNamespaceWorkflow ¶ added in v1.17.3
func (mr *MockControllerMockRecorder) GetShardByNamespaceWorkflow(namespaceID, workflowID any) *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) 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) BackfillHistoryEvents ¶ added in v1.25.0
func (m *MockEngine) BackfillHistoryEvents(ctx context.Context, request *BackfillHistoryEventsRequest) error
BackfillHistoryEvents mocks base method.
func (*MockEngine) ConvertReplicationTask ¶ added in v1.21.0
func (m *MockEngine) ConvertReplicationTask(ctx context.Context, task tasks.Task, clusterID int32) (*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) ExecuteMultiOperation ¶ added in v1.24.0
func (m *MockEngine) ExecuteMultiOperation(ctx context.Context, request *historyservice.ExecuteMultiOperationRequest) (*historyservice.ExecuteMultiOperationResponse, error)
ExecuteMultiOperation mocks base method.
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) GetMaxReplicationTaskInfo ¶ added in v1.25.0
func (m *MockEngine) GetMaxReplicationTaskInfo() (int64, time.Time)
GetMaxReplicationTaskInfo 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) GetWorkflowExecutionRawHistory ¶ added in v1.24.0
func (m *MockEngine) GetWorkflowExecutionRawHistory(ctx context.Context, request *historyservice.GetWorkflowExecutionRawHistoryRequest) (*historyservice.GetWorkflowExecutionRawHistoryResponse, error)
GetWorkflowExecutionRawHistory 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) ListTasks ¶ added in v1.24.0
func (m *MockEngine) ListTasks(ctx context.Context, request *historyservice.ListTasksRequest) (*historyservice.ListTasksResponse, error)
ListTasks 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, newRunID string) error
ReplicateHistoryEvents mocks base method.
func (*MockEngine) ReplicateVersionedTransition ¶ added in v1.26.2
func (m *MockEngine) ReplicateVersionedTransition(ctx context.Context, artifact *repication.VersionedTransitionArtifact, sourceClusterName string) error
ReplicateVersionedTransition 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) StateMachineEnvironment ¶ added in v1.24.0
func (m *MockEngine) StateMachineEnvironment() hsm.Environment
StateMachineEnvironment mocks base method.
func (*MockEngine) SubscribeReplicationNotification ¶ added in v1.21.0
func (m *MockEngine) SubscribeReplicationNotification() (<-chan struct{}, string)
SubscribeReplicationNotification mocks base method.
func (*MockEngine) SyncActivities ¶ added in v1.24.0
func (m *MockEngine) SyncActivities(ctx context.Context, request *historyservice.SyncActivitiesRequest) error
SyncActivities mocks base method.
func (*MockEngine) SyncActivity ¶
func (m *MockEngine) SyncActivity(ctx context.Context, request *historyservice.SyncActivityRequest) error
SyncActivity mocks base method.
func (*MockEngine) SyncHSM ¶ added in v1.25.0
func (m *MockEngine) SyncHSM(ctx context.Context, request *SyncHSMRequest) error
SyncHSM mocks base method.
func (*MockEngine) SyncShardStatus ¶
func (m *MockEngine) SyncShardStatus(ctx context.Context, request *historyservice.SyncShardStatusRequest) error
SyncShardStatus mocks base method.
func (*MockEngine) SyncWorkflowState ¶ added in v1.26.0
func (m *MockEngine) SyncWorkflowState(ctx context.Context, request *historyservice.SyncWorkflowStateRequest) (*historyservice.SyncWorkflowStateResponse, error)
SyncWorkflowState 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 any) *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) AddTasks ¶ added in v1.23.0
func (mr *MockEngineMockRecorder) AddTasks(ctx, request any) *gomock.Call
AddTasks indicates an expected call of AddTasks.
func (*MockEngineMockRecorder) BackfillHistoryEvents ¶ added in v1.25.0
func (mr *MockEngineMockRecorder) BackfillHistoryEvents(ctx, request any) *gomock.Call
BackfillHistoryEvents indicates an expected call of BackfillHistoryEvents.
func (*MockEngineMockRecorder) ConvertReplicationTask ¶ added in v1.21.0
func (mr *MockEngineMockRecorder) ConvertReplicationTask(ctx, task, clusterID any) *gomock.Call
ConvertReplicationTask indicates an expected call of ConvertReplicationTask.
func (*MockEngineMockRecorder) DeleteWorkflowExecution ¶ added in v1.15.0
func (mr *MockEngineMockRecorder) DeleteWorkflowExecution(ctx, deleteRequest any) *gomock.Call
DeleteWorkflowExecution indicates an expected call of DeleteWorkflowExecution.
func (*MockEngineMockRecorder) DescribeMutableState ¶
func (mr *MockEngineMockRecorder) DescribeMutableState(ctx, request any) *gomock.Call
DescribeMutableState indicates an expected call of DescribeMutableState.
func (*MockEngineMockRecorder) DescribeWorkflowExecution ¶
func (mr *MockEngineMockRecorder) DescribeWorkflowExecution(ctx, request any) *gomock.Call
DescribeWorkflowExecution indicates an expected call of DescribeWorkflowExecution.
func (*MockEngineMockRecorder) ExecuteMultiOperation ¶ added in v1.24.0
func (mr *MockEngineMockRecorder) ExecuteMultiOperation(ctx, request any) *gomock.Call
ExecuteMultiOperation indicates an expected call of ExecuteMultiOperation.
func (*MockEngineMockRecorder) GenerateLastHistoryReplicationTasks ¶ added in v1.14.0
func (mr *MockEngineMockRecorder) GenerateLastHistoryReplicationTasks(ctx, request any) *gomock.Call
GenerateLastHistoryReplicationTasks indicates an expected call of GenerateLastHistoryReplicationTasks.
func (*MockEngineMockRecorder) GetDLQMessages ¶
func (mr *MockEngineMockRecorder) GetDLQMessages(ctx, messagesRequest any) *gomock.Call
GetDLQMessages indicates an expected call of GetDLQMessages.
func (*MockEngineMockRecorder) GetDLQReplicationMessages ¶
func (mr *MockEngineMockRecorder) GetDLQReplicationMessages(ctx, taskInfos any) *gomock.Call
GetDLQReplicationMessages indicates an expected call of GetDLQReplicationMessages.
func (*MockEngineMockRecorder) GetMaxReplicationTaskInfo ¶ added in v1.25.0
func (mr *MockEngineMockRecorder) GetMaxReplicationTaskInfo() *gomock.Call
GetMaxReplicationTaskInfo indicates an expected call of GetMaxReplicationTaskInfo.
func (*MockEngineMockRecorder) GetMutableState ¶
func (mr *MockEngineMockRecorder) GetMutableState(ctx, request any) *gomock.Call
GetMutableState indicates an expected call of GetMutableState.
func (*MockEngineMockRecorder) GetReplicationMessages ¶
func (mr *MockEngineMockRecorder) GetReplicationMessages(ctx, pollingCluster, ackMessageID, ackTimestamp, queryMessageID any) *gomock.Call
GetReplicationMessages indicates an expected call of GetReplicationMessages.
func (*MockEngineMockRecorder) GetReplicationStatus ¶ added in v1.14.0
func (mr *MockEngineMockRecorder) GetReplicationStatus(ctx, request any) *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 any) *gomock.Call
GetReplicationTasksIter indicates an expected call of GetReplicationTasksIter.
func (*MockEngineMockRecorder) GetWorkflowExecutionHistory ¶ added in v1.23.0
func (mr *MockEngineMockRecorder) GetWorkflowExecutionHistory(ctx, request any) *gomock.Call
GetWorkflowExecutionHistory indicates an expected call of GetWorkflowExecutionHistory.
func (*MockEngineMockRecorder) GetWorkflowExecutionHistoryReverse ¶ added in v1.23.0
func (mr *MockEngineMockRecorder) GetWorkflowExecutionHistoryReverse(ctx, request any) *gomock.Call
GetWorkflowExecutionHistoryReverse indicates an expected call of GetWorkflowExecutionHistoryReverse.
func (*MockEngineMockRecorder) GetWorkflowExecutionRawHistory ¶ added in v1.24.0
func (mr *MockEngineMockRecorder) GetWorkflowExecutionRawHistory(ctx, request any) *gomock.Call
GetWorkflowExecutionRawHistory indicates an expected call of GetWorkflowExecutionRawHistory.
func (*MockEngineMockRecorder) GetWorkflowExecutionRawHistoryV2 ¶ added in v1.23.0
func (mr *MockEngineMockRecorder) GetWorkflowExecutionRawHistoryV2(ctx, request any) *gomock.Call
GetWorkflowExecutionRawHistoryV2 indicates an expected call of GetWorkflowExecutionRawHistoryV2.
func (*MockEngineMockRecorder) ImportWorkflowExecution ¶ added in v1.23.0
func (mr *MockEngineMockRecorder) ImportWorkflowExecution(ctx, request any) *gomock.Call
ImportWorkflowExecution indicates an expected call of ImportWorkflowExecution.
func (*MockEngineMockRecorder) IsActivityTaskValid ¶ added in v1.22.0
func (mr *MockEngineMockRecorder) IsActivityTaskValid(ctx, request any) *gomock.Call
IsActivityTaskValid indicates an expected call of IsActivityTaskValid.
func (*MockEngineMockRecorder) IsWorkflowTaskValid ¶ added in v1.22.0
func (mr *MockEngineMockRecorder) IsWorkflowTaskValid(ctx, request any) *gomock.Call
IsWorkflowTaskValid indicates an expected call of IsWorkflowTaskValid.
func (*MockEngineMockRecorder) ListTasks ¶ added in v1.24.0
func (mr *MockEngineMockRecorder) ListTasks(ctx, request any) *gomock.Call
ListTasks indicates an expected call of ListTasks.
func (*MockEngineMockRecorder) MergeDLQMessages ¶
func (mr *MockEngineMockRecorder) MergeDLQMessages(ctx, messagesRequest any) *gomock.Call
MergeDLQMessages indicates an expected call of MergeDLQMessages.
func (*MockEngineMockRecorder) NotifyNewHistoryEvent ¶
func (mr *MockEngineMockRecorder) NotifyNewHistoryEvent(event any) *gomock.Call
NotifyNewHistoryEvent indicates an expected call of NotifyNewHistoryEvent.
func (*MockEngineMockRecorder) NotifyNewTasks ¶ added in v1.16.0
func (mr *MockEngineMockRecorder) NotifyNewTasks(tasks any) *gomock.Call
NotifyNewTasks indicates an expected call of NotifyNewTasks.
func (*MockEngineMockRecorder) PollMutableState ¶
func (mr *MockEngineMockRecorder) PollMutableState(ctx, request any) *gomock.Call
PollMutableState indicates an expected call of PollMutableState.
func (*MockEngineMockRecorder) PollWorkflowExecutionUpdate ¶ added in v1.21.0
func (mr *MockEngineMockRecorder) PollWorkflowExecutionUpdate(ctx, request any) *gomock.Call
PollWorkflowExecutionUpdate indicates an expected call of PollWorkflowExecutionUpdate.
func (*MockEngineMockRecorder) PurgeDLQMessages ¶
func (mr *MockEngineMockRecorder) PurgeDLQMessages(ctx, messagesRequest any) *gomock.Call
PurgeDLQMessages indicates an expected call of PurgeDLQMessages.
func (*MockEngineMockRecorder) QueryWorkflow ¶
func (mr *MockEngineMockRecorder) QueryWorkflow(ctx, request any) *gomock.Call
QueryWorkflow indicates an expected call of QueryWorkflow.
func (*MockEngineMockRecorder) ReapplyEvents ¶
func (mr *MockEngineMockRecorder) ReapplyEvents(ctx, namespaceUUID, workflowID, runID, events any) *gomock.Call
ReapplyEvents indicates an expected call of ReapplyEvents.
func (*MockEngineMockRecorder) RebuildMutableState ¶ added in v1.16.0
func (mr *MockEngineMockRecorder) RebuildMutableState(ctx, namespaceUUID, execution any) *gomock.Call
RebuildMutableState indicates an expected call of RebuildMutableState.
func (*MockEngineMockRecorder) RecordActivityTaskHeartbeat ¶
func (mr *MockEngineMockRecorder) RecordActivityTaskHeartbeat(ctx, request any) *gomock.Call
RecordActivityTaskHeartbeat indicates an expected call of RecordActivityTaskHeartbeat.
func (*MockEngineMockRecorder) RecordActivityTaskStarted ¶
func (mr *MockEngineMockRecorder) RecordActivityTaskStarted(ctx, request any) *gomock.Call
RecordActivityTaskStarted indicates an expected call of RecordActivityTaskStarted.
func (*MockEngineMockRecorder) RecordChildExecutionCompleted ¶
func (mr *MockEngineMockRecorder) RecordChildExecutionCompleted(ctx, request any) *gomock.Call
RecordChildExecutionCompleted indicates an expected call of RecordChildExecutionCompleted.
func (*MockEngineMockRecorder) RecordWorkflowTaskStarted ¶
func (mr *MockEngineMockRecorder) RecordWorkflowTaskStarted(ctx, request any) *gomock.Call
RecordWorkflowTaskStarted indicates an expected call of RecordWorkflowTaskStarted.
func (*MockEngineMockRecorder) RefreshWorkflowTasks ¶
func (mr *MockEngineMockRecorder) RefreshWorkflowTasks(ctx, namespaceUUID, execution any) *gomock.Call
RefreshWorkflowTasks indicates an expected call of RefreshWorkflowTasks.
func (*MockEngineMockRecorder) RemoveSignalMutableState ¶
func (mr *MockEngineMockRecorder) RemoveSignalMutableState(ctx, request any) *gomock.Call
RemoveSignalMutableState indicates an expected call of RemoveSignalMutableState.
func (*MockEngineMockRecorder) ReplicateEventsV2 ¶
func (mr *MockEngineMockRecorder) ReplicateEventsV2(ctx, request any) *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, newRunID any) *gomock.Call
ReplicateHistoryEvents indicates an expected call of ReplicateHistoryEvents.
func (*MockEngineMockRecorder) ReplicateVersionedTransition ¶ added in v1.26.2
func (mr *MockEngineMockRecorder) ReplicateVersionedTransition(ctx, artifact, sourceClusterName any) *gomock.Call
ReplicateVersionedTransition indicates an expected call of ReplicateVersionedTransition.
func (*MockEngineMockRecorder) ReplicateWorkflowState ¶ added in v1.17.0
func (mr *MockEngineMockRecorder) ReplicateWorkflowState(ctx, request any) *gomock.Call
ReplicateWorkflowState indicates an expected call of ReplicateWorkflowState.
func (*MockEngineMockRecorder) RequestCancelWorkflowExecution ¶
func (mr *MockEngineMockRecorder) RequestCancelWorkflowExecution(ctx, request any) *gomock.Call
RequestCancelWorkflowExecution indicates an expected call of RequestCancelWorkflowExecution.
func (*MockEngineMockRecorder) ResetStickyTaskQueue ¶
func (mr *MockEngineMockRecorder) ResetStickyTaskQueue(ctx, resetRequest any) *gomock.Call
ResetStickyTaskQueue indicates an expected call of ResetStickyTaskQueue.
func (*MockEngineMockRecorder) ResetWorkflowExecution ¶
func (mr *MockEngineMockRecorder) ResetWorkflowExecution(ctx, request any) *gomock.Call
ResetWorkflowExecution indicates an expected call of ResetWorkflowExecution.
func (*MockEngineMockRecorder) RespondActivityTaskCanceled ¶
func (mr *MockEngineMockRecorder) RespondActivityTaskCanceled(ctx, request any) *gomock.Call
RespondActivityTaskCanceled indicates an expected call of RespondActivityTaskCanceled.
func (*MockEngineMockRecorder) RespondActivityTaskCompleted ¶
func (mr *MockEngineMockRecorder) RespondActivityTaskCompleted(ctx, request any) *gomock.Call
RespondActivityTaskCompleted indicates an expected call of RespondActivityTaskCompleted.
func (*MockEngineMockRecorder) RespondActivityTaskFailed ¶
func (mr *MockEngineMockRecorder) RespondActivityTaskFailed(ctx, request any) *gomock.Call
RespondActivityTaskFailed indicates an expected call of RespondActivityTaskFailed.
func (*MockEngineMockRecorder) RespondWorkflowTaskCompleted ¶
func (mr *MockEngineMockRecorder) RespondWorkflowTaskCompleted(ctx, request any) *gomock.Call
RespondWorkflowTaskCompleted indicates an expected call of RespondWorkflowTaskCompleted.
func (*MockEngineMockRecorder) RespondWorkflowTaskFailed ¶
func (mr *MockEngineMockRecorder) RespondWorkflowTaskFailed(ctx, request any) *gomock.Call
RespondWorkflowTaskFailed indicates an expected call of RespondWorkflowTaskFailed.
func (*MockEngineMockRecorder) ScheduleWorkflowTask ¶
func (mr *MockEngineMockRecorder) ScheduleWorkflowTask(ctx, request any) *gomock.Call
ScheduleWorkflowTask indicates an expected call of ScheduleWorkflowTask.
func (*MockEngineMockRecorder) SignalWithStartWorkflowExecution ¶
func (mr *MockEngineMockRecorder) SignalWithStartWorkflowExecution(ctx, request any) *gomock.Call
SignalWithStartWorkflowExecution indicates an expected call of SignalWithStartWorkflowExecution.
func (*MockEngineMockRecorder) SignalWorkflowExecution ¶
func (mr *MockEngineMockRecorder) SignalWorkflowExecution(ctx, request any) *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 any) *gomock.Call
StartWorkflowExecution indicates an expected call of StartWorkflowExecution.
func (*MockEngineMockRecorder) StateMachineEnvironment ¶ added in v1.24.0
func (mr *MockEngineMockRecorder) StateMachineEnvironment() *gomock.Call
StateMachineEnvironment indicates an expected call of StateMachineEnvironment.
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) SyncActivities ¶ added in v1.24.0
func (mr *MockEngineMockRecorder) SyncActivities(ctx, request any) *gomock.Call
SyncActivities indicates an expected call of SyncActivities.
func (*MockEngineMockRecorder) SyncActivity ¶
func (mr *MockEngineMockRecorder) SyncActivity(ctx, request any) *gomock.Call
SyncActivity indicates an expected call of SyncActivity.
func (*MockEngineMockRecorder) SyncHSM ¶ added in v1.25.0
func (mr *MockEngineMockRecorder) SyncHSM(ctx, request any) *gomock.Call
SyncHSM indicates an expected call of SyncHSM.
func (*MockEngineMockRecorder) SyncShardStatus ¶
func (mr *MockEngineMockRecorder) SyncShardStatus(ctx, request any) *gomock.Call
SyncShardStatus indicates an expected call of SyncShardStatus.
func (*MockEngineMockRecorder) SyncWorkflowState ¶ added in v1.26.0
func (mr *MockEngineMockRecorder) SyncWorkflowState(ctx, request any) *gomock.Call
SyncWorkflowState indicates an expected call of SyncWorkflowState.
func (*MockEngineMockRecorder) TerminateWorkflowExecution ¶
func (mr *MockEngineMockRecorder) TerminateWorkflowExecution(ctx, request any) *gomock.Call
TerminateWorkflowExecution indicates an expected call of TerminateWorkflowExecution.
func (*MockEngineMockRecorder) UnsubscribeReplicationNotification ¶ added in v1.21.0
func (mr *MockEngineMockRecorder) UnsubscribeReplicationNotification(arg0 any) *gomock.Call
UnsubscribeReplicationNotification indicates an expected call of UnsubscribeReplicationNotification.
func (*MockEngineMockRecorder) UpdateWorkflowExecution ¶ added in v1.20.0
func (mr *MockEngineMockRecorder) UpdateWorkflowExecution(ctx, request any) *gomock.Call
UpdateWorkflowExecution indicates an expected call of UpdateWorkflowExecution.
func (*MockEngineMockRecorder) VerifyChildExecutionCompletionRecorded ¶ added in v1.17.0
func (mr *MockEngineMockRecorder) VerifyChildExecutionCompletionRecorded(ctx, request any) *gomock.Call
VerifyChildExecutionCompletionRecorded indicates an expected call of VerifyChildExecutionCompletionRecorded.
func (*MockEngineMockRecorder) VerifyFirstWorkflowTaskScheduled ¶ added in v1.17.0
func (mr *MockEngineMockRecorder) VerifyFirstWorkflowTaskScheduled(ctx, request any) *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, clusterID int32) (*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) GetMaxReplicationTaskInfo ¶ added in v1.25.0
func (m *MockReplicationStream) GetMaxReplicationTaskInfo() (int64, time.Time)
GetMaxReplicationTaskInfo mocks base method.
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, clusterID any) *gomock.Call
ConvertReplicationTask indicates an expected call of ConvertReplicationTask.
func (*MockReplicationStreamMockRecorder) GetMaxReplicationTaskInfo ¶ added in v1.25.0
func (mr *MockReplicationStreamMockRecorder) GetMaxReplicationTaskInfo() *gomock.Call
GetMaxReplicationTaskInfo indicates an expected call of GetMaxReplicationTaskInfo.
func (*MockReplicationStreamMockRecorder) GetReplicationTasksIter ¶ added in v1.21.0
func (mr *MockReplicationStreamMockRecorder) GetReplicationTasksIter(ctx, pollingCluster, minInclusiveTaskID, maxExclusiveTaskID any) *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 any) *gomock.Call
UnsubscribeReplicationNotification indicates an expected call of UnsubscribeReplicationNotification.
type OwnershipAwareNamespaceQuotaCalculator ¶ added in v1.23.0
type OwnershipAwareNamespaceQuotaCalculator struct { calculator.ClusterAwareNamespaceQuotaCalculator // contains filtered or unexported fields }
func NewOwnershipAwareNamespaceQuotaCalculator ¶ added in v1.23.0
func NewOwnershipAwareNamespaceQuotaCalculator( scaler OwnershipBasedQuotaScaler, memberCounter calculator.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 { calculator.ClusterAwareQuotaCalculator // contains filtered or unexported fields }
func NewOwnershipAwareQuotaCalculator ¶ added in v1.23.0
func NewOwnershipAwareQuotaCalculator( scaler OwnershipBasedQuotaScaler, memberCounter calculator.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, clusterID int32, ) (*replicationspb.ReplicationTask, error) GetReplicationTasksIter( ctx context.Context, pollingCluster string, minInclusiveTaskID int64, maxExclusiveTaskID int64, ) (collection.Iterator[tasks.Task], error) GetMaxReplicationTaskInfo() (int64, time.Time) }
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.
type StubContext ¶ added in v1.24.0
type StubContext struct { ContextTest // contains filtered or unexported fields }
func NewStubContext ¶ added in v1.24.0
func NewStubContext( ctrl *gomock.Controller, overrides ContextConfigOverrides, engine Engine, ) *StubContext
type SyncHSMRequest ¶ added in v1.25.0
type SyncHSMRequest struct { definition.WorkflowKey StateMachineNode *persistencespb.StateMachineNode EventVersionHistory *historyspb.VersionHistory }
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