Package client is a generated GoMock package.

Package nosql is a generated GoMock package.

Package serialization is a generated GoMock package.

BuildHistoryGarbageCleanupInfo combine the workflow identity information into a string.

DBTimestampToUnixNano converts Milliseconds timestamp to UnixNano.

DeserializeClusterConfigs creates an array of ClusterReplicationConfigs from an array of map representations.

FromDataBlob decodes a datablob into a (payload, encodingType) tuple.

FromInternalWorkflowExecutionCloseStatus convert internal representation of close status to persistence representation.

HasMoreRowsToDelete checks if there is more data need to be deleted.

IsBackgroundTransientError checks if the error is a transient error on background jobs.

IsNopUpsertWorkflowRequest return whether upsert request should be no-op.

IsTimeoutError check whether error is TimeoutError.

IsTransientError checks if the error is a transient persistence error.

NewCadenceDeserializationError returns a CadenceDeserializationError.

NewCadenceSerializationError returns a CadenceSerializationError.

NewConfigStoreManagerImpl returns new ConfigStoreManager.

NewDataBlob returns a new DataBlob.

NewDataBlobFromInternal convert data blob from internal representation.

NewDomainManagerImpl returns new DomainManager.

NewDynamicConfiguration returns new config with default values.

NewExecutionManagerImpl returns new ExecutionManager.

NewGetReplicationTasksFromDLQRequest creates a new GetReplicationTasksFromDLQRequest.

NewHistoryBranchToken return a new branch token.

NewHistoryBranchTokenByBranchID return a new branch token with treeID/branchID.

NewHistoryBranchTokenFromAnother make up a branchToken.

NewHistoryV2ManagerImpl returns new HistoryManager.

NewMockConfigStore creates a new mock instance.

NewMockConfigStoreManager creates a new mock instance.

NewMockDomainManager creates a new mock instance.

NewMockDomainStore creates a new mock instance.

NewMockExecutionManager creates a new mock instance.

NewMockExecutionManagerFactory creates a new mock instance.

NewMockExecutionStore creates a new mock instance.

NewMockHistoryManager creates a new mock instance.

NewMockHistoryStore creates a new mock instance.

NewMockPayloadSerializer creates a new mock instance.

NewMockQueueManager creates a new mock instance.

NewMockRetryer creates a new mock instance.

NewMockShardManager creates a new mock instance.

NewMockShardStore creates a new mock instance.

NewMockTask creates a new mock instance.

NewMockTaskManager creates a new mock instance.

NewMockTaskStore creates a new mock instance.

NewMockVisibilityManager creates a new mock instance.

NewMockVisibilityStore creates a new mock instance.

NewPayloadSerializer returns a PayloadSerializer.

NewPersistenceRetryer constructs a new Retryer.

NewQueueManager returns a new QueueManager.

NewShardManager returns a new ShardManager.

NewTaskManager returns a new TaskManager.

NewUnknownEncodingTypeError returns a new instance of encoding type error.

NewVersionHistories create a new version histories.

NewVersionHistoriesFromInternalType create a new version histories from internal type object.

NewVersionHistory create a new version history.

NewVersionHistoryFromInternalType create a new version history from internal type object.

NewVersionHistoryItem create a new version history item.

NewVersionHistoryItemFromInternalType create a new version history item from internal type object.

NewVisibilityTripleManager create a visibility manager that operate on DB or advanced visibility based on dynamic config.

NewVisibilityManagerImpl returns new VisibilityManager via a VisibilityStore.

SerializeClusterConfigs makes an array of *ClusterReplicationConfig serializable by flattening them into map[string]interface{}.

SplitHistoryGarbageCleanupInfo returns workflow identity information.

ToInternalWorkflowExecutionCloseStatus convert persistence representation of close status to internal representation.

UnixNanoToDBTimestamp converts UnixNano to Milliseconds timestamp.

ValidateConflictResolveWorkflowModeState validate workflow conflict resolve mode & workflow state.

ValidateCreateWorkflowModeState validate workflow creation mode & workflow state.

ValidateCreateWorkflowStateCloseStatus validate workflow state and close status.

ValidateUpdateWorkflowModeState validate workflow update mode & workflow state.

ValidateUpdateWorkflowStateCloseStatus validate workflow state and close status.

Conflict resolve workflow, without current record NOTE: current record CANNOT point to the workflow to be updated.

Conflict resolve workflow, including current record NOTE: update on current record is a condition update.

Fail if current record exists Only applicable for CreateWorkflowExecution.

Update current record only if workflow is open Only applicable for UpdateWorkflowExecution.

Update current record only if workflow is closed Only applicable for CreateWorkflowExecution.

Do not update current record since workflow to applicable for CreateWorkflowExecution, UpdateWorkflowExecution.

Fail if data with the same domain_id, workflow_id, request_id exists It is used for transactions started by external API requests to allow us detecting duplicate requests.

Upsert the data without checking duplication It is used for transactions started by replication stack to achieve eventual consistency.

Deprecated: This is deprecated as of May 24 CrossClusterTaskDefaultTargetRunID is the the dummy run ID for cross-cluster tasks of types that do not have a target workflow.

Deprecated: Types of cross-cluster tasks.

Deprecated: Types of cross-cluster tasks.

Deprecated: Types of cross-cluster tasks.

Deprecated: Types of cross-cluster tasks.

Deprecated: Types of cross-cluster tasks.

Queue types used in queue table Use positive numbers for queue type Negative numbers are reserved for DLQ.

Domain status.

Domain status.

Domain status.

EventStoreVersion is already deprecated, this is used for forward compatibility (so that rollback is possible).

InitialFailoverNotificationVersion is the initial failover version for a domain.

Types of replication tasks.

Types of replication tasks.

Types of replication tasks.

Kinds of task lists.

Kinds of task lists.

Types of task lists.

Types of task lists.

Types of timers.

Types of timers.

Types of timers.

Types of timers.

Types of timers.

Types of timers.

Types of timers.

TransferTaskTransferTargetRunID is the the dummy run ID for transfer tasks of types that do not have a target workflow.

TransferTaskTransferTargetWorkflowID is the the dummy workflow ID for transfer tasks of types that do not have a target workflow.

Transfer task types.

Transfer task types.

Transfer task types.

Transfer task types.

Transfer task types.

Transfer task types.

Transfer task types.

Transfer task types.

Transfer task types.

Transfer task types.

Transfer task types.

Transfer task types.

UnknownNumRowsAffected is returned when the number of rows that an API affected cannot be determined.

Update workflow, without current record NOTE: current record CANNOT point to the workflow to be updated.

Update workflow, ignoring current record NOTE: current record may or may not point to the workflow this mode should only be used for (re-)generating workflow tasks and there's no other changes to the workflow.

Update workflow, including current record NOTE: update on current record is a condition update.

VisibilityEncoding is default encoding for visibility data.

Types of workflow backoff timeout.

Types of workflow backoff timeout.

Workflow execution close status.

Workflow execution close status.

Workflow execution close status.

Workflow execution close status.

Workflow execution close status.

Workflow execution close status.

Workflow execution close status.

Types of workflow requests.

Types of workflow requests.

Types of workflow requests.

Types of workflow requests.

Workflow execution states.

Workflow execution states.

Workflow execution states.

Workflow execution states.

Workflow execution states.

Workflow execution states.

ErrVisibilityOperationNotSupported is an error which indicates that operation is not supported in selected persistence.

HistoryTaskCategory represents various categories of history tasks.

MockConfigStore is a mock of ConfigStore interface.

MockConfigStoreManager is a mock of ConfigStoreManager interface.

MockConfigStoreManagerMockRecorder is the mock recorder for MockConfigStoreManager.

MockConfigStoreMockRecorder is the mock recorder for MockConfigStore.

MockDomainManager is a mock of DomainManager interface.

MockDomainManagerMockRecorder is the mock recorder for MockDomainManager.

MockDomainStore is a mock of DomainStore interface.

MockDomainStoreMockRecorder is the mock recorder for MockDomainStore.

MockExecutionManager is a mock of ExecutionManager interface.

MockExecutionManagerFactory is a mock of ExecutionManagerFactory interface.

MockExecutionManagerFactoryMockRecorder is the mock recorder for MockExecutionManagerFactory.

MockExecutionManagerMockRecorder is the mock recorder for MockExecutionManager.

MockExecutionStore is a mock of ExecutionStore interface.

MockExecutionStoreMockRecorder is the mock recorder for MockExecutionStore.

MockHistoryManager is a mock of HistoryManager interface.

MockHistoryManagerMockRecorder is the mock recorder for MockHistoryManager.

MockHistoryStore is a mock of HistoryStore interface.

MockHistoryStoreMockRecorder is the mock recorder for MockHistoryStore.

MockPayloadSerializer is a mock of PayloadSerializer interface.

MockPayloadSerializerMockRecorder is the mock recorder for MockPayloadSerializer.

MockQueueManager is a mock of QueueManager interface.

MockQueueManagerMockRecorder is the mock recorder for MockQueueManager.

MockRetryer is a mock of Retryer interface.

MockRetryerMockRecorder is the mock recorder for MockRetryer.

MockShardManager is a mock of ShardManager interface.

MockShardManagerMockRecorder is the mock recorder for MockShardManager.

MockShardStore is a mock of ShardStore interface.

MockShardStoreMockRecorder is the mock recorder for MockShardStore.

MockTask is a mock of Task interface.

MockTaskManager is a mock of TaskManager interface.

MockTaskManagerMockRecorder is the mock recorder for MockTaskManager.

MockTaskMockRecorder is the mock recorder for MockTask.

MockTaskStore is a mock of TaskStore interface.

MockTaskStoreMockRecorder is the mock recorder for MockTaskStore.

MockVisibilityManager is a mock of VisibilityManager interface.

MockVisibilityManagerMockRecorder is the mock recorder for MockVisibilityManager.

MockVisibilityStore is a mock of VisibilityStore interface.

MockVisibilityStoreMockRecorder is the mock recorder for MockVisibilityStore.

Retryer is used to retry requests to persistence with provided retry policy.

Task is the generic interface for workflow tasks.

ConflictResolveWorkflowMode conflict resolve mode.

CreateWorkflowMode workflow creation mode.

CreateWorkflowRequestMode is the mode of create workflow request.

QueueType is an enum that represents various queue types in persistence.

ResponseComparatorContextKey is for Pinot/ES response comparator.

UpdateWorkflowMode update mode.

WorkflowRequestType is the type of workflow request.