Documentation
¶
Overview ¶
Package persistence is a generated GoMock package.
Package persistence is a generated GoMock package.
Package persistence is a generated GoMock package.
Package persistence is a generated GoMock package.
Package persistence is a generated GoMock package.
Package persistence is a generated GoMock package.
Index ¶
- Constants
- Variables
- func BuildHistoryGarbageCleanupInfo(domainID, workflowID, runID string) string
- func DBTimestampToUnixNano(milliseconds int64) int64
- func FromDataBlob(blob *DataBlob) ([]byte, string)
- func FromInternalWorkflowExecutionCloseStatus(closeStatus *types.WorkflowExecutionCloseStatus) int
- func HasMoreRowsToDelete(rowsDeleted, batchSize int) bool
- func IsBackgroundTransientError(err error) bool
- func IsNopUpsertWorkflowRequest(request *InternalUpsertWorkflowExecutionRequest) bool
- func IsTimeoutError(err error) bool
- func IsTransientError(err error) bool
- func NewHistoryBranchToken(treeID string) ([]byte, error)
- func NewHistoryBranchTokenByBranchID(treeID, branchID string) ([]byte, error)
- func NewHistoryBranchTokenFromAnother(branchID string, anotherToken []byte) ([]byte, error)
- func NewUnknownEncodingTypeError(encodingType common.EncodingType) error
- func SerializeClusterConfigs(replicationConfigs []*ClusterReplicationConfig) []map[string]interface{}
- func SplitHistoryGarbageCleanupInfo(info string) (domainID, workflowID, runID string, err error)
- func ToInternalWorkflowExecutionCloseStatus(closeStatus int) *types.WorkflowExecutionCloseStatus
- func UnixNanoToDBTimestamp(timestamp int64) int64
- func ValidateConflictResolveWorkflowModeState(mode ConflictResolveWorkflowMode, ...) error
- func ValidateCreateWorkflowModeState(mode CreateWorkflowMode, newWorkflowSnapshot InternalWorkflowSnapshot) error
- func ValidateCreateWorkflowStateCloseStatus(state int, closeStatus int) error
- func ValidateUpdateWorkflowModeState(mode UpdateWorkflowMode, currentWorkflowMutation InternalWorkflowMutation, ...) error
- func ValidateUpdateWorkflowStateCloseStatus(state int, closeStatus int) error
- type ActivityInfo
- type ActivityRetryTimerTask
- type ActivityTask
- type ActivityTimeoutTask
- type AppendHistoryNodesRequest
- type AppendHistoryNodesResponse
- type ApplyParentClosePolicyTask
- type CadenceDeserializationError
- type CadenceSerializationError
- type CancelExecutionTask
- type ChildExecutionInfo
- type CloseExecutionTask
- type Closeable
- type ClusterReplicationConfig
- type CompleteCrossClusterTaskRequest
- type CompleteForkBranchRequest
- type CompleteReplicationTaskRequest
- type CompleteTaskRequest
- type CompleteTasksLessThanRequest
- type CompleteTasksLessThanResponse
- type CompleteTimerTaskRequest
- type CompleteTransferTaskRequest
- type ConditionFailedError
- type ConfigStore
- type ConfigStoreManager
- type ConfigType
- type ConflictResolveWorkflowExecutionRequest
- type ConflictResolveWorkflowExecutionResponse
- type ConflictResolveWorkflowMode
- type CountWorkflowExecutionsRequest
- type CountWorkflowExecutionsResponse
- type CreateDomainRequest
- type CreateDomainResponse
- type CreateFailoverMarkersRequest
- type CreateShardRequest
- type CreateTaskInfo
- type CreateTasksRequest
- type CreateTasksResponse
- type CreateWorkflowExecutionRequest
- type CreateWorkflowExecutionResponse
- type CreateWorkflowMode
- type CreateWorkflowRequestMode
- type CrossClusterApplyParentClosePolicyTask
- type CrossClusterCancelExecutionTask
- type CrossClusterRecordChildExecutionCompletedTask
- type CrossClusterSignalExecutionTask
- type CrossClusterStartChildExecutionTask
- type CrossClusterTaskInfo
- type CurrentWorkflowConditionFailedError
- type CurrentWorkflowExecution
- type DBUnavailableError
- type DataBlob
- type DecisionTask
- type DecisionTimeoutTask
- type DeleteCurrentWorkflowExecutionRequest
- type DeleteDomainByNameRequest
- type DeleteDomainRequest
- type DeleteHistoryBranchRequest
- type DeleteHistoryEventTask
- type DeleteReplicationTaskFromDLQRequest
- type DeleteTaskListRequest
- type DeleteWorkflowExecutionRequest
- type DomainConfig
- type DomainInfo
- type DomainManager
- type DomainReplicationConfig
- type DomainStore
- type DuplicateRequestError
- type DynamicConfigSnapshot
- type DynamicConfiguration
- type ExecutionManager
- type ExecutionManagerFactory
- type ExecutionStats
- type ExecutionStore
- type FailoverMarkerTask
- type FetchDynamicConfigResponse
- type ForkHistoryBranchRequest
- type ForkHistoryBranchResponse
- type GetAllHistoryTreeBranchesRequest
- type GetAllHistoryTreeBranchesResponse
- type GetClosedWorkflowExecutionRequest
- type GetClosedWorkflowExecutionResponse
- type GetCrossClusterTasksRequest
- type GetCrossClusterTasksResponse
- type GetCurrentExecutionRequest
- type GetCurrentExecutionResponse
- type GetDomainRequest
- type GetDomainResponse
- type GetHistoryTreeRequest
- type GetHistoryTreeResponse
- type GetMetadataResponse
- type GetOrphanTasksRequest
- type GetOrphanTasksResponse
- type GetReplicationDLQSizeRequest
- type GetReplicationDLQSizeResponse
- type GetReplicationTasksFromDLQRequest
- type GetReplicationTasksFromDLQResponse
- type GetReplicationTasksRequest
- type GetReplicationTasksResponse
- type GetShardRequest
- type GetShardResponse
- type GetTaskListSizeRequest
- type GetTaskListSizeResponse
- type GetTasksRequest
- type GetTasksResponse
- type GetTimerIndexTasksRequest
- type GetTimerIndexTasksResponse
- type GetTransferTasksRequest
- type GetTransferTasksResponse
- type GetWorkflowExecutionRequest
- type GetWorkflowExecutionResponse
- type HistoryBranchDetail
- type HistoryManager
- type HistoryReplicationTask
- type HistoryStore
- type InternalActivityInfo
- type InternalAppendHistoryEventsRequest
- type InternalAppendHistoryNodesRequest
- type InternalChildExecutionInfo
- type InternalCompleteForkBranchRequest
- type InternalConfigStoreEntry
- type InternalConflictResolveWorkflowExecutionRequest
- type InternalCreateDomainRequest
- type InternalCreateShardRequest
- type InternalCreateTasksInfo
- type InternalCreateTasksRequest
- type InternalCreateWorkflowExecutionRequest
- type InternalDeleteHistoryBranchRequest
- type InternalDomainConfig
- type InternalForkHistoryBranchRequest
- type InternalForkHistoryBranchResponse
- type InternalGetClosedWorkflowExecutionRequest
- type InternalGetClosedWorkflowExecutionResponse
- type InternalGetDomainResponse
- type InternalGetHistoryTreeRequest
- type InternalGetHistoryTreeResponse
- type InternalGetReplicationTasksFromDLQResponse
- type InternalGetReplicationTasksResponse
- type InternalGetShardRequest
- type InternalGetShardResponse
- type InternalGetTasksResponse
- type InternalGetWorkflowExecutionRequest
- type InternalGetWorkflowExecutionResponse
- type InternalListAllWorkflowExecutionsByTypeRequest
- type InternalListClosedWorkflowExecutionsByStatusRequest
- type InternalListConcreteExecutionsEntity
- type InternalListConcreteExecutionsResponse
- type InternalListDomainsResponse
- type InternalListWorkflowExecutionsByTypeRequest
- type InternalListWorkflowExecutionsByWorkflowIDRequest
- type InternalListWorkflowExecutionsRequest
- type InternalListWorkflowExecutionsResponse
- type InternalPutReplicationTaskToDLQRequest
- type InternalQueueMessage
- type InternalReadHistoryBranchRequest
- type InternalReadHistoryBranchResponse
- type InternalRecordWorkflowExecutionClosedRequest
- type InternalRecordWorkflowExecutionStartedRequest
- type InternalRecordWorkflowExecutionUninitializedRequest
- type InternalReplicationTaskInfo
- type InternalShardInfo
- type InternalTaskInfo
- type InternalUpdateDomainRequest
- type InternalUpdateShardRequest
- type InternalUpdateWorkflowExecutionRequest
- type InternalUpsertWorkflowExecutionRequest
- type InternalVisibilityWorkflowExecutionInfo
- type InternalWorkflowExecutionInfo
- type InternalWorkflowMutableState
- type InternalWorkflowMutation
- type InternalWorkflowSnapshot
- type InvalidPersistenceRequestError
- type IsWorkflowExecutionExistsRequest
- type IsWorkflowExecutionExistsResponse
- type LeaseTaskListRequest
- type LeaseTaskListResponse
- type ListAllWorkflowExecutionsRequest
- type ListClosedWorkflowExecutionsByStatusRequest
- type ListConcreteExecutionsEntity
- type ListConcreteExecutionsRequest
- type ListConcreteExecutionsResponse
- type ListCurrentExecutionsRequest
- type ListCurrentExecutionsResponse
- type ListDomainsRequest
- type ListDomainsResponse
- type ListTaskListRequest
- type ListTaskListResponse
- type ListWorkflowExecutionsByQueryRequest
- type ListWorkflowExecutionsByTypeRequest
- type ListWorkflowExecutionsByWorkflowIDRequest
- type ListWorkflowExecutionsRequest
- type ListWorkflowExecutionsResponse
- type MockConfigStoreManager
- func (m *MockConfigStoreManager) Close()
- func (m *MockConfigStoreManager) EXPECT() *MockConfigStoreManagerMockRecorder
- func (m *MockConfigStoreManager) FetchDynamicConfig(arg0 context.Context, arg1 ConfigType) (*FetchDynamicConfigResponse, error)
- func (m *MockConfigStoreManager) UpdateDynamicConfig(arg0 context.Context, arg1 *UpdateDynamicConfigRequest, arg2 ConfigType) error
- type MockConfigStoreManagerMockRecorder
- type MockDomainManager
- func (m *MockDomainManager) Close()
- func (m *MockDomainManager) CreateDomain(arg0 context.Context, arg1 *CreateDomainRequest) (*CreateDomainResponse, error)
- func (m *MockDomainManager) DeleteDomain(arg0 context.Context, arg1 *DeleteDomainRequest) error
- func (m *MockDomainManager) DeleteDomainByName(arg0 context.Context, arg1 *DeleteDomainByNameRequest) error
- func (m *MockDomainManager) EXPECT() *MockDomainManagerMockRecorder
- func (m *MockDomainManager) GetDomain(arg0 context.Context, arg1 *GetDomainRequest) (*GetDomainResponse, error)
- func (m *MockDomainManager) GetMetadata(arg0 context.Context) (*GetMetadataResponse, error)
- func (m *MockDomainManager) GetName() string
- func (m *MockDomainManager) ListDomains(arg0 context.Context, arg1 *ListDomainsRequest) (*ListDomainsResponse, error)
- func (m *MockDomainManager) UpdateDomain(arg0 context.Context, arg1 *UpdateDomainRequest) error
- type MockDomainManagerMockRecorder
- func (mr *MockDomainManagerMockRecorder) Close() *gomock.Call
- func (mr *MockDomainManagerMockRecorder) CreateDomain(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockDomainManagerMockRecorder) DeleteDomain(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockDomainManagerMockRecorder) DeleteDomainByName(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockDomainManagerMockRecorder) GetDomain(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockDomainManagerMockRecorder) GetMetadata(arg0 interface{}) *gomock.Call
- func (mr *MockDomainManagerMockRecorder) GetName() *gomock.Call
- func (mr *MockDomainManagerMockRecorder) ListDomains(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockDomainManagerMockRecorder) UpdateDomain(arg0, arg1 interface{}) *gomock.Call
- type MockExecutionManager
- func (m *MockExecutionManager) Close()
- func (m *MockExecutionManager) CompleteCrossClusterTask(arg0 context.Context, arg1 *CompleteCrossClusterTaskRequest) error
- func (m *MockExecutionManager) CompleteReplicationTask(arg0 context.Context, arg1 *CompleteReplicationTaskRequest) error
- func (m *MockExecutionManager) CompleteTimerTask(arg0 context.Context, arg1 *CompleteTimerTaskRequest) error
- func (m *MockExecutionManager) CompleteTransferTask(arg0 context.Context, arg1 *CompleteTransferTaskRequest) error
- func (m *MockExecutionManager) ConflictResolveWorkflowExecution(arg0 context.Context, arg1 *ConflictResolveWorkflowExecutionRequest) (*ConflictResolveWorkflowExecutionResponse, error)
- func (m *MockExecutionManager) CreateFailoverMarkerTasks(arg0 context.Context, arg1 *CreateFailoverMarkersRequest) error
- func (m *MockExecutionManager) CreateWorkflowExecution(arg0 context.Context, arg1 *CreateWorkflowExecutionRequest) (*CreateWorkflowExecutionResponse, error)
- func (m *MockExecutionManager) DeleteCurrentWorkflowExecution(arg0 context.Context, arg1 *DeleteCurrentWorkflowExecutionRequest) error
- func (m *MockExecutionManager) DeleteReplicationTaskFromDLQ(arg0 context.Context, arg1 *DeleteReplicationTaskFromDLQRequest) error
- func (m *MockExecutionManager) DeleteWorkflowExecution(arg0 context.Context, arg1 *DeleteWorkflowExecutionRequest) error
- func (m *MockExecutionManager) EXPECT() *MockExecutionManagerMockRecorder
- func (m *MockExecutionManager) GetCrossClusterTasks(arg0 context.Context, arg1 *GetCrossClusterTasksRequest) (*GetCrossClusterTasksResponse, error)
- func (m *MockExecutionManager) GetCurrentExecution(arg0 context.Context, arg1 *GetCurrentExecutionRequest) (*GetCurrentExecutionResponse, error)
- func (m *MockExecutionManager) GetName() string
- func (m *MockExecutionManager) GetReplicationDLQSize(arg0 context.Context, arg1 *GetReplicationDLQSizeRequest) (*GetReplicationDLQSizeResponse, error)
- func (m *MockExecutionManager) GetReplicationTasks(arg0 context.Context, arg1 *GetReplicationTasksRequest) (*GetReplicationTasksResponse, error)
- func (m *MockExecutionManager) GetReplicationTasksFromDLQ(arg0 context.Context, arg1 *GetReplicationTasksFromDLQRequest) (*GetReplicationTasksResponse, error)
- func (m *MockExecutionManager) GetShardID() int
- func (m *MockExecutionManager) GetTimerIndexTasks(arg0 context.Context, arg1 *GetTimerIndexTasksRequest) (*GetTimerIndexTasksResponse, error)
- func (m *MockExecutionManager) GetTransferTasks(arg0 context.Context, arg1 *GetTransferTasksRequest) (*GetTransferTasksResponse, error)
- func (m *MockExecutionManager) GetWorkflowExecution(arg0 context.Context, arg1 *GetWorkflowExecutionRequest) (*GetWorkflowExecutionResponse, error)
- func (m *MockExecutionManager) IsWorkflowExecutionExists(arg0 context.Context, arg1 *IsWorkflowExecutionExistsRequest) (*IsWorkflowExecutionExistsResponse, error)
- func (m *MockExecutionManager) ListConcreteExecutions(arg0 context.Context, arg1 *ListConcreteExecutionsRequest) (*ListConcreteExecutionsResponse, error)
- func (m *MockExecutionManager) ListCurrentExecutions(arg0 context.Context, arg1 *ListCurrentExecutionsRequest) (*ListCurrentExecutionsResponse, error)
- func (m *MockExecutionManager) PutReplicationTaskToDLQ(arg0 context.Context, arg1 *PutReplicationTaskToDLQRequest) error
- func (m *MockExecutionManager) RangeCompleteCrossClusterTask(arg0 context.Context, arg1 *RangeCompleteCrossClusterTaskRequest) (*RangeCompleteCrossClusterTaskResponse, error)
- func (m *MockExecutionManager) RangeCompleteReplicationTask(arg0 context.Context, arg1 *RangeCompleteReplicationTaskRequest) (*RangeCompleteReplicationTaskResponse, error)
- func (m *MockExecutionManager) RangeCompleteTimerTask(arg0 context.Context, arg1 *RangeCompleteTimerTaskRequest) (*RangeCompleteTimerTaskResponse, error)
- func (m *MockExecutionManager) RangeCompleteTransferTask(arg0 context.Context, arg1 *RangeCompleteTransferTaskRequest) (*RangeCompleteTransferTaskResponse, error)
- func (m *MockExecutionManager) RangeDeleteReplicationTaskFromDLQ(arg0 context.Context, arg1 *RangeDeleteReplicationTaskFromDLQRequest) (*RangeDeleteReplicationTaskFromDLQResponse, error)
- func (m *MockExecutionManager) UpdateWorkflowExecution(arg0 context.Context, arg1 *UpdateWorkflowExecutionRequest) (*UpdateWorkflowExecutionResponse, error)
- type MockExecutionManagerFactory
- type MockExecutionManagerFactoryMockRecorder
- type MockExecutionManagerMockRecorder
- func (mr *MockExecutionManagerMockRecorder) Close() *gomock.Call
- func (mr *MockExecutionManagerMockRecorder) CompleteCrossClusterTask(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockExecutionManagerMockRecorder) CompleteReplicationTask(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockExecutionManagerMockRecorder) CompleteTimerTask(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockExecutionManagerMockRecorder) CompleteTransferTask(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockExecutionManagerMockRecorder) ConflictResolveWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockExecutionManagerMockRecorder) CreateFailoverMarkerTasks(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockExecutionManagerMockRecorder) CreateWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockExecutionManagerMockRecorder) DeleteCurrentWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockExecutionManagerMockRecorder) DeleteReplicationTaskFromDLQ(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockExecutionManagerMockRecorder) DeleteWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockExecutionManagerMockRecorder) GetCrossClusterTasks(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockExecutionManagerMockRecorder) GetCurrentExecution(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockExecutionManagerMockRecorder) GetName() *gomock.Call
- func (mr *MockExecutionManagerMockRecorder) GetReplicationDLQSize(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockExecutionManagerMockRecorder) GetReplicationTasks(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockExecutionManagerMockRecorder) GetReplicationTasksFromDLQ(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockExecutionManagerMockRecorder) GetShardID() *gomock.Call
- func (mr *MockExecutionManagerMockRecorder) GetTimerIndexTasks(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockExecutionManagerMockRecorder) GetTransferTasks(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockExecutionManagerMockRecorder) GetWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockExecutionManagerMockRecorder) IsWorkflowExecutionExists(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockExecutionManagerMockRecorder) ListConcreteExecutions(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockExecutionManagerMockRecorder) ListCurrentExecutions(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockExecutionManagerMockRecorder) PutReplicationTaskToDLQ(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockExecutionManagerMockRecorder) RangeCompleteCrossClusterTask(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockExecutionManagerMockRecorder) RangeCompleteReplicationTask(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockExecutionManagerMockRecorder) RangeCompleteTimerTask(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockExecutionManagerMockRecorder) RangeCompleteTransferTask(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockExecutionManagerMockRecorder) RangeDeleteReplicationTaskFromDLQ(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockExecutionManagerMockRecorder) UpdateWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
- type MockExecutionStore
- func (m *MockExecutionStore) Close()
- func (m *MockExecutionStore) CompleteCrossClusterTask(arg0 context.Context, arg1 *CompleteCrossClusterTaskRequest) error
- func (m *MockExecutionStore) CompleteReplicationTask(arg0 context.Context, arg1 *CompleteReplicationTaskRequest) error
- func (m *MockExecutionStore) CompleteTimerTask(arg0 context.Context, arg1 *CompleteTimerTaskRequest) error
- func (m *MockExecutionStore) CompleteTransferTask(arg0 context.Context, arg1 *CompleteTransferTaskRequest) error
- func (m *MockExecutionStore) ConflictResolveWorkflowExecution(arg0 context.Context, arg1 *InternalConflictResolveWorkflowExecutionRequest) error
- func (m *MockExecutionStore) CreateFailoverMarkerTasks(arg0 context.Context, arg1 *CreateFailoverMarkersRequest) error
- func (m *MockExecutionStore) CreateWorkflowExecution(arg0 context.Context, arg1 *InternalCreateWorkflowExecutionRequest) (*CreateWorkflowExecutionResponse, error)
- func (m *MockExecutionStore) DeleteCurrentWorkflowExecution(arg0 context.Context, arg1 *DeleteCurrentWorkflowExecutionRequest) error
- func (m *MockExecutionStore) DeleteReplicationTaskFromDLQ(arg0 context.Context, arg1 *DeleteReplicationTaskFromDLQRequest) error
- func (m *MockExecutionStore) DeleteWorkflowExecution(arg0 context.Context, arg1 *DeleteWorkflowExecutionRequest) error
- func (m *MockExecutionStore) EXPECT() *MockExecutionStoreMockRecorder
- func (m *MockExecutionStore) GetCrossClusterTasks(arg0 context.Context, arg1 *GetCrossClusterTasksRequest) (*GetCrossClusterTasksResponse, error)
- func (m *MockExecutionStore) GetCurrentExecution(arg0 context.Context, arg1 *GetCurrentExecutionRequest) (*GetCurrentExecutionResponse, error)
- func (m *MockExecutionStore) GetName() string
- func (m *MockExecutionStore) GetReplicationDLQSize(arg0 context.Context, arg1 *GetReplicationDLQSizeRequest) (*GetReplicationDLQSizeResponse, error)
- func (m *MockExecutionStore) GetReplicationTasks(arg0 context.Context, arg1 *GetReplicationTasksRequest) (*InternalGetReplicationTasksResponse, error)
- func (m *MockExecutionStore) GetReplicationTasksFromDLQ(arg0 context.Context, arg1 *GetReplicationTasksFromDLQRequest) (*InternalGetReplicationTasksResponse, error)
- func (m *MockExecutionStore) GetShardID() int
- func (m *MockExecutionStore) GetTimerIndexTasks(arg0 context.Context, arg1 *GetTimerIndexTasksRequest) (*GetTimerIndexTasksResponse, error)
- func (m *MockExecutionStore) GetTransferTasks(arg0 context.Context, arg1 *GetTransferTasksRequest) (*GetTransferTasksResponse, error)
- func (m *MockExecutionStore) GetWorkflowExecution(arg0 context.Context, arg1 *InternalGetWorkflowExecutionRequest) (*InternalGetWorkflowExecutionResponse, error)
- func (m *MockExecutionStore) IsWorkflowExecutionExists(arg0 context.Context, arg1 *IsWorkflowExecutionExistsRequest) (*IsWorkflowExecutionExistsResponse, error)
- func (m *MockExecutionStore) ListConcreteExecutions(arg0 context.Context, arg1 *ListConcreteExecutionsRequest) (*InternalListConcreteExecutionsResponse, error)
- func (m *MockExecutionStore) ListCurrentExecutions(arg0 context.Context, arg1 *ListCurrentExecutionsRequest) (*ListCurrentExecutionsResponse, error)
- func (m *MockExecutionStore) PutReplicationTaskToDLQ(arg0 context.Context, arg1 *InternalPutReplicationTaskToDLQRequest) error
- func (m *MockExecutionStore) RangeCompleteCrossClusterTask(arg0 context.Context, arg1 *RangeCompleteCrossClusterTaskRequest) (*RangeCompleteCrossClusterTaskResponse, error)
- func (m *MockExecutionStore) RangeCompleteReplicationTask(arg0 context.Context, arg1 *RangeCompleteReplicationTaskRequest) (*RangeCompleteReplicationTaskResponse, error)
- func (m *MockExecutionStore) RangeCompleteTimerTask(arg0 context.Context, arg1 *RangeCompleteTimerTaskRequest) (*RangeCompleteTimerTaskResponse, error)
- func (m *MockExecutionStore) RangeCompleteTransferTask(arg0 context.Context, arg1 *RangeCompleteTransferTaskRequest) (*RangeCompleteTransferTaskResponse, error)
- func (m *MockExecutionStore) RangeDeleteReplicationTaskFromDLQ(arg0 context.Context, arg1 *RangeDeleteReplicationTaskFromDLQRequest) (*RangeDeleteReplicationTaskFromDLQResponse, error)
- func (m *MockExecutionStore) UpdateWorkflowExecution(arg0 context.Context, arg1 *InternalUpdateWorkflowExecutionRequest) error
- type MockExecutionStoreMockRecorder
- func (mr *MockExecutionStoreMockRecorder) Close() *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) CompleteCrossClusterTask(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) CompleteReplicationTask(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) CompleteTimerTask(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) CompleteTransferTask(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) ConflictResolveWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) CreateFailoverMarkerTasks(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) CreateWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) DeleteCurrentWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) DeleteReplicationTaskFromDLQ(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) DeleteWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) GetCrossClusterTasks(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) GetCurrentExecution(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) GetName() *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) GetReplicationDLQSize(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) GetReplicationTasks(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) GetReplicationTasksFromDLQ(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) GetShardID() *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) GetTimerIndexTasks(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) GetTransferTasks(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) GetWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) IsWorkflowExecutionExists(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) ListConcreteExecutions(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) ListCurrentExecutions(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) PutReplicationTaskToDLQ(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) RangeCompleteCrossClusterTask(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) RangeCompleteReplicationTask(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) RangeCompleteTimerTask(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) RangeCompleteTransferTask(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) RangeDeleteReplicationTaskFromDLQ(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) UpdateWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
- type MockHistoryManager
- func (m *MockHistoryManager) AppendHistoryNodes(arg0 context.Context, arg1 *AppendHistoryNodesRequest) (*AppendHistoryNodesResponse, error)
- func (m *MockHistoryManager) Close()
- func (m *MockHistoryManager) DeleteHistoryBranch(arg0 context.Context, arg1 *DeleteHistoryBranchRequest) error
- func (m *MockHistoryManager) EXPECT() *MockHistoryManagerMockRecorder
- func (m *MockHistoryManager) ForkHistoryBranch(arg0 context.Context, arg1 *ForkHistoryBranchRequest) (*ForkHistoryBranchResponse, error)
- func (m *MockHistoryManager) GetAllHistoryTreeBranches(arg0 context.Context, arg1 *GetAllHistoryTreeBranchesRequest) (*GetAllHistoryTreeBranchesResponse, error)
- func (m *MockHistoryManager) GetHistoryTree(arg0 context.Context, arg1 *GetHistoryTreeRequest) (*GetHistoryTreeResponse, error)
- func (m *MockHistoryManager) GetName() string
- func (m *MockHistoryManager) ReadHistoryBranch(arg0 context.Context, arg1 *ReadHistoryBranchRequest) (*ReadHistoryBranchResponse, error)
- func (m *MockHistoryManager) ReadHistoryBranchByBatch(arg0 context.Context, arg1 *ReadHistoryBranchRequest) (*ReadHistoryBranchByBatchResponse, error)
- func (m *MockHistoryManager) ReadRawHistoryBranch(arg0 context.Context, arg1 *ReadHistoryBranchRequest) (*ReadRawHistoryBranchResponse, error)
- type MockHistoryManagerMockRecorder
- func (mr *MockHistoryManagerMockRecorder) AppendHistoryNodes(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHistoryManagerMockRecorder) Close() *gomock.Call
- func (mr *MockHistoryManagerMockRecorder) DeleteHistoryBranch(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHistoryManagerMockRecorder) ForkHistoryBranch(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHistoryManagerMockRecorder) GetAllHistoryTreeBranches(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHistoryManagerMockRecorder) GetHistoryTree(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHistoryManagerMockRecorder) GetName() *gomock.Call
- func (mr *MockHistoryManagerMockRecorder) ReadHistoryBranch(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHistoryManagerMockRecorder) ReadHistoryBranchByBatch(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHistoryManagerMockRecorder) ReadRawHistoryBranch(arg0, arg1 interface{}) *gomock.Call
- type MockPayloadSerializer
- func (m *MockPayloadSerializer) DeserializeAsyncWorkflowsConfig(arg0 *DataBlob) (*types.AsyncWorkflowConfiguration, error)
- func (m *MockPayloadSerializer) DeserializeBadBinaries(arg0 *DataBlob) (*types.BadBinaries, error)
- func (m *MockPayloadSerializer) DeserializeBatchEvents(arg0 *DataBlob) ([]*types.HistoryEvent, error)
- func (m *MockPayloadSerializer) DeserializeChecksum(arg0 *DataBlob) (checksum.Checksum, error)
- func (m *MockPayloadSerializer) DeserializeDynamicConfigBlob(arg0 *DataBlob) (*types.DynamicConfigBlob, error)
- func (m *MockPayloadSerializer) DeserializeEvent(arg0 *DataBlob) (*types.HistoryEvent, error)
- func (m *MockPayloadSerializer) DeserializeIsolationGroups(arg0 *DataBlob) (*types.IsolationGroupConfiguration, error)
- func (m *MockPayloadSerializer) DeserializePendingFailoverMarkers(arg0 *DataBlob) ([]*types.FailoverMarkerAttributes, error)
- func (m *MockPayloadSerializer) DeserializeProcessingQueueStates(arg0 *DataBlob) (*types.ProcessingQueueStates, error)
- func (m *MockPayloadSerializer) DeserializeResetPoints(arg0 *DataBlob) (*types.ResetPoints, error)
- func (m *MockPayloadSerializer) DeserializeVersionHistories(arg0 *DataBlob) (*types.VersionHistories, error)
- func (m *MockPayloadSerializer) DeserializeVisibilityMemo(arg0 *DataBlob) (*types.Memo, error)
- func (m *MockPayloadSerializer) EXPECT() *MockPayloadSerializerMockRecorder
- func (m *MockPayloadSerializer) SerializeAsyncWorkflowsConfig(arg0 *types.AsyncWorkflowConfiguration, arg1 common.EncodingType) (*DataBlob, error)
- func (m *MockPayloadSerializer) SerializeBadBinaries(arg0 *types.BadBinaries, arg1 common.EncodingType) (*DataBlob, error)
- func (m *MockPayloadSerializer) SerializeBatchEvents(arg0 []*types.HistoryEvent, arg1 common.EncodingType) (*DataBlob, error)
- func (m *MockPayloadSerializer) SerializeChecksum(arg0 checksum.Checksum, arg1 common.EncodingType) (*DataBlob, error)
- func (m *MockPayloadSerializer) SerializeDynamicConfigBlob(arg0 *types.DynamicConfigBlob, arg1 common.EncodingType) (*DataBlob, error)
- func (m *MockPayloadSerializer) SerializeEvent(arg0 *types.HistoryEvent, arg1 common.EncodingType) (*DataBlob, error)
- func (m *MockPayloadSerializer) SerializeIsolationGroups(arg0 *types.IsolationGroupConfiguration, arg1 common.EncodingType) (*DataBlob, error)
- func (m *MockPayloadSerializer) SerializePendingFailoverMarkers(arg0 []*types.FailoverMarkerAttributes, arg1 common.EncodingType) (*DataBlob, error)
- func (m *MockPayloadSerializer) SerializeProcessingQueueStates(arg0 *types.ProcessingQueueStates, arg1 common.EncodingType) (*DataBlob, error)
- func (m *MockPayloadSerializer) SerializeResetPoints(arg0 *types.ResetPoints, arg1 common.EncodingType) (*DataBlob, error)
- func (m *MockPayloadSerializer) SerializeVersionHistories(arg0 *types.VersionHistories, arg1 common.EncodingType) (*DataBlob, error)
- func (m *MockPayloadSerializer) SerializeVisibilityMemo(arg0 *types.Memo, arg1 common.EncodingType) (*DataBlob, error)
- type MockPayloadSerializerMockRecorder
- func (mr *MockPayloadSerializerMockRecorder) DeserializeAsyncWorkflowsConfig(arg0 interface{}) *gomock.Call
- func (mr *MockPayloadSerializerMockRecorder) DeserializeBadBinaries(arg0 interface{}) *gomock.Call
- func (mr *MockPayloadSerializerMockRecorder) DeserializeBatchEvents(arg0 interface{}) *gomock.Call
- func (mr *MockPayloadSerializerMockRecorder) DeserializeChecksum(arg0 interface{}) *gomock.Call
- func (mr *MockPayloadSerializerMockRecorder) DeserializeDynamicConfigBlob(arg0 interface{}) *gomock.Call
- func (mr *MockPayloadSerializerMockRecorder) DeserializeEvent(arg0 interface{}) *gomock.Call
- func (mr *MockPayloadSerializerMockRecorder) DeserializeIsolationGroups(arg0 interface{}) *gomock.Call
- func (mr *MockPayloadSerializerMockRecorder) DeserializePendingFailoverMarkers(arg0 interface{}) *gomock.Call
- func (mr *MockPayloadSerializerMockRecorder) DeserializeProcessingQueueStates(arg0 interface{}) *gomock.Call
- func (mr *MockPayloadSerializerMockRecorder) DeserializeResetPoints(arg0 interface{}) *gomock.Call
- func (mr *MockPayloadSerializerMockRecorder) DeserializeVersionHistories(arg0 interface{}) *gomock.Call
- func (mr *MockPayloadSerializerMockRecorder) DeserializeVisibilityMemo(arg0 interface{}) *gomock.Call
- func (mr *MockPayloadSerializerMockRecorder) SerializeAsyncWorkflowsConfig(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockPayloadSerializerMockRecorder) SerializeBadBinaries(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockPayloadSerializerMockRecorder) SerializeBatchEvents(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockPayloadSerializerMockRecorder) SerializeChecksum(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockPayloadSerializerMockRecorder) SerializeDynamicConfigBlob(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockPayloadSerializerMockRecorder) SerializeEvent(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockPayloadSerializerMockRecorder) SerializeIsolationGroups(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockPayloadSerializerMockRecorder) SerializePendingFailoverMarkers(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockPayloadSerializerMockRecorder) SerializeProcessingQueueStates(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockPayloadSerializerMockRecorder) SerializeResetPoints(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockPayloadSerializerMockRecorder) SerializeVersionHistories(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockPayloadSerializerMockRecorder) SerializeVisibilityMemo(arg0, arg1 interface{}) *gomock.Call
- type MockQueueManager
- func (m *MockQueueManager) Close()
- func (m *MockQueueManager) DeleteMessageFromDLQ(arg0 context.Context, arg1 int64) error
- func (m *MockQueueManager) DeleteMessagesBefore(arg0 context.Context, arg1 int64) error
- func (m *MockQueueManager) EXPECT() *MockQueueManagerMockRecorder
- func (m *MockQueueManager) EnqueueMessage(arg0 context.Context, arg1 []byte) error
- func (m *MockQueueManager) EnqueueMessageToDLQ(arg0 context.Context, arg1 []byte) error
- func (m *MockQueueManager) GetAckLevels(arg0 context.Context) (map[string]int64, error)
- func (m *MockQueueManager) GetDLQAckLevels(arg0 context.Context) (map[string]int64, error)
- func (m *MockQueueManager) GetDLQSize(arg0 context.Context) (int64, error)
- func (m *MockQueueManager) RangeDeleteMessagesFromDLQ(arg0 context.Context, arg1, arg2 int64) error
- func (m *MockQueueManager) ReadMessages(arg0 context.Context, arg1 int64, arg2 int) (QueueMessageList, error)
- func (m *MockQueueManager) ReadMessagesFromDLQ(arg0 context.Context, arg1, arg2 int64, arg3 int, arg4 []byte) ([]*QueueMessage, []byte, error)
- func (m *MockQueueManager) UpdateAckLevel(arg0 context.Context, arg1 int64, arg2 string) error
- func (m *MockQueueManager) UpdateDLQAckLevel(arg0 context.Context, arg1 int64, arg2 string) error
- type MockQueueManagerMockRecorder
- func (mr *MockQueueManagerMockRecorder) Close() *gomock.Call
- func (mr *MockQueueManagerMockRecorder) DeleteMessageFromDLQ(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockQueueManagerMockRecorder) DeleteMessagesBefore(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockQueueManagerMockRecorder) EnqueueMessage(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockQueueManagerMockRecorder) EnqueueMessageToDLQ(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockQueueManagerMockRecorder) GetAckLevels(arg0 interface{}) *gomock.Call
- func (mr *MockQueueManagerMockRecorder) GetDLQAckLevels(arg0 interface{}) *gomock.Call
- func (mr *MockQueueManagerMockRecorder) GetDLQSize(arg0 interface{}) *gomock.Call
- func (mr *MockQueueManagerMockRecorder) RangeDeleteMessagesFromDLQ(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockQueueManagerMockRecorder) ReadMessages(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockQueueManagerMockRecorder) ReadMessagesFromDLQ(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call
- func (mr *MockQueueManagerMockRecorder) UpdateAckLevel(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockQueueManagerMockRecorder) UpdateDLQAckLevel(arg0, arg1, arg2 interface{}) *gomock.Call
- type MockRetryer
- func (m *MockRetryer) CompleteTimerTask(ctx context.Context, request *CompleteTimerTaskRequest) error
- func (m *MockRetryer) DeleteCurrentWorkflowExecution(arg0 context.Context, arg1 *DeleteCurrentWorkflowExecutionRequest) error
- func (m *MockRetryer) DeleteWorkflowExecution(arg0 context.Context, arg1 *DeleteWorkflowExecutionRequest) error
- func (m *MockRetryer) EXPECT() *MockRetryerMockRecorder
- func (m *MockRetryer) GetCurrentExecution(arg0 context.Context, arg1 *GetCurrentExecutionRequest) (*GetCurrentExecutionResponse, error)
- func (m *MockRetryer) GetShardID() int
- func (m *MockRetryer) GetTimerIndexTasks(arg0 context.Context, arg1 *GetTimerIndexTasksRequest) (*GetTimerIndexTasksResponse, error)
- func (m *MockRetryer) GetWorkflowExecution(arg0 context.Context, arg1 *GetWorkflowExecutionRequest) (*GetWorkflowExecutionResponse, error)
- func (m *MockRetryer) IsWorkflowExecutionExists(arg0 context.Context, arg1 *IsWorkflowExecutionExistsRequest) (*IsWorkflowExecutionExistsResponse, error)
- func (m *MockRetryer) ListConcreteExecutions(arg0 context.Context, arg1 *ListConcreteExecutionsRequest) (*ListConcreteExecutionsResponse, error)
- func (m *MockRetryer) ListCurrentExecutions(arg0 context.Context, arg1 *ListCurrentExecutionsRequest) (*ListCurrentExecutionsResponse, error)
- func (m *MockRetryer) ReadHistoryBranch(arg0 context.Context, arg1 *ReadHistoryBranchRequest) (*ReadHistoryBranchResponse, error)
- type MockRetryerMockRecorder
- func (mr *MockRetryerMockRecorder) CompleteTimerTask(ctx, request interface{}) *gomock.Call
- func (mr *MockRetryerMockRecorder) DeleteCurrentWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockRetryerMockRecorder) DeleteWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockRetryerMockRecorder) GetCurrentExecution(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockRetryerMockRecorder) GetShardID() *gomock.Call
- func (mr *MockRetryerMockRecorder) GetTimerIndexTasks(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockRetryerMockRecorder) GetWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockRetryerMockRecorder) IsWorkflowExecutionExists(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockRetryerMockRecorder) ListConcreteExecutions(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockRetryerMockRecorder) ListCurrentExecutions(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockRetryerMockRecorder) ReadHistoryBranch(arg0, arg1 interface{}) *gomock.Call
- type MockShardManager
- func (m *MockShardManager) Close()
- func (m *MockShardManager) CreateShard(arg0 context.Context, arg1 *CreateShardRequest) error
- func (m *MockShardManager) EXPECT() *MockShardManagerMockRecorder
- func (m *MockShardManager) GetName() string
- func (m *MockShardManager) GetShard(arg0 context.Context, arg1 *GetShardRequest) (*GetShardResponse, error)
- func (m *MockShardManager) UpdateShard(arg0 context.Context, arg1 *UpdateShardRequest) error
- type MockShardManagerMockRecorder
- func (mr *MockShardManagerMockRecorder) Close() *gomock.Call
- func (mr *MockShardManagerMockRecorder) CreateShard(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockShardManagerMockRecorder) GetName() *gomock.Call
- func (mr *MockShardManagerMockRecorder) GetShard(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockShardManagerMockRecorder) UpdateShard(arg0, arg1 interface{}) *gomock.Call
- type MockShardStore
- func (m *MockShardStore) Close()
- func (m *MockShardStore) CreateShard(arg0 context.Context, arg1 *InternalCreateShardRequest) error
- func (m *MockShardStore) EXPECT() *MockShardStoreMockRecorder
- func (m *MockShardStore) GetName() string
- func (m *MockShardStore) GetShard(arg0 context.Context, arg1 *InternalGetShardRequest) (*InternalGetShardResponse, error)
- func (m *MockShardStore) UpdateShard(arg0 context.Context, arg1 *InternalUpdateShardRequest) error
- type MockShardStoreMockRecorder
- func (mr *MockShardStoreMockRecorder) Close() *gomock.Call
- func (mr *MockShardStoreMockRecorder) CreateShard(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockShardStoreMockRecorder) GetName() *gomock.Call
- func (mr *MockShardStoreMockRecorder) GetShard(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockShardStoreMockRecorder) UpdateShard(arg0, arg1 interface{}) *gomock.Call
- type MockTask
- func (m *MockTask) EXPECT() *MockTaskMockRecorder
- func (m *MockTask) GetTaskID() int64
- func (m *MockTask) GetType() int
- func (m *MockTask) GetVersion() int64
- func (m *MockTask) GetVisibilityTimestamp() time.Time
- func (m *MockTask) SetTaskID(arg0 int64)
- func (m *MockTask) SetVersion(arg0 int64)
- func (m *MockTask) SetVisibilityTimestamp(arg0 time.Time)
- type MockTaskManager
- func (m *MockTaskManager) Close()
- func (m *MockTaskManager) CompleteTask(arg0 context.Context, arg1 *CompleteTaskRequest) error
- func (m *MockTaskManager) CompleteTasksLessThan(arg0 context.Context, arg1 *CompleteTasksLessThanRequest) (*CompleteTasksLessThanResponse, error)
- func (m *MockTaskManager) CreateTasks(arg0 context.Context, arg1 *CreateTasksRequest) (*CreateTasksResponse, error)
- func (m *MockTaskManager) DeleteTaskList(arg0 context.Context, arg1 *DeleteTaskListRequest) error
- func (m *MockTaskManager) EXPECT() *MockTaskManagerMockRecorder
- func (m *MockTaskManager) GetName() string
- func (m *MockTaskManager) GetOrphanTasks(arg0 context.Context, arg1 *GetOrphanTasksRequest) (*GetOrphanTasksResponse, error)
- func (m *MockTaskManager) GetTaskListSize(arg0 context.Context, arg1 *GetTaskListSizeRequest) (*GetTaskListSizeResponse, error)
- func (m *MockTaskManager) GetTasks(arg0 context.Context, arg1 *GetTasksRequest) (*GetTasksResponse, error)
- func (m *MockTaskManager) LeaseTaskList(arg0 context.Context, arg1 *LeaseTaskListRequest) (*LeaseTaskListResponse, error)
- func (m *MockTaskManager) ListTaskList(arg0 context.Context, arg1 *ListTaskListRequest) (*ListTaskListResponse, error)
- func (m *MockTaskManager) UpdateTaskList(arg0 context.Context, arg1 *UpdateTaskListRequest) (*UpdateTaskListResponse, error)
- type MockTaskManagerMockRecorder
- func (mr *MockTaskManagerMockRecorder) Close() *gomock.Call
- func (mr *MockTaskManagerMockRecorder) CompleteTask(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockTaskManagerMockRecorder) CompleteTasksLessThan(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockTaskManagerMockRecorder) CreateTasks(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockTaskManagerMockRecorder) DeleteTaskList(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockTaskManagerMockRecorder) GetName() *gomock.Call
- func (mr *MockTaskManagerMockRecorder) GetOrphanTasks(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockTaskManagerMockRecorder) GetTaskListSize(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockTaskManagerMockRecorder) GetTasks(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockTaskManagerMockRecorder) LeaseTaskList(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockTaskManagerMockRecorder) ListTaskList(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockTaskManagerMockRecorder) UpdateTaskList(arg0, arg1 interface{}) *gomock.Call
- type MockTaskMockRecorder
- func (mr *MockTaskMockRecorder) GetTaskID() *gomock.Call
- func (mr *MockTaskMockRecorder) GetType() *gomock.Call
- func (mr *MockTaskMockRecorder) GetVersion() *gomock.Call
- func (mr *MockTaskMockRecorder) GetVisibilityTimestamp() *gomock.Call
- func (mr *MockTaskMockRecorder) SetTaskID(arg0 interface{}) *gomock.Call
- func (mr *MockTaskMockRecorder) SetVersion(arg0 interface{}) *gomock.Call
- func (mr *MockTaskMockRecorder) SetVisibilityTimestamp(arg0 interface{}) *gomock.Call
- type MockVisibilityManager
- func (m *MockVisibilityManager) Close()
- func (m *MockVisibilityManager) CountWorkflowExecutions(arg0 context.Context, arg1 *CountWorkflowExecutionsRequest) (*CountWorkflowExecutionsResponse, error)
- func (m *MockVisibilityManager) DeleteUninitializedWorkflowExecution(arg0 context.Context, arg1 *VisibilityDeleteWorkflowExecutionRequest) error
- func (m *MockVisibilityManager) DeleteWorkflowExecution(arg0 context.Context, arg1 *VisibilityDeleteWorkflowExecutionRequest) error
- func (m *MockVisibilityManager) EXPECT() *MockVisibilityManagerMockRecorder
- func (m *MockVisibilityManager) GetClosedWorkflowExecution(arg0 context.Context, arg1 *GetClosedWorkflowExecutionRequest) (*GetClosedWorkflowExecutionResponse, error)
- func (m *MockVisibilityManager) GetName() string
- func (m *MockVisibilityManager) ListAllWorkflowExecutions(arg0 context.Context, arg1 *ListAllWorkflowExecutionsRequest) (*ListWorkflowExecutionsResponse, error)
- func (m *MockVisibilityManager) ListClosedWorkflowExecutions(arg0 context.Context, arg1 *ListWorkflowExecutionsRequest) (*ListWorkflowExecutionsResponse, error)
- func (m *MockVisibilityManager) ListClosedWorkflowExecutionsByStatus(arg0 context.Context, arg1 *ListClosedWorkflowExecutionsByStatusRequest) (*ListWorkflowExecutionsResponse, error)
- func (m *MockVisibilityManager) ListClosedWorkflowExecutionsByType(arg0 context.Context, arg1 *ListWorkflowExecutionsByTypeRequest) (*ListWorkflowExecutionsResponse, error)
- func (m *MockVisibilityManager) ListClosedWorkflowExecutionsByWorkflowID(arg0 context.Context, arg1 *ListWorkflowExecutionsByWorkflowIDRequest) (*ListWorkflowExecutionsResponse, error)
- func (m *MockVisibilityManager) ListOpenWorkflowExecutions(arg0 context.Context, arg1 *ListWorkflowExecutionsRequest) (*ListWorkflowExecutionsResponse, error)
- func (m *MockVisibilityManager) ListOpenWorkflowExecutionsByType(arg0 context.Context, arg1 *ListWorkflowExecutionsByTypeRequest) (*ListWorkflowExecutionsResponse, error)
- func (m *MockVisibilityManager) ListOpenWorkflowExecutionsByWorkflowID(arg0 context.Context, arg1 *ListWorkflowExecutionsByWorkflowIDRequest) (*ListWorkflowExecutionsResponse, error)
- func (m *MockVisibilityManager) ListWorkflowExecutions(arg0 context.Context, arg1 *ListWorkflowExecutionsByQueryRequest) (*ListWorkflowExecutionsResponse, error)
- func (m *MockVisibilityManager) RecordWorkflowExecutionClosed(arg0 context.Context, arg1 *RecordWorkflowExecutionClosedRequest) error
- func (m *MockVisibilityManager) RecordWorkflowExecutionStarted(arg0 context.Context, arg1 *RecordWorkflowExecutionStartedRequest) error
- func (m *MockVisibilityManager) RecordWorkflowExecutionUninitialized(arg0 context.Context, arg1 *RecordWorkflowExecutionUninitializedRequest) error
- func (m *MockVisibilityManager) ScanWorkflowExecutions(arg0 context.Context, arg1 *ListWorkflowExecutionsByQueryRequest) (*ListWorkflowExecutionsResponse, error)
- func (m *MockVisibilityManager) UpsertWorkflowExecution(arg0 context.Context, arg1 *UpsertWorkflowExecutionRequest) error
- type MockVisibilityManagerMockRecorder
- func (mr *MockVisibilityManagerMockRecorder) Close() *gomock.Call
- func (mr *MockVisibilityManagerMockRecorder) CountWorkflowExecutions(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockVisibilityManagerMockRecorder) DeleteUninitializedWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockVisibilityManagerMockRecorder) DeleteWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockVisibilityManagerMockRecorder) GetClosedWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockVisibilityManagerMockRecorder) GetName() *gomock.Call
- func (mr *MockVisibilityManagerMockRecorder) ListAllWorkflowExecutions(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockVisibilityManagerMockRecorder) ListClosedWorkflowExecutions(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockVisibilityManagerMockRecorder) ListClosedWorkflowExecutionsByStatus(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockVisibilityManagerMockRecorder) ListClosedWorkflowExecutionsByType(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockVisibilityManagerMockRecorder) ListClosedWorkflowExecutionsByWorkflowID(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockVisibilityManagerMockRecorder) ListOpenWorkflowExecutions(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockVisibilityManagerMockRecorder) ListOpenWorkflowExecutionsByType(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockVisibilityManagerMockRecorder) ListOpenWorkflowExecutionsByWorkflowID(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockVisibilityManagerMockRecorder) ListWorkflowExecutions(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockVisibilityManagerMockRecorder) RecordWorkflowExecutionClosed(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockVisibilityManagerMockRecorder) RecordWorkflowExecutionStarted(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockVisibilityManagerMockRecorder) RecordWorkflowExecutionUninitialized(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockVisibilityManagerMockRecorder) ScanWorkflowExecutions(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockVisibilityManagerMockRecorder) UpsertWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
- type MockVisibilityStore
- func (m *MockVisibilityStore) Close()
- func (m *MockVisibilityStore) CountWorkflowExecutions(arg0 context.Context, arg1 *CountWorkflowExecutionsRequest) (*CountWorkflowExecutionsResponse, error)
- func (m *MockVisibilityStore) DeleteUninitializedWorkflowExecution(arg0 context.Context, arg1 *VisibilityDeleteWorkflowExecutionRequest) error
- func (m *MockVisibilityStore) DeleteWorkflowExecution(arg0 context.Context, arg1 *VisibilityDeleteWorkflowExecutionRequest) error
- func (m *MockVisibilityStore) EXPECT() *MockVisibilityStoreMockRecorder
- func (m *MockVisibilityStore) GetClosedWorkflowExecution(arg0 context.Context, arg1 *InternalGetClosedWorkflowExecutionRequest) (*InternalGetClosedWorkflowExecutionResponse, error)
- func (m *MockVisibilityStore) GetName() string
- func (m *MockVisibilityStore) ListAllWorkflowExecutions(arg0 context.Context, arg1 *InternalListAllWorkflowExecutionsByTypeRequest) (*InternalListWorkflowExecutionsResponse, error)
- func (m *MockVisibilityStore) ListClosedWorkflowExecutions(arg0 context.Context, arg1 *InternalListWorkflowExecutionsRequest) (*InternalListWorkflowExecutionsResponse, error)
- func (m *MockVisibilityStore) ListClosedWorkflowExecutionsByStatus(arg0 context.Context, ...) (*InternalListWorkflowExecutionsResponse, error)
- func (m *MockVisibilityStore) ListClosedWorkflowExecutionsByType(arg0 context.Context, arg1 *InternalListWorkflowExecutionsByTypeRequest) (*InternalListWorkflowExecutionsResponse, error)
- func (m *MockVisibilityStore) ListClosedWorkflowExecutionsByWorkflowID(arg0 context.Context, arg1 *InternalListWorkflowExecutionsByWorkflowIDRequest) (*InternalListWorkflowExecutionsResponse, error)
- func (m *MockVisibilityStore) ListOpenWorkflowExecutions(arg0 context.Context, arg1 *InternalListWorkflowExecutionsRequest) (*InternalListWorkflowExecutionsResponse, error)
- func (m *MockVisibilityStore) ListOpenWorkflowExecutionsByType(arg0 context.Context, arg1 *InternalListWorkflowExecutionsByTypeRequest) (*InternalListWorkflowExecutionsResponse, error)
- func (m *MockVisibilityStore) ListOpenWorkflowExecutionsByWorkflowID(arg0 context.Context, arg1 *InternalListWorkflowExecutionsByWorkflowIDRequest) (*InternalListWorkflowExecutionsResponse, error)
- func (m *MockVisibilityStore) ListWorkflowExecutions(arg0 context.Context, arg1 *ListWorkflowExecutionsByQueryRequest) (*InternalListWorkflowExecutionsResponse, error)
- func (m *MockVisibilityStore) RecordWorkflowExecutionClosed(arg0 context.Context, arg1 *InternalRecordWorkflowExecutionClosedRequest) error
- func (m *MockVisibilityStore) RecordWorkflowExecutionStarted(arg0 context.Context, arg1 *InternalRecordWorkflowExecutionStartedRequest) error
- func (m *MockVisibilityStore) RecordWorkflowExecutionUninitialized(arg0 context.Context, ...) error
- func (m *MockVisibilityStore) ScanWorkflowExecutions(arg0 context.Context, arg1 *ListWorkflowExecutionsByQueryRequest) (*InternalListWorkflowExecutionsResponse, error)
- func (m *MockVisibilityStore) UpsertWorkflowExecution(arg0 context.Context, arg1 *InternalUpsertWorkflowExecutionRequest) error
- type MockVisibilityStoreMockRecorder
- func (mr *MockVisibilityStoreMockRecorder) Close() *gomock.Call
- func (mr *MockVisibilityStoreMockRecorder) CountWorkflowExecutions(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockVisibilityStoreMockRecorder) DeleteUninitializedWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockVisibilityStoreMockRecorder) DeleteWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockVisibilityStoreMockRecorder) GetClosedWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockVisibilityStoreMockRecorder) GetName() *gomock.Call
- func (mr *MockVisibilityStoreMockRecorder) ListAllWorkflowExecutions(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockVisibilityStoreMockRecorder) ListClosedWorkflowExecutions(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockVisibilityStoreMockRecorder) ListClosedWorkflowExecutionsByStatus(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockVisibilityStoreMockRecorder) ListClosedWorkflowExecutionsByType(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockVisibilityStoreMockRecorder) ListClosedWorkflowExecutionsByWorkflowID(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockVisibilityStoreMockRecorder) ListOpenWorkflowExecutions(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockVisibilityStoreMockRecorder) ListOpenWorkflowExecutionsByType(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockVisibilityStoreMockRecorder) ListOpenWorkflowExecutionsByWorkflowID(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockVisibilityStoreMockRecorder) ListWorkflowExecutions(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockVisibilityStoreMockRecorder) RecordWorkflowExecutionClosed(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockVisibilityStoreMockRecorder) RecordWorkflowExecutionStarted(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockVisibilityStoreMockRecorder) RecordWorkflowExecutionUninitialized(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockVisibilityStoreMockRecorder) ScanWorkflowExecutions(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockVisibilityStoreMockRecorder) UpsertWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
- type MutableStateStats
- type MutableStateUpdateSessionStats
- type OperationType
- type PayloadSerializer
- type PutReplicationTaskToDLQRequest
- type Queue
- type QueueManager
- type QueueMessage
- type QueueMessageList
- type QueueType
- type RangeCompleteCrossClusterTaskRequest
- type RangeCompleteCrossClusterTaskResponse
- type RangeCompleteReplicationTaskRequest
- type RangeCompleteReplicationTaskResponse
- type RangeCompleteTimerTaskRequest
- type RangeCompleteTimerTaskResponse
- type RangeCompleteTransferTaskRequest
- type RangeCompleteTransferTaskResponse
- type RangeDeleteReplicationTaskFromDLQRequest
- type RangeDeleteReplicationTaskFromDLQResponse
- type ReadHistoryBranchByBatchResponse
- type ReadHistoryBranchRequest
- type ReadHistoryBranchResponse
- type ReadRawHistoryBranchResponse
- type RecordChildExecutionCompletedTask
- type RecordWorkflowClosedTask
- type RecordWorkflowExecutionClosedRequest
- type RecordWorkflowExecutionStartedRequest
- type RecordWorkflowExecutionUninitializedRequest
- type RecordWorkflowStartedTask
- type ReplicationInfo
- type ReplicationState
- type ReplicationTaskInfo
- func (t *ReplicationTaskInfo) GetDomainID() string
- func (t *ReplicationTaskInfo) GetRunID() string
- func (t *ReplicationTaskInfo) GetTaskID() int64
- func (t *ReplicationTaskInfo) GetTaskType() int
- func (t *ReplicationTaskInfo) GetVersion() int64
- func (t *ReplicationTaskInfo) GetVisibilityTimestamp() time.Time
- func (t *ReplicationTaskInfo) GetWorkflowID() string
- type RequestCancelInfo
- type ResetWorkflowTask
- type ResponseComparatorContextKey
- type Retryer
- type ShardAlreadyExistError
- type ShardInfo
- type ShardManager
- type ShardManagerOption
- type ShardOwnershipLostError
- type ShardStore
- type SignalExecutionTask
- type SignalInfo
- type StartChildExecutionTask
- type SyncActivityTask
- type Task
- type TaskData
- type TaskInfo
- type TaskKey
- type TaskListInfo
- type TaskManager
- type TaskStore
- type TimeoutError
- type TimerInfo
- type TimerTaskInfo
- func (t *TimerTaskInfo) GetDomainID() string
- func (t *TimerTaskInfo) GetRunID() string
- func (t *TimerTaskInfo) GetTaskID() int64
- func (t *TimerTaskInfo) GetTaskType() int
- func (t *TimerTaskInfo) GetVersion() int64
- func (t *TimerTaskInfo) GetVisibilityTimestamp() time.Time
- func (t *TimerTaskInfo) GetWorkflowID() string
- func (t *TimerTaskInfo) String() string
- type TransactionSizeLimitError
- type TransferTaskInfo
- func (t *TransferTaskInfo) GetDomainID() string
- func (t *TransferTaskInfo) GetRunID() string
- func (t *TransferTaskInfo) GetTargetDomainIDs() map[string]struct{}
- func (t *TransferTaskInfo) GetTaskID() int64
- func (t *TransferTaskInfo) GetTaskType() int
- func (t *TransferTaskInfo) GetVersion() int64
- func (t *TransferTaskInfo) GetVisibilityTimestamp() time.Time
- func (t *TransferTaskInfo) GetWorkflowID() string
- func (t *TransferTaskInfo) String() string
- type UnknownEncodingTypeError
- type UpdateDomainRequest
- type UpdateDynamicConfigRequest
- type UpdateShardRequest
- type UpdateTaskListRequest
- type UpdateTaskListResponse
- type UpdateWorkflowExecutionRequest
- type UpdateWorkflowExecutionResponse
- type UpdateWorkflowMode
- type UpsertWorkflowExecutionRequest
- type UpsertWorkflowSearchAttributesTask
- type UserTimerTask
- type VersionHistories
- func (h *VersionHistories) AddVersionHistory(v *VersionHistory) (bool, int, error)
- func (h *VersionHistories) Duplicate() *VersionHistories
- func (h *VersionHistories) FindFirstVersionHistoryByItem(item *VersionHistoryItem) (index int, history *VersionHistory, err error)
- func (h *VersionHistories) FindLCAVersionHistoryIndexAndItem(incomingHistory *VersionHistory) (int, *VersionHistoryItem, error)
- func (h *VersionHistories) GetCurrentVersionHistory() (*VersionHistory, error)
- func (h *VersionHistories) GetCurrentVersionHistoryIndex() int
- func (h *VersionHistories) GetVersionHistory(branchIndex int) (*VersionHistory, error)
- func (h *VersionHistories) IsRebuilt() (bool, error)
- func (h *VersionHistories) SetCurrentVersionHistoryIndex(index int) error
- func (h *VersionHistories) ToInternalType() *types.VersionHistories
- type VersionHistory
- func (v *VersionHistory) AddOrUpdateItem(item *VersionHistoryItem) error
- func (v *VersionHistory) ContainsItem(item *VersionHistoryItem) bool
- func (v *VersionHistory) Duplicate() *VersionHistory
- func (v *VersionHistory) DuplicateUntilLCAItem(lcaItem *VersionHistoryItem) (*VersionHistory, error)
- func (v *VersionHistory) Equals(input *VersionHistory) bool
- func (v *VersionHistory) FindLCAItem(remote *VersionHistory) (*VersionHistoryItem, error)
- func (v *VersionHistory) GetBranchToken() []byte
- func (v *VersionHistory) GetEventVersion(eventID int64) (int64, error)
- func (v *VersionHistory) GetFirstItem() (*VersionHistoryItem, error)
- func (v *VersionHistory) GetLastItem() (*VersionHistoryItem, error)
- func (v *VersionHistory) IsEmpty() bool
- func (v *VersionHistory) IsLCAAppendable(item *VersionHistoryItem) bool
- func (v *VersionHistory) SetBranchToken(inputToken []byte) error
- func (v *VersionHistory) ToInternalType() *types.VersionHistory
- type VersionHistoryItem
- type VisibilityAdminDeletionKey
- type VisibilityDeleteWorkflowExecutionRequest
- type VisibilityManager
- func NewPinotVisibilityDualManager(dbVisibilityManager VisibilityManager, ...) VisibilityManager
- func NewVisibilityDualManager(dbVisibilityManager VisibilityManager, ...) VisibilityManager
- func NewVisibilityManagerImpl(persistence VisibilityStore, logger log.Logger) VisibilityManager
- func NewVisibilityTripleManager(dbVisibilityManager VisibilityManager, ...) VisibilityManager
- type VisibilityStore
- type WorkflowBackoffTimerTask
- type WorkflowEvents
- type WorkflowExecutionAlreadyStartedError
- type WorkflowExecutionInfo
- func (e *WorkflowExecutionInfo) IncreaseNextEventID()
- func (e *WorkflowExecutionInfo) IsRunning() bool
- func (e *WorkflowExecutionInfo) SetLastFirstEventID(id int64)
- func (e *WorkflowExecutionInfo) SetNextEventID(id int64)
- func (e *WorkflowExecutionInfo) UpdateWorkflowStateCloseStatus(state int, closeStatus int) error
- type WorkflowMutableState
- type WorkflowMutation
- type WorkflowRequest
- type WorkflowRequestType
- type WorkflowSnapshot
- type WorkflowTimeoutTask
Constants ¶
const ( DomainStatusRegistered = iota DomainStatusDeprecated DomainStatusDeleted )
Domain status
const ( WorkflowStateCreated = iota WorkflowStateRunning WorkflowStateCompleted WorkflowStateZombie WorkflowStateVoid WorkflowStateCorrupted )
Workflow execution states
const ( WorkflowCloseStatusNone = iota WorkflowCloseStatusCompleted WorkflowCloseStatusFailed WorkflowCloseStatusCanceled WorkflowCloseStatusTerminated WorkflowCloseStatusContinuedAsNew WorkflowCloseStatusTimedOut )
Workflow execution close status
const ( TaskListTypeDecision = iota TaskListTypeActivity )
Types of task lists
const ( TaskListKindNormal = iota TaskListKindSticky )
Kinds of task lists
const ( TransferTaskTypeDecisionTask = iota TransferTaskTypeActivityTask TransferTaskTypeCloseExecution TransferTaskTypeCancelExecution TransferTaskTypeStartChildExecution TransferTaskTypeSignalExecution TransferTaskTypeRecordWorkflowStarted TransferTaskTypeResetWorkflow TransferTaskTypeUpsertWorkflowSearchAttributes TransferTaskTypeRecordWorkflowClosed TransferTaskTypeRecordChildExecutionCompleted TransferTaskTypeApplyParentClosePolicy )
Transfer task types
const ( CrossClusterTaskTypeStartChildExecution = iota + 1 CrossClusterTaskTypeCancelExecution CrossClusterTaskTypeSignalExecution CrossClusterTaskTypeRecordChildExeuctionCompleted CrossClusterTaskTypeApplyParentClosePolicy )
Types of cross-cluster tasks
const ( ReplicationTaskTypeHistory = iota ReplicationTaskTypeSyncActivity ReplicationTaskTypeFailoverMarker )
Types of replication tasks
const ( TaskTypeDecisionTimeout = iota TaskTypeActivityTimeout TaskTypeUserTimer TaskTypeWorkflowTimeout TaskTypeDeleteHistoryEvent TaskTypeActivityRetryTimer TaskTypeWorkflowBackoffTimer )
Types of timers
const ( WorkflowBackoffTimeoutTypeRetry = iota WorkflowBackoffTimeoutTypeCron )
Types of workflow backoff timeout
const ( // InitialFailoverNotificationVersion is the initial failover version for a domain InitialFailoverNotificationVersion int64 = 0 // TransferTaskTransferTargetWorkflowID is the the dummy workflow ID for transfer tasks of types // that do not have a target workflow TransferTaskTransferTargetWorkflowID = "20000000-0000-f000-f000-000000000001" // TransferTaskTransferTargetRunID is the the dummy run ID for transfer tasks of types // that do not have a target workflow TransferTaskTransferTargetRunID = "30000000-0000-f000-f000-000000000002" // CrossClusterTaskDefaultTargetRunID is the the dummy run ID for cross-cluster tasks of types // that do not have a target workflow CrossClusterTaskDefaultTargetRunID = TransferTaskTransferTargetRunID )
const ( VisibilityOverridePrimary = "Primary" VisibilityOverrideSecondary = "Secondary" ContextKey = ResponseComparatorContextKey("visibility-override") )
const ( // EventStoreVersion is already deprecated, this is used for forward // compatibility (so that rollback is possible). // TODO we can remove it after fixing all the query templates and when // we decide the compatibility is no longer needed. EventStoreVersion = 2 )
const UnknownNumRowsAffected = -1
UnknownNumRowsAffected is returned when the number of rows that an API affected cannot be determined
const VisibilityEncoding = common.EncodingTypeThriftRW
VisibilityEncoding is default encoding for visibility data
Variables ¶
var (
ErrCorruptedHistory = &types.InternalDataInconsistencyError{Message: "corrupted history event batch, eventID is not continouous"}
)
var ErrVisibilityOperationNotSupported = &types.BadRequestError{Message: "Operation is not supported"}
ErrVisibilityOperationNotSupported is an error which indicates that operation is not supported in selected persistence
var Operation = struct { LIST OperationType COUNT OperationType }{ LIST: "list", COUNT: "count", }
Functions ¶
func BuildHistoryGarbageCleanupInfo ¶ added in v0.9.3
BuildHistoryGarbageCleanupInfo combine the workflow identity information into a string
func DBTimestampToUnixNano ¶ added in v0.4.0
DBTimestampToUnixNano converts Milliseconds timestamp to UnixNano
func FromDataBlob ¶ added in v0.4.0
FromDataBlob decodes a datablob into a (payload, encodingType) tuple
func FromInternalWorkflowExecutionCloseStatus ¶ added in v0.21.0
func FromInternalWorkflowExecutionCloseStatus( closeStatus *types.WorkflowExecutionCloseStatus, ) int
FromInternalWorkflowExecutionCloseStatus convert internal representation of close status to persistence representation
func HasMoreRowsToDelete ¶ added in v0.23.1
HasMoreRowsToDelete checks if there is more data need to be deleted
func IsBackgroundTransientError ¶ added in v0.23.1
IsBackgroundTransientError checks if the error is a transient error on background jobs
func IsNopUpsertWorkflowRequest ¶ added in v0.11.0
func IsNopUpsertWorkflowRequest(request *InternalUpsertWorkflowExecutionRequest) bool
IsNopUpsertWorkflowRequest return whether upsert request should be no-op
func IsTimeoutError ¶ added in v0.5.7
IsTimeoutError check whether error is TimeoutError
func IsTransientError ¶ added in v0.20.0
IsTransientError checks if the error is a transient persistence error
func NewHistoryBranchToken ¶ added in v0.5.0
NewHistoryBranchToken return a new branch token
func NewHistoryBranchTokenByBranchID ¶ added in v0.9.3
NewHistoryBranchTokenByBranchID return a new branch token with treeID/branchID
func NewHistoryBranchTokenFromAnother ¶ added in v0.5.2
NewHistoryBranchTokenFromAnother make up a branchToken
func NewUnknownEncodingTypeError ¶
func NewUnknownEncodingTypeError(encodingType common.EncodingType) error
NewUnknownEncodingTypeError returns a new instance of encoding type error
func SerializeClusterConfigs ¶ added in v0.4.0
func SerializeClusterConfigs(replicationConfigs []*ClusterReplicationConfig) []map[string]interface{}
SerializeClusterConfigs makes an array of *ClusterReplicationConfig serializable by flattening them into map[string]interface{}
func SplitHistoryGarbageCleanupInfo ¶ added in v0.9.3
SplitHistoryGarbageCleanupInfo returns workflow identity information
func ToInternalWorkflowExecutionCloseStatus ¶ added in v0.18.0
func ToInternalWorkflowExecutionCloseStatus( closeStatus int, ) *types.WorkflowExecutionCloseStatus
ToInternalWorkflowExecutionCloseStatus convert persistence representation of close status to internal representation
func UnixNanoToDBTimestamp ¶ added in v0.4.0
UnixNanoToDBTimestamp converts UnixNano to Milliseconds timestamp
func ValidateConflictResolveWorkflowModeState ¶ added in v0.9.3
func ValidateConflictResolveWorkflowModeState( mode ConflictResolveWorkflowMode, resetWorkflowSnapshot InternalWorkflowSnapshot, newWorkflowSnapshot *InternalWorkflowSnapshot, currentWorkflowMutation *InternalWorkflowMutation, ) error
ValidateConflictResolveWorkflowModeState validate workflow conflict resolve mode & workflow state
func ValidateCreateWorkflowModeState ¶ added in v0.9.3
func ValidateCreateWorkflowModeState( mode CreateWorkflowMode, newWorkflowSnapshot InternalWorkflowSnapshot, ) error
ValidateCreateWorkflowModeState validate workflow creation mode & workflow state
func ValidateCreateWorkflowStateCloseStatus ¶ added in v0.5.9
ValidateCreateWorkflowStateCloseStatus validate workflow state and close status
func ValidateUpdateWorkflowModeState ¶ added in v0.9.3
func ValidateUpdateWorkflowModeState( mode UpdateWorkflowMode, currentWorkflowMutation InternalWorkflowMutation, newWorkflowSnapshot *InternalWorkflowSnapshot, ) error
ValidateUpdateWorkflowModeState validate workflow update mode & workflow state
func ValidateUpdateWorkflowStateCloseStatus ¶ added in v0.5.9
ValidateUpdateWorkflowStateCloseStatus validate workflow state and close status
Types ¶
type ActivityInfo ¶
type ActivityInfo struct { Version int64 ScheduleID int64 ScheduledEventBatchID int64 ScheduledEvent *types.HistoryEvent ScheduledTime time.Time StartedID int64 StartedEvent *types.HistoryEvent StartedTime time.Time DomainID string ActivityID string RequestID string Details []byte ScheduleToStartTimeout int32 ScheduleToCloseTimeout int32 StartToCloseTimeout int32 HeartbeatTimeout int32 CancelRequested bool CancelRequestID int64 LastHeartBeatUpdatedTime time.Time TimerTaskStatus int32 // For retry Attempt int32 StartedIdentity string TaskList string HasRetryPolicy bool InitialInterval int32 BackoffCoefficient float64 MaximumInterval int32 ExpirationTime time.Time MaximumAttempts int32 NonRetriableErrors []string LastFailureReason string LastWorkerIdentity string LastFailureDetails []byte // Not written to database - This is used only for deduping heartbeat timer creation LastHeartbeatTimeoutVisibilityInSeconds int64 }
ActivityInfo details.
type ActivityRetryTimerTask ¶ added in v0.4.0
ActivityRetryTimerTask to schedule a retry task for activity
func (*ActivityRetryTimerTask) GetType ¶ added in v0.4.0
func (r *ActivityRetryTimerTask) GetType() int
GetType returns the type of the retry timer task
type ActivityTask ¶
ActivityTask identifies a transfer task for activity
func (*ActivityTask) GetType ¶
func (a *ActivityTask) GetType() int
GetType returns the type of the activity task
type ActivityTimeoutTask ¶
ActivityTimeoutTask identifies a timeout task.
func (*ActivityTimeoutTask) GetType ¶
func (a *ActivityTimeoutTask) GetType() int
GetType returns the type of the timer task
type AppendHistoryNodesRequest ¶ added in v0.5.0
type AppendHistoryNodesRequest struct { // true if this is the first append request to the branch IsNewBranch bool // the info for clean up data in background Info string // The branch to be appended BranchToken []byte // The batch of events to be appended. The first eventID will become the nodeID of this batch Events []*types.HistoryEvent // requested TransactionID for this write operation. For the same eventID, the node with larger TransactionID always wins TransactionID int64 // optional binary encoding type Encoding common.EncodingType // The shard to get history node data ShardID *int // DomainName to get metrics created with the domain DomainName string }
AppendHistoryNodesRequest is used to append a batch of history nodes
func (AppendHistoryNodesRequest) MetricTags ¶ added in v1.2.7
func (r AppendHistoryNodesRequest) MetricTags() []metrics.Tag
type AppendHistoryNodesResponse ¶ added in v0.5.0
type AppendHistoryNodesResponse struct { // The data blob that was persisted to database DataBlob DataBlob }
AppendHistoryNodesResponse is a response to AppendHistoryNodesRequest
type ApplyParentClosePolicyTask ¶ added in v0.24.0
ApplyParentClosePolicyTask identifies a task for applying parent close policy
func (*ApplyParentClosePolicyTask) GetType ¶ added in v0.24.0
func (u *ApplyParentClosePolicyTask) GetType() int
GetType returns the type of the apply parent close policy task
type CadenceDeserializationError ¶ added in v0.5.7
type CadenceDeserializationError struct {
// contains filtered or unexported fields
}
CadenceDeserializationError is an error type for cadence deserialization
func NewCadenceDeserializationError ¶ added in v0.5.7
func NewCadenceDeserializationError(msg string) *CadenceDeserializationError
NewCadenceDeserializationError returns a CadenceDeserializationError
func (*CadenceDeserializationError) Error ¶ added in v0.5.7
func (e *CadenceDeserializationError) Error() string
type CadenceSerializationError ¶ added in v0.5.7
type CadenceSerializationError struct {
// contains filtered or unexported fields
}
CadenceSerializationError is an error type for cadence serialization
func NewCadenceSerializationError ¶ added in v0.5.7
func NewCadenceSerializationError(msg string) *CadenceSerializationError
NewCadenceSerializationError returns a CadenceSerializationError
func (*CadenceSerializationError) Error ¶ added in v0.5.7
func (e *CadenceSerializationError) Error() string
type CancelExecutionTask ¶
type CancelExecutionTask struct { TaskData TargetDomainID string TargetWorkflowID string TargetRunID string TargetChildWorkflowOnly bool InitiatedID int64 }
CancelExecutionTask identifies a transfer task for cancel of execution
func (*CancelExecutionTask) GetType ¶
func (u *CancelExecutionTask) GetType() int
GetType returns the type of the cancel transfer task
type ChildExecutionInfo ¶
type ChildExecutionInfo struct { Version int64 InitiatedID int64 InitiatedEventBatchID int64 InitiatedEvent *types.HistoryEvent StartedID int64 StartedWorkflowID string StartedRunID string StartedEvent *types.HistoryEvent CreateRequestID string DomainID string DomainNameDEPRECATED string // deprecated: please use DomainID field instead WorkflowTypeName string ParentClosePolicy types.ParentClosePolicy }
ChildExecutionInfo has details for pending child executions.
type CloseExecutionTask ¶ added in v0.3.3
type CloseExecutionTask struct {
TaskData
}
CloseExecutionTask identifies a transfer task for deletion of execution
func (*CloseExecutionTask) GetType ¶ added in v0.3.3
func (a *CloseExecutionTask) GetType() int
GetType returns the type of the close execution task
type Closeable ¶
type Closeable interface {
Close()
}
Closeable is an interface for any entity that supports a close operation to release resources
type ClusterReplicationConfig ¶ added in v0.3.7
type ClusterReplicationConfig struct {
ClusterName string
}
ClusterReplicationConfig describes the cross DC cluster replication configuration
func DeserializeClusterConfigs ¶ added in v0.4.0
func DeserializeClusterConfigs(replicationConfigs []map[string]interface{}) []*ClusterReplicationConfig
DeserializeClusterConfigs creates an array of ClusterReplicationConfigs from an array of map representations
func (*ClusterReplicationConfig) GetCopy ¶ added in v0.12.0
func (config *ClusterReplicationConfig) GetCopy() *ClusterReplicationConfig
GetCopy return a copy of ClusterReplicationConfig
type CompleteCrossClusterTaskRequest ¶ added in v0.22.0
CompleteCrossClusterTaskRequest is used to complete a task in the cross-cluster task queue
type CompleteForkBranchRequest ¶ added in v0.5.2
type CompleteForkBranchRequest struct { // the new branch returned from ForkHistoryBranchRequest BranchToken []byte // true means the fork is success, will update the flag, otherwise will delete the new branch Success bool // The shard to update history branch data ShardID *int }
CompleteForkBranchRequest is used to complete forking
type CompleteReplicationTaskRequest ¶ added in v0.3.11
type CompleteReplicationTaskRequest struct {
TaskID int64
}
CompleteReplicationTaskRequest is used to complete a task in the replication task queue
type CompleteTaskRequest ¶
type CompleteTaskRequest struct { TaskList *TaskListInfo TaskID int64 DomainName string }
CompleteTaskRequest is used to complete a task
func (CompleteTaskRequest) MetricTags ¶ added in v1.2.7
func (r CompleteTaskRequest) MetricTags() []metrics.Tag
type CompleteTasksLessThanRequest ¶ added in v0.5.4
type CompleteTasksLessThanRequest struct { DomainID string TaskListName string TaskType int TaskID int64 // Tasks less than or equal to this ID will be completed Limit int // Limit on the max number of tasks that can be completed. Required param DomainName string }
CompleteTasksLessThanRequest contains the request params needed to invoke CompleteTasksLessThan API
func (CompleteTasksLessThanRequest) MetricTags ¶ added in v1.2.7
func (r CompleteTasksLessThanRequest) MetricTags() []metrics.Tag
type CompleteTasksLessThanResponse ¶ added in v0.23.1
type CompleteTasksLessThanResponse struct {
TasksCompleted int
}
CompleteTasksLessThanResponse is the response of CompleteTasksLessThan
type CompleteTimerTaskRequest ¶
CompleteTimerTaskRequest is used to complete a task in the timer task queue
type CompleteTransferTaskRequest ¶
type CompleteTransferTaskRequest struct {
TaskID int64
}
CompleteTransferTaskRequest is used to complete a task in the transfer task queue
type ConditionFailedError ¶
type ConditionFailedError struct {
Msg string
}
ConditionFailedError represents a failed conditional update for execution record
func (*ConditionFailedError) Error ¶
func (e *ConditionFailedError) Error() string
type ConfigStore ¶ added in v0.23.1
type ConfigStore interface { Closeable FetchConfig(ctx context.Context, configType ConfigType) (*InternalConfigStoreEntry, error) UpdateConfig(ctx context.Context, value *InternalConfigStoreEntry) error }
type ConfigStoreManager ¶ added in v0.23.1
type ConfigStoreManager interface { Closeable FetchDynamicConfig(ctx context.Context, cfgType ConfigType) (*FetchDynamicConfigResponse, error) UpdateDynamicConfig(ctx context.Context, request *UpdateDynamicConfigRequest, cfgType ConfigType) error }
func NewConfigStoreManagerImpl ¶ added in v0.23.1
func NewConfigStoreManagerImpl(persistence ConfigStore, logger log.Logger) ConfigStoreManager
NewConfigStoreManagerImpl returns new ConfigStoreManager
type ConfigType ¶ added in v0.23.1
type ConfigType int
const ( DynamicConfig ConfigType = iota GlobalIsolationGroupConfig )
type ConflictResolveWorkflowExecutionRequest ¶ added in v0.7.0
type ConflictResolveWorkflowExecutionRequest struct { RangeID int64 Mode ConflictResolveWorkflowMode // workflow to be resetted ResetWorkflowSnapshot WorkflowSnapshot // maybe new workflow NewWorkflowSnapshot *WorkflowSnapshot // current workflow CurrentWorkflowMutation *WorkflowMutation WorkflowRequestMode CreateWorkflowRequestMode Encoding common.EncodingType // optional binary encoding type DomainName string }
ConflictResolveWorkflowExecutionRequest is used to reset workflow execution state for a single run
func (ConflictResolveWorkflowExecutionRequest) GetDomainName ¶ added in v1.2.7
func (r ConflictResolveWorkflowExecutionRequest) GetDomainName() string
type ConflictResolveWorkflowExecutionResponse ¶ added in v0.21.0
type ConflictResolveWorkflowExecutionResponse struct {
MutableStateUpdateSessionStats *MutableStateUpdateSessionStats
}
ConflictResolveWorkflowExecutionResponse is response for ConflictResolveWorkflowExecutionRequest
type ConflictResolveWorkflowMode ¶ added in v0.9.3
type ConflictResolveWorkflowMode int
ConflictResolveWorkflowMode conflict resolve mode
const ( // Conflict resolve workflow, including current record // NOTE: update on current record is a condition update ConflictResolveWorkflowModeUpdateCurrent ConflictResolveWorkflowMode = iota // Conflict resolve workflow, without current record // NOTE: current record CANNOT point to the workflow to be updated ConflictResolveWorkflowModeBypassCurrent )
Conflict Resolve Workflow Mode
type CountWorkflowExecutionsRequest ¶ added in v0.5.8
type CountWorkflowExecutionsRequest struct { DomainUUID string Domain string // domain name is not persisted, but used as config filter key Query string }
CountWorkflowExecutionsRequest is request from CountWorkflowExecutions
type CountWorkflowExecutionsResponse ¶ added in v0.5.8
type CountWorkflowExecutionsResponse struct {
Count int64
}
CountWorkflowExecutionsResponse is response to CountWorkflowExecutions
type CreateDomainRequest ¶
type CreateDomainRequest struct { Info *DomainInfo Config *DomainConfig ReplicationConfig *DomainReplicationConfig IsGlobalDomain bool ConfigVersion int64 FailoverVersion int64 LastUpdatedTime int64 }
CreateDomainRequest is used to create the domain
type CreateDomainResponse ¶
type CreateDomainResponse struct {
ID string
}
CreateDomainResponse is the response for CreateDomain
type CreateFailoverMarkersRequest ¶ added in v0.14.0
type CreateFailoverMarkersRequest struct { RangeID int64 Markers []*FailoverMarkerTask }
CreateFailoverMarkersRequest is request to create failover markers
type CreateShardRequest ¶
type CreateShardRequest struct {
ShardInfo *ShardInfo
}
CreateShardRequest is used to create a shard in executions table
type CreateTaskInfo ¶
CreateTaskInfo describes a task to be created in CreateTasksRequest
type CreateTasksRequest ¶
type CreateTasksRequest struct { TaskListInfo *TaskListInfo Tasks []*CreateTaskInfo DomainName string }
CreateTasksRequest is used to create a new task for a workflow exectution
func (CreateTasksRequest) MetricTags ¶ added in v1.2.7
func (r CreateTasksRequest) MetricTags() []metrics.Tag
type CreateTasksResponse ¶
type CreateTasksResponse struct { }
CreateTasksResponse is the response to CreateTasksRequest
type CreateWorkflowExecutionRequest ¶
type CreateWorkflowExecutionRequest struct { RangeID int64 Mode CreateWorkflowMode PreviousRunID string PreviousLastWriteVersion int64 NewWorkflowSnapshot WorkflowSnapshot WorkflowRequestMode CreateWorkflowRequestMode DomainName string }
CreateWorkflowExecutionRequest is used to write a new workflow execution
func (*CreateWorkflowExecutionRequest) GetDomainName ¶ added in v1.2.7
func (r *CreateWorkflowExecutionRequest) GetDomainName() string
func (*CreateWorkflowExecutionRequest) GetExtraLogTags ¶ added in v1.2.7
func (r *CreateWorkflowExecutionRequest) GetExtraLogTags() []tag.Tag
type CreateWorkflowExecutionResponse ¶
type CreateWorkflowExecutionResponse struct {
MutableStateUpdateSessionStats *MutableStateUpdateSessionStats
}
CreateWorkflowExecutionResponse is the response to CreateWorkflowExecutionRequest
type CreateWorkflowMode ¶ added in v0.9.3
type CreateWorkflowMode int
CreateWorkflowMode workflow creation mode
const ( // Fail if current record exists // Only applicable for CreateWorkflowExecution CreateWorkflowModeBrandNew CreateWorkflowMode = iota // Update current record only if workflow is closed // Only applicable for CreateWorkflowExecution CreateWorkflowModeWorkflowIDReuse // Update current record only if workflow is open // Only applicable for UpdateWorkflowExecution CreateWorkflowModeContinueAsNew // Do not update current record since workflow to // applicable for CreateWorkflowExecution, UpdateWorkflowExecution CreateWorkflowModeZombie )
Create Workflow Execution Mode
type CreateWorkflowRequestMode ¶ added in v1.2.9
type CreateWorkflowRequestMode int
CreateWorkflowRequestMode is the mode of create workflow request
const ( // 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 CreateWorkflowRequestModeNew CreateWorkflowRequestMode = iota // Upsert the data without checking duplication // It is used for transactions started by replication stack to achieve // eventual consistency CreateWorkflowRequestModeReplicated )
Modes of create workflow request
type CrossClusterApplyParentClosePolicyTask ¶ added in v0.24.0
type CrossClusterApplyParentClosePolicyTask struct { ApplyParentClosePolicyTask TargetCluster string }
CrossClusterApplyParentClosePolicyTask is the cross-cluster version of ApplyParentClosePolicyTask
func (*CrossClusterApplyParentClosePolicyTask) GetType ¶ added in v0.24.0
func (c *CrossClusterApplyParentClosePolicyTask) GetType() int
GetType returns of type of the cross-cluster cancel task
type CrossClusterCancelExecutionTask ¶ added in v0.22.0
type CrossClusterCancelExecutionTask struct { CancelExecutionTask TargetCluster string }
CrossClusterCancelExecutionTask is the cross-cluster version of CancelExecutionTask
func (*CrossClusterCancelExecutionTask) GetType ¶ added in v0.22.0
func (c *CrossClusterCancelExecutionTask) GetType() int
GetType returns of type of the cross-cluster cancel task
type CrossClusterRecordChildExecutionCompletedTask ¶ added in v0.24.0
type CrossClusterRecordChildExecutionCompletedTask struct { RecordChildExecutionCompletedTask TargetCluster string }
CrossClusterRecordChildExecutionCompletedTask is the cross-cluster version of RecordChildExecutionCompletedTask
func (*CrossClusterRecordChildExecutionCompletedTask) GetType ¶ added in v0.24.0
func (c *CrossClusterRecordChildExecutionCompletedTask) GetType() int
GetType returns of type of the cross-cluster record child workflow completion task
type CrossClusterSignalExecutionTask ¶ added in v0.22.0
type CrossClusterSignalExecutionTask struct { SignalExecutionTask TargetCluster string }
CrossClusterSignalExecutionTask is the cross-cluster version of SignalExecutionTask
func (*CrossClusterSignalExecutionTask) GetType ¶ added in v0.22.0
func (c *CrossClusterSignalExecutionTask) GetType() int
GetType returns of type of the cross-cluster signal task
type CrossClusterStartChildExecutionTask ¶ added in v0.22.0
type CrossClusterStartChildExecutionTask struct { StartChildExecutionTask TargetCluster string }
CrossClusterStartChildExecutionTask is the cross-cluster version of StartChildExecutionTask
func (*CrossClusterStartChildExecutionTask) GetType ¶ added in v0.22.0
func (c *CrossClusterStartChildExecutionTask) GetType() int
GetType returns of type of the cross-cluster start child task
type CrossClusterTaskInfo ¶ added in v0.22.0
type CrossClusterTaskInfo = TransferTaskInfo
CrossClusterTaskInfo describes a cross-cluster task Cross cluster tasks are exactly like transfer tasks so instead of creating another struct and duplicating the same logic everywhere. We reuse TransferTaskInfo
type CurrentWorkflowConditionFailedError ¶ added in v0.4.0
type CurrentWorkflowConditionFailedError struct {
Msg string
}
CurrentWorkflowConditionFailedError represents a failed conditional update for current workflow record
func (*CurrentWorkflowConditionFailedError) Error ¶ added in v0.4.0
func (e *CurrentWorkflowConditionFailedError) Error() string
type CurrentWorkflowExecution ¶ added in v0.14.0
type CurrentWorkflowExecution struct { DomainID string WorkflowID string RunID string State int CurrentRunID string }
CurrentWorkflowExecution describes a current execution record
type DBUnavailableError ¶ added in v0.25.0
type DBUnavailableError struct {
}DBUnavailableError is returned when the database is unavailable, could be for various reasons.
func (*DBUnavailableError) Error ¶ added in v0.25.0
func (e *DBUnavailableError) Error() string
type DataBlob ¶ added in v0.4.0
type DataBlob struct { Encoding common.EncodingType Data []byte }
DataBlob represents a blob for any binary data. It contains raw data, and metadata(right now only encoding) in other field Note that it should be only used for Persistence layer, below dataInterface and application(historyEngine/etc)
func NewDataBlob ¶ added in v0.4.0
func NewDataBlob(data []byte, encodingType common.EncodingType) *DataBlob
NewDataBlob returns a new DataBlob
func NewDataBlobFromInternal ¶ added in v0.18.0
NewDataBlobFromInternal convert data blob from internal representation
func (*DataBlob) GetEncoding ¶ added in v0.4.0
func (d *DataBlob) GetEncoding() common.EncodingType
GetEncoding returns encoding type
func (*DataBlob) GetEncodingString ¶ added in v0.22.0
func (*DataBlob) ToInternal ¶ added in v0.18.0
ToInternal convert data blob to internal representation
func (*DataBlob) ToNilSafeDataBlob ¶ added in v0.22.0
Convert a *Datablob to safe that calling its method won't run into NPE
type DecisionTask ¶
type DecisionTask struct { TaskData DomainID string TaskList string ScheduleID int64 RecordVisibility bool }
DecisionTask identifies a transfer task for decision
func (*DecisionTask) GetType ¶
func (d *DecisionTask) GetType() int
GetType returns the type of the decision task
func (*DecisionTask) GetVersion ¶ added in v0.3.12
func (d *DecisionTask) GetVersion() int64
GetVersion returns the version of the decision task
type DecisionTimeoutTask ¶
DecisionTimeoutTask identifies a timeout task.
func (*DecisionTimeoutTask) GetType ¶
func (d *DecisionTimeoutTask) GetType() int
GetType returns the type of the timer task
type DeleteCurrentWorkflowExecutionRequest ¶ added in v0.5.8
type DeleteCurrentWorkflowExecutionRequest struct { DomainID string WorkflowID string RunID string DomainName string }
DeleteCurrentWorkflowExecutionRequest is used to delete the current workflow execution
func (DeleteCurrentWorkflowExecutionRequest) GetDomainName ¶ added in v1.2.7
func (r DeleteCurrentWorkflowExecutionRequest) GetDomainName() string
func (DeleteCurrentWorkflowExecutionRequest) GetExtraLogTags ¶ added in v1.2.7
func (r DeleteCurrentWorkflowExecutionRequest) GetExtraLogTags() []tag.Tag
type DeleteDomainByNameRequest ¶
type DeleteDomainByNameRequest struct {
Name string
}
DeleteDomainByNameRequest is used to delete domain entry from domains_by_name table
type DeleteDomainRequest ¶
type DeleteDomainRequest struct {
ID string
}
DeleteDomainRequest is used to delete domain entry from domains table
type DeleteHistoryBranchRequest ¶ added in v0.5.0
type DeleteHistoryBranchRequest struct { // branch to be deleted BranchToken []byte // The shard to delete history branch data ShardID *int // DomainName to generate metrics for Domain Cost Attribution DomainName string }
DeleteHistoryBranchRequest is used to remove a history branch
func (DeleteHistoryBranchRequest) MetricTags ¶ added in v1.2.7
func (r DeleteHistoryBranchRequest) MetricTags() []metrics.Tag
type DeleteHistoryEventTask ¶
type DeleteHistoryEventTask struct {
TaskData
}
DeleteHistoryEventTask identifies a timer task for deletion of history events of completed execution.
func (*DeleteHistoryEventTask) GetType ¶
func (a *DeleteHistoryEventTask) GetType() int
GetType returns the type of the delete execution task
type DeleteReplicationTaskFromDLQRequest ¶ added in v0.12.0
DeleteReplicationTaskFromDLQRequest is used to delete replication task from DLQ
type DeleteTaskListRequest ¶ added in v0.5.4
type DeleteTaskListRequest struct { DomainID string DomainName string TaskListName string TaskListType int RangeID int64 }
DeleteTaskListRequest contains the request params needed to invoke DeleteTaskList API
func (DeleteTaskListRequest) MetricTags ¶ added in v1.2.7
func (r DeleteTaskListRequest) MetricTags() []metrics.Tag
type DeleteWorkflowExecutionRequest ¶
type DeleteWorkflowExecutionRequest struct { DomainID string WorkflowID string RunID string DomainName string }
DeleteWorkflowExecutionRequest is used to delete a workflow execution
func (DeleteWorkflowExecutionRequest) GetDomainName ¶ added in v1.2.7
func (r DeleteWorkflowExecutionRequest) GetDomainName() string
func (DeleteWorkflowExecutionRequest) GetExtraLogTags ¶ added in v1.2.7
func (r DeleteWorkflowExecutionRequest) GetExtraLogTags() []tag.Tag
type DomainConfig ¶
type DomainConfig struct { // NOTE: this retention is in days, not in seconds Retention int32 EmitMetric bool HistoryArchivalStatus types.ArchivalStatus HistoryArchivalURI string VisibilityArchivalStatus types.ArchivalStatus VisibilityArchivalURI string BadBinaries types.BadBinaries IsolationGroups types.IsolationGroupConfiguration AsyncWorkflowConfig types.AsyncWorkflowConfiguration }
DomainConfig describes the domain configuration
type DomainInfo ¶
type DomainInfo struct { ID string Name string Status int Description string OwnerEmail string Data map[string]string }
DomainInfo describes the domain entity
type DomainManager ¶ added in v0.22.0
type DomainManager interface { Closeable GetName() string CreateDomain(ctx context.Context, request *CreateDomainRequest) (*CreateDomainResponse, error) GetDomain(ctx context.Context, request *GetDomainRequest) (*GetDomainResponse, error) UpdateDomain(ctx context.Context, request *UpdateDomainRequest) error DeleteDomain(ctx context.Context, request *DeleteDomainRequest) error DeleteDomainByName(ctx context.Context, request *DeleteDomainByNameRequest) error ListDomains(ctx context.Context, request *ListDomainsRequest) (*ListDomainsResponse, error) GetMetadata(ctx context.Context) (*GetMetadataResponse, error) }
DomainManager is used to manage metadata CRUD for domain entities
func NewDomainManagerImpl ¶ added in v0.22.0
func NewDomainManagerImpl(persistence DomainStore, logger log.Logger) DomainManager
NewDomainManagerImpl returns new DomainManager
type DomainReplicationConfig ¶ added in v0.3.7
type DomainReplicationConfig struct { ActiveClusterName string Clusters []*ClusterReplicationConfig }
DomainReplicationConfig describes the cross DC domain replication configuration
type DomainStore ¶ added in v0.23.1
type DomainStore interface { Closeable GetName() string CreateDomain(ctx context.Context, request *InternalCreateDomainRequest) (*CreateDomainResponse, error) GetDomain(ctx context.Context, request *GetDomainRequest) (*InternalGetDomainResponse, error) UpdateDomain(ctx context.Context, request *InternalUpdateDomainRequest) error DeleteDomain(ctx context.Context, request *DeleteDomainRequest) error DeleteDomainByName(ctx context.Context, request *DeleteDomainByNameRequest) error ListDomains(ctx context.Context, request *ListDomainsRequest) (*InternalListDomainsResponse, error) GetMetadata(ctx context.Context) (*GetMetadataResponse, error) }
DomainStore is a lower level of DomainManager
type DuplicateRequestError ¶ added in v1.2.9
type DuplicateRequestError struct { RequestType WorkflowRequestType RunID string }
func AsDuplicateRequestError ¶ added in v1.2.10
func AsDuplicateRequestError(err error) (*DuplicateRequestError, bool)
func (*DuplicateRequestError) Error ¶ added in v1.2.9
func (e *DuplicateRequestError) Error() string
type DynamicConfigSnapshot ¶ added in v0.23.1
type DynamicConfigSnapshot struct { Version int64 Values *types.DynamicConfigBlob }
type DynamicConfiguration ¶ added in v0.25.0
type DynamicConfiguration struct { EnableSQLAsyncTransaction dynamicconfig.BoolPropertyFn EnableCassandraAllConsistencyLevelDelete dynamicconfig.BoolPropertyFn PersistenceSampleLoggingRate dynamicconfig.IntPropertyFn EnableShardIDMetrics dynamicconfig.BoolPropertyFn }
DynamicConfiguration represents dynamic configuration for persistence layer
func NewDynamicConfiguration ¶ added in v0.25.0
func NewDynamicConfiguration(dc *dynamicconfig.Collection) *DynamicConfiguration
NewDynamicConfiguration returns new config with default values
type ExecutionManager ¶
type ExecutionManager interface { Closeable GetName() string GetShardID() int CreateWorkflowExecution(ctx context.Context, request *CreateWorkflowExecutionRequest) (*CreateWorkflowExecutionResponse, error) GetWorkflowExecution(ctx context.Context, request *GetWorkflowExecutionRequest) (*GetWorkflowExecutionResponse, error) UpdateWorkflowExecution(ctx context.Context, request *UpdateWorkflowExecutionRequest) (*UpdateWorkflowExecutionResponse, error) ConflictResolveWorkflowExecution(ctx context.Context, request *ConflictResolveWorkflowExecutionRequest) (*ConflictResolveWorkflowExecutionResponse, error) DeleteWorkflowExecution(ctx context.Context, request *DeleteWorkflowExecutionRequest) error DeleteCurrentWorkflowExecution(ctx context.Context, request *DeleteCurrentWorkflowExecutionRequest) error GetCurrentExecution(ctx context.Context, request *GetCurrentExecutionRequest) (*GetCurrentExecutionResponse, error) IsWorkflowExecutionExists(ctx context.Context, request *IsWorkflowExecutionExistsRequest) (*IsWorkflowExecutionExistsResponse, error) // Transfer task related methods GetTransferTasks(ctx context.Context, request *GetTransferTasksRequest) (*GetTransferTasksResponse, error) CompleteTransferTask(ctx context.Context, request *CompleteTransferTaskRequest) error RangeCompleteTransferTask(ctx context.Context, request *RangeCompleteTransferTaskRequest) (*RangeCompleteTransferTaskResponse, error) // Cross-cluster related methods GetCrossClusterTasks(ctx context.Context, request *GetCrossClusterTasksRequest) (*GetCrossClusterTasksResponse, error) CompleteCrossClusterTask(ctx context.Context, request *CompleteCrossClusterTaskRequest) error RangeCompleteCrossClusterTask(ctx context.Context, request *RangeCompleteCrossClusterTaskRequest) (*RangeCompleteCrossClusterTaskResponse, error) // Replication task related methods GetReplicationTasks(ctx context.Context, request *GetReplicationTasksRequest) (*GetReplicationTasksResponse, error) CompleteReplicationTask(ctx context.Context, request *CompleteReplicationTaskRequest) error RangeCompleteReplicationTask(ctx context.Context, request *RangeCompleteReplicationTaskRequest) (*RangeCompleteReplicationTaskResponse, error) PutReplicationTaskToDLQ(ctx context.Context, request *PutReplicationTaskToDLQRequest) error GetReplicationTasksFromDLQ(ctx context.Context, request *GetReplicationTasksFromDLQRequest) (*GetReplicationTasksFromDLQResponse, error) GetReplicationDLQSize(ctx context.Context, request *GetReplicationDLQSizeRequest) (*GetReplicationDLQSizeResponse, error) DeleteReplicationTaskFromDLQ(ctx context.Context, request *DeleteReplicationTaskFromDLQRequest) error RangeDeleteReplicationTaskFromDLQ(ctx context.Context, request *RangeDeleteReplicationTaskFromDLQRequest) (*RangeDeleteReplicationTaskFromDLQResponse, error) CreateFailoverMarkerTasks(ctx context.Context, request *CreateFailoverMarkersRequest) error // Timer related methods. GetTimerIndexTasks(ctx context.Context, request *GetTimerIndexTasksRequest) (*GetTimerIndexTasksResponse, error) CompleteTimerTask(ctx context.Context, request *CompleteTimerTaskRequest) error RangeCompleteTimerTask(ctx context.Context, request *RangeCompleteTimerTaskRequest) (*RangeCompleteTimerTaskResponse, error) // Scan operations ListConcreteExecutions(ctx context.Context, request *ListConcreteExecutionsRequest) (*ListConcreteExecutionsResponse, error) ListCurrentExecutions(ctx context.Context, request *ListCurrentExecutionsRequest) (*ListCurrentExecutionsResponse, error) }
ExecutionManager is used to manage workflow executions
func NewExecutionManagerImpl ¶ added in v0.4.0
func NewExecutionManagerImpl( persistence ExecutionStore, logger log.Logger, serializer PayloadSerializer, ) ExecutionManager
NewExecutionManagerImpl returns new ExecutionManager
type ExecutionManagerFactory ¶
type ExecutionManagerFactory interface { Closeable NewExecutionManager(shardID int) (ExecutionManager, error) }
ExecutionManagerFactory creates an instance of ExecutionManager for a given shard
type ExecutionStats ¶ added in v0.7.0
type ExecutionStats struct {
HistorySize int64
}
ExecutionStats is the statistics about workflow execution
type ExecutionStore ¶ added in v0.4.0
type ExecutionStore interface { Closeable GetName() string GetShardID() int // The below three APIs are related to serialization/deserialization GetWorkflowExecution(ctx context.Context, request *InternalGetWorkflowExecutionRequest) (*InternalGetWorkflowExecutionResponse, error) UpdateWorkflowExecution(ctx context.Context, request *InternalUpdateWorkflowExecutionRequest) error ConflictResolveWorkflowExecution(ctx context.Context, request *InternalConflictResolveWorkflowExecutionRequest) error CreateWorkflowExecution(ctx context.Context, request *InternalCreateWorkflowExecutionRequest) (*CreateWorkflowExecutionResponse, error) DeleteWorkflowExecution(ctx context.Context, request *DeleteWorkflowExecutionRequest) error DeleteCurrentWorkflowExecution(ctx context.Context, request *DeleteCurrentWorkflowExecutionRequest) error GetCurrentExecution(ctx context.Context, request *GetCurrentExecutionRequest) (*GetCurrentExecutionResponse, error) IsWorkflowExecutionExists(ctx context.Context, request *IsWorkflowExecutionExistsRequest) (*IsWorkflowExecutionExistsResponse, error) // Transfer task related methods GetTransferTasks(ctx context.Context, request *GetTransferTasksRequest) (*GetTransferTasksResponse, error) CompleteTransferTask(ctx context.Context, request *CompleteTransferTaskRequest) error RangeCompleteTransferTask(ctx context.Context, request *RangeCompleteTransferTaskRequest) (*RangeCompleteTransferTaskResponse, error) // Cross-cluster task related methods GetCrossClusterTasks(ctx context.Context, request *GetCrossClusterTasksRequest) (*GetCrossClusterTasksResponse, error) CompleteCrossClusterTask(ctx context.Context, request *CompleteCrossClusterTaskRequest) error RangeCompleteCrossClusterTask(ctx context.Context, request *RangeCompleteCrossClusterTaskRequest) (*RangeCompleteCrossClusterTaskResponse, error) // Replication task related methods GetReplicationTasks(ctx context.Context, request *GetReplicationTasksRequest) (*InternalGetReplicationTasksResponse, error) CompleteReplicationTask(ctx context.Context, request *CompleteReplicationTaskRequest) error RangeCompleteReplicationTask(ctx context.Context, request *RangeCompleteReplicationTaskRequest) (*RangeCompleteReplicationTaskResponse, error) PutReplicationTaskToDLQ(ctx context.Context, request *InternalPutReplicationTaskToDLQRequest) error GetReplicationTasksFromDLQ(ctx context.Context, request *GetReplicationTasksFromDLQRequest) (*InternalGetReplicationTasksFromDLQResponse, error) GetReplicationDLQSize(ctx context.Context, request *GetReplicationDLQSizeRequest) (*GetReplicationDLQSizeResponse, error) DeleteReplicationTaskFromDLQ(ctx context.Context, request *DeleteReplicationTaskFromDLQRequest) error RangeDeleteReplicationTaskFromDLQ(ctx context.Context, request *RangeDeleteReplicationTaskFromDLQRequest) (*RangeDeleteReplicationTaskFromDLQResponse, error) CreateFailoverMarkerTasks(ctx context.Context, request *CreateFailoverMarkersRequest) error // Timer related methods. GetTimerIndexTasks(ctx context.Context, request *GetTimerIndexTasksRequest) (*GetTimerIndexTasksResponse, error) CompleteTimerTask(ctx context.Context, request *CompleteTimerTaskRequest) error RangeCompleteTimerTask(ctx context.Context, request *RangeCompleteTimerTaskRequest) (*RangeCompleteTimerTaskResponse, error) // Scan related methods ListConcreteExecutions(ctx context.Context, request *ListConcreteExecutionsRequest) (*InternalListConcreteExecutionsResponse, error) ListCurrentExecutions(ctx context.Context, request *ListCurrentExecutionsRequest) (*ListCurrentExecutionsResponse, error) }
ExecutionStore is used to manage workflow executions for Persistence layer
type FailoverMarkerTask ¶ added in v0.13.0
FailoverMarkerTask is the marker for graceful failover
func (*FailoverMarkerTask) GetType ¶ added in v0.13.0
func (a *FailoverMarkerTask) GetType() int
GetType returns the type of the history replication task
type FetchDynamicConfigResponse ¶ added in v0.23.1
type FetchDynamicConfigResponse struct {
Snapshot *DynamicConfigSnapshot
}
FetchDynamicConfigResponse is a response to FetchDynamicConfigResponse
type ForkHistoryBranchRequest ¶ added in v0.5.0
type ForkHistoryBranchRequest struct { // The base branch to fork from ForkBranchToken []byte // The nodeID to fork from, the new branch will start from ( inclusive ), the base branch will stop at(exclusive) // Application must provide a void forking nodeID, it must be a valid nodeID in that branch. A valid nodeID is the firstEventID of a valid batch of events. // And ForkNodeID > 1 because forking from 1 doesn't make any sense. ForkNodeID int64 // the info for clean up data in background Info string // The shard to get history branch data ShardID *int // DomainName to create metrics for Domain Cost Attribution DomainName string }
ForkHistoryBranchRequest is used to fork a history branch
func (ForkHistoryBranchRequest) MetricTags ¶ added in v1.2.7
func (r ForkHistoryBranchRequest) MetricTags() []metrics.Tag
type ForkHistoryBranchResponse ¶ added in v0.5.0
type ForkHistoryBranchResponse struct { // branchToken to represent the new branch NewBranchToken []byte }
ForkHistoryBranchResponse is the response to ForkHistoryBranchRequest
type GetAllHistoryTreeBranchesRequest ¶ added in v0.9.0
type GetAllHistoryTreeBranchesRequest struct { // pagination token NextPageToken []byte // maximum number of branches returned per page PageSize int }
GetAllHistoryTreeBranchesRequest is a request of GetAllHistoryTreeBranches
type GetAllHistoryTreeBranchesResponse ¶ added in v0.9.0
type GetAllHistoryTreeBranchesResponse struct { // pagination token NextPageToken []byte // all branches of all trees Branches []HistoryBranchDetail }
GetAllHistoryTreeBranchesResponse is a response to GetAllHistoryTreeBranches
func (GetAllHistoryTreeBranchesResponse) Len ¶ added in v1.2.7
func (r GetAllHistoryTreeBranchesResponse) Len() int
type GetClosedWorkflowExecutionRequest ¶
type GetClosedWorkflowExecutionRequest struct { DomainUUID string Domain string // domain name is not persisted, but used as config filter key Execution types.WorkflowExecution }
GetClosedWorkflowExecutionRequest is used retrieve the record for a specific execution
type GetClosedWorkflowExecutionResponse ¶
type GetClosedWorkflowExecutionResponse struct {
Execution *types.WorkflowExecutionInfo
}
GetClosedWorkflowExecutionResponse is the response to GetClosedWorkflowExecutionRequest
type GetCrossClusterTasksRequest ¶ added in v0.22.0
type GetCrossClusterTasksRequest struct { TargetCluster string ReadLevel int64 MaxReadLevel int64 BatchSize int NextPageToken []byte }
GetCrossClusterTasksRequest is used to read tasks from the cross-cluster task queue
type GetCrossClusterTasksResponse ¶ added in v0.22.0
type GetCrossClusterTasksResponse struct { Tasks []*CrossClusterTaskInfo NextPageToken []byte }
GetCrossClusterTasksResponse is the response to GetCrossClusterTasksRequest
func (*GetCrossClusterTasksResponse) Len ¶ added in v1.2.7
func (r *GetCrossClusterTasksResponse) Len() int
type GetCurrentExecutionRequest ¶
GetCurrentExecutionRequest is used to retrieve the current RunId for an execution
func (GetCurrentExecutionRequest) GetDomainName ¶ added in v1.2.7
func (r GetCurrentExecutionRequest) GetDomainName() string
func (GetCurrentExecutionRequest) GetExtraLogTags ¶ added in v1.2.7
func (r GetCurrentExecutionRequest) GetExtraLogTags() []tag.Tag
type GetCurrentExecutionResponse ¶
type GetCurrentExecutionResponse struct { StartRequestID string RunID string State int CloseStatus int LastWriteVersion int64 }
GetCurrentExecutionResponse is the response to GetCurrentExecution
type GetDomainRequest ¶
GetDomainRequest is used to read domain
type GetDomainResponse ¶
type GetDomainResponse struct { Info *DomainInfo Config *DomainConfig ReplicationConfig *DomainReplicationConfig IsGlobalDomain bool ConfigVersion int64 FailoverVersion int64 FailoverNotificationVersion int64 PreviousFailoverVersion int64 FailoverEndTime *int64 LastUpdatedTime int64 NotificationVersion int64 }
GetDomainResponse is the response for GetDomain
type GetHistoryTreeRequest ¶ added in v0.5.0
type GetHistoryTreeRequest struct { // A UUID of a tree TreeID string // Get data from this shard ShardID *int // optional: can provide treeID via branchToken if treeID is empty BranchToken []byte // DomainName to create metrics DomainName string }
GetHistoryTreeRequest is used to retrieve branch info of a history tree
func (GetHistoryTreeRequest) MetricTags ¶ added in v1.2.7
func (r GetHistoryTreeRequest) MetricTags() []metrics.Tag
type GetHistoryTreeResponse ¶ added in v0.5.0
type GetHistoryTreeResponse struct { // all branches of a tree Branches []*workflow.HistoryBranch }
GetHistoryTreeResponse is a response to GetHistoryTreeRequest
type GetMetadataResponse ¶ added in v0.3.13
type GetMetadataResponse struct {
NotificationVersion int64
}
GetMetadataResponse is the response for GetMetadata
type GetOrphanTasksRequest ¶ added in v0.21.0
type GetOrphanTasksRequest struct {
Limit int
}
GetOrphanTasksRequest contains the request params need to invoke the GetOrphanTasks API
type GetOrphanTasksResponse ¶ added in v0.21.0
type GetOrphanTasksResponse struct {
Tasks []*TaskKey
}
GetOrphanTasksResponse is the response to GetOrphanTasksRequests
type GetReplicationDLQSizeRequest ¶ added in v0.14.0
type GetReplicationDLQSizeRequest struct {
SourceClusterName string
}
GetReplicationDLQSizeRequest is used to get one replication task from dlq
type GetReplicationDLQSizeResponse ¶ added in v0.14.0
type GetReplicationDLQSizeResponse struct {
Size int64
}
GetReplicationDLQSizeResponse is the response for GetReplicationDLQSize
type GetReplicationTasksFromDLQRequest ¶ added in v0.11.0
type GetReplicationTasksFromDLQRequest struct { SourceClusterName string GetReplicationTasksRequest }
GetReplicationTasksFromDLQRequest is used to get replication tasks from dlq
func NewGetReplicationTasksFromDLQRequest ¶ added in v0.11.0
func NewGetReplicationTasksFromDLQRequest( sourceClusterName string, readLevel int64, maxReadLevel int64, batchSize int, nextPageToken []byte, ) *GetReplicationTasksFromDLQRequest
NewGetReplicationTasksFromDLQRequest creates a new GetReplicationTasksFromDLQRequest
type GetReplicationTasksFromDLQResponse ¶ added in v0.11.0
type GetReplicationTasksFromDLQResponse = GetReplicationTasksResponse
GetReplicationTasksFromDLQResponse is the response for GetReplicationTasksFromDLQ
type GetReplicationTasksRequest ¶ added in v0.3.11
type GetReplicationTasksRequest struct { ReadLevel int64 MaxReadLevel int64 BatchSize int NextPageToken []byte }
GetReplicationTasksRequest is used to read tasks from the replication task queue
type GetReplicationTasksResponse ¶ added in v0.3.11
type GetReplicationTasksResponse struct { Tasks []*ReplicationTaskInfo NextPageToken []byte }
GetReplicationTasksResponse is the response to GetReplicationTask
func (*GetReplicationTasksResponse) Len ¶ added in v1.2.7
func (r *GetReplicationTasksResponse) Len() int
type GetShardRequest ¶
type GetShardRequest struct {
ShardID int
}
GetShardRequest is used to get shard information
type GetShardResponse ¶
type GetShardResponse struct {
ShardInfo *ShardInfo
}
GetShardResponse is the response to GetShard
type GetTaskListSizeRequest ¶ added in v1.2.6
type GetTaskListSizeRequest struct { DomainID string DomainName string TaskListName string TaskListType int AckLevel int64 }
func (GetTaskListSizeRequest) MetricTags ¶ added in v1.2.10
func (r GetTaskListSizeRequest) MetricTags() []metrics.Tag
type GetTaskListSizeResponse ¶ added in v1.2.6
type GetTaskListSizeResponse struct {
Size int64
}
type GetTasksRequest ¶
type GetTasksRequest struct { DomainID string TaskList string TaskType int ReadLevel int64 // range exclusive MaxReadLevel *int64 // optional: range inclusive when specified BatchSize int DomainName string }
GetTasksRequest is used to retrieve tasks of a task list
func (GetTasksRequest) MetricTags ¶ added in v1.2.7
func (r GetTasksRequest) MetricTags() []metrics.Tag
type GetTasksResponse ¶
type GetTasksResponse struct {
Tasks []*TaskInfo
}
GetTasksResponse is the response to GetTasksRequests
func (*GetTasksResponse) Len ¶ added in v1.2.7
func (r *GetTasksResponse) Len() int
type GetTimerIndexTasksRequest ¶
type GetTimerIndexTasksRequest struct { MinTimestamp time.Time MaxTimestamp time.Time BatchSize int NextPageToken []byte }
GetTimerIndexTasksRequest is the request for GetTimerIndexTasks TODO: replace this with an iterator that can configure min and max index.
type GetTimerIndexTasksResponse ¶
type GetTimerIndexTasksResponse struct { Timers []*TimerTaskInfo NextPageToken []byte }
GetTimerIndexTasksResponse is the response for GetTimerIndexTasks
func (*GetTimerIndexTasksResponse) Len ¶ added in v1.2.7
func (r *GetTimerIndexTasksResponse) Len() int
type GetTransferTasksRequest ¶
type GetTransferTasksRequest struct { ReadLevel int64 MaxReadLevel int64 BatchSize int NextPageToken []byte }
GetTransferTasksRequest is used to read tasks from the transfer task queue
type GetTransferTasksResponse ¶
type GetTransferTasksResponse struct { Tasks []*TransferTaskInfo NextPageToken []byte }
GetTransferTasksResponse is the response to GetTransferTasksRequest
func (*GetTransferTasksResponse) Len ¶ added in v1.2.7
func (r *GetTransferTasksResponse) Len() int
type GetWorkflowExecutionRequest ¶
type GetWorkflowExecutionRequest struct { DomainID string Execution types.WorkflowExecution DomainName string RangeID int64 }
GetWorkflowExecutionRequest is used to retrieve the info of a workflow execution
func (GetWorkflowExecutionRequest) GetDomainName ¶ added in v1.2.7
func (r GetWorkflowExecutionRequest) GetDomainName() string
func (GetWorkflowExecutionRequest) GetExtraLogTags ¶ added in v1.2.7
func (r GetWorkflowExecutionRequest) GetExtraLogTags() []tag.Tag
type GetWorkflowExecutionResponse ¶
type GetWorkflowExecutionResponse struct { State *WorkflowMutableState MutableStateStats *MutableStateStats }
GetWorkflowExecutionResponse is the response to GetworkflowExecutionRequest
type HistoryBranchDetail ¶ added in v0.9.0
HistoryBranchDetail contains detailed information of a branch
type HistoryManager ¶
type HistoryManager interface { Closeable GetName() string // AppendHistoryNodes add(or override) a batch of nodes to a history branch AppendHistoryNodes(ctx context.Context, request *AppendHistoryNodesRequest) (*AppendHistoryNodesResponse, error) // ReadHistoryBranch returns history node data for a branch ReadHistoryBranch(ctx context.Context, request *ReadHistoryBranchRequest) (*ReadHistoryBranchResponse, error) // ReadHistoryBranchByBatch returns history node data for a branch ByBatch ReadHistoryBranchByBatch(ctx context.Context, request *ReadHistoryBranchRequest) (*ReadHistoryBranchByBatchResponse, error) // ReadRawHistoryBranch returns history node raw data for a branch ByBatch // NOTE: this API should only be used by 3+DC ReadRawHistoryBranch(ctx context.Context, request *ReadHistoryBranchRequest) (*ReadRawHistoryBranchResponse, error) // ForkHistoryBranch forks a new branch from a old branch ForkHistoryBranch(ctx context.Context, request *ForkHistoryBranchRequest) (*ForkHistoryBranchResponse, error) // DeleteHistoryBranch removes a branch // If this is the last branch to delete, it will also remove the root node DeleteHistoryBranch(ctx context.Context, request *DeleteHistoryBranchRequest) error // GetHistoryTree returns all branch information of a tree GetHistoryTree(ctx context.Context, request *GetHistoryTreeRequest) (*GetHistoryTreeResponse, error) // GetAllHistoryTreeBranches returns all branches of all trees GetAllHistoryTreeBranches(ctx context.Context, request *GetAllHistoryTreeBranchesRequest) (*GetAllHistoryTreeBranchesResponse, error) }
HistoryManager is used to manager workflow history events
func NewHistoryV2ManagerImpl ¶ added in v0.5.0
func NewHistoryV2ManagerImpl( persistence HistoryStore, logger log.Logger, transactionSizeLimit dynamicconfig.IntPropertyFn, ) HistoryManager
NewHistoryV2ManagerImpl returns new HistoryManager
type HistoryReplicationTask ¶ added in v0.3.11
type HistoryReplicationTask struct { TaskData FirstEventID int64 NextEventID int64 BranchToken []byte NewRunBranchToken []byte }
HistoryReplicationTask is the replication task created for shipping history replication events to other clusters
func (*HistoryReplicationTask) GetType ¶ added in v0.3.11
func (a *HistoryReplicationTask) GetType() int
GetType returns the type of the history replication task
type HistoryStore ¶ added in v0.4.0
type HistoryStore interface { Closeable GetName() string // AppendHistoryNodes add(or override) a node to a history branch AppendHistoryNodes(ctx context.Context, request *InternalAppendHistoryNodesRequest) error // ReadHistoryBranch returns history node data for a branch ReadHistoryBranch(ctx context.Context, request *InternalReadHistoryBranchRequest) (*InternalReadHistoryBranchResponse, error) // ForkHistoryBranch forks a new branch from a old branch ForkHistoryBranch(ctx context.Context, request *InternalForkHistoryBranchRequest) (*InternalForkHistoryBranchResponse, error) // DeleteHistoryBranch removes a branch DeleteHistoryBranch(ctx context.Context, request *InternalDeleteHistoryBranchRequest) error // GetHistoryTree returns all branch information of a tree GetHistoryTree(ctx context.Context, request *InternalGetHistoryTreeRequest) (*InternalGetHistoryTreeResponse, error) // GetAllHistoryTreeBranches returns all branches of all trees GetAllHistoryTreeBranches(ctx context.Context, request *GetAllHistoryTreeBranchesRequest) (*GetAllHistoryTreeBranchesResponse, error) }
HistoryStore is to manager workflow history events
type InternalActivityInfo ¶ added in v0.4.0
type InternalActivityInfo struct { Version int64 ScheduleID int64 ScheduledEventBatchID int64 ScheduledEvent *DataBlob ScheduledTime time.Time StartedID int64 StartedEvent *DataBlob StartedTime time.Time ActivityID string RequestID string Details []byte ScheduleToStartTimeout time.Duration ScheduleToCloseTimeout time.Duration StartToCloseTimeout time.Duration HeartbeatTimeout time.Duration CancelRequested bool CancelRequestID int64 LastHeartBeatUpdatedTime time.Time TimerTaskStatus int32 // For retry Attempt int32 DomainID string StartedIdentity string TaskList string HasRetryPolicy bool InitialInterval time.Duration BackoffCoefficient float64 MaximumInterval time.Duration ExpirationTime time.Time MaximumAttempts int32 NonRetriableErrors []string LastFailureReason string LastWorkerIdentity string LastFailureDetails []byte // Not written to database - This is used only for deduping heartbeat timer creation LastHeartbeatTimeoutVisibilityInSeconds int64 }
InternalActivityInfo details for Persistence Interface
type InternalAppendHistoryEventsRequest ¶ added in v0.4.0
type InternalAppendHistoryEventsRequest struct { DomainID string Execution workflow.WorkflowExecution FirstEventID int64 EventBatchVersion int64 RangeID int64 TransactionID int64 Events *DataBlob Overwrite bool }
InternalAppendHistoryEventsRequest is used to append new events to workflow execution history for Persistence Interface
type InternalAppendHistoryNodesRequest ¶ added in v0.5.0
type InternalAppendHistoryNodesRequest struct { // True if it is the first append request to the branch IsNewBranch bool // The info for clean up data in background Info string // The branch to be appended BranchInfo types.HistoryBranch // The first eventID becomes the nodeID to be appended NodeID int64 // The events to be appended Events *DataBlob // Requested TransactionID for conditional update TransactionID int64 // Used in sharded data stores to identify which shard to use ShardID int }
InternalAppendHistoryNodesRequest is used to append a batch of history nodes
type InternalChildExecutionInfo ¶ added in v0.4.0
type InternalChildExecutionInfo struct { Version int64 InitiatedID int64 InitiatedEventBatchID int64 InitiatedEvent *DataBlob StartedID int64 StartedWorkflowID string StartedRunID string StartedEvent *DataBlob CreateRequestID string DomainID string DomainNameDEPRECATED string // deprecated: use DomainID field WorkflowTypeName string ParentClosePolicy types.ParentClosePolicy }
InternalChildExecutionInfo has details for pending child executions for Persistence Interface
type InternalCompleteForkBranchRequest ¶ added in v0.5.2
type InternalCompleteForkBranchRequest struct { // branch to be updated BranchInfo workflow.HistoryBranch // whether fork is successful Success bool // Used in sharded data stores to identify which shard to use ShardID int }
InternalCompleteForkBranchRequest is used to update some tree/branch meta data for forking
type InternalConfigStoreEntry ¶ added in v0.23.1
type InternalConflictResolveWorkflowExecutionRequest ¶ added in v0.7.0
type InternalConflictResolveWorkflowExecutionRequest struct { RangeID int64 Mode ConflictResolveWorkflowMode // workflow to be resetted ResetWorkflowSnapshot InternalWorkflowSnapshot // maybe new workflow NewWorkflowSnapshot *InternalWorkflowSnapshot // current workflow CurrentWorkflowMutation *InternalWorkflowMutation WorkflowRequestMode CreateWorkflowRequestMode }
InternalConflictResolveWorkflowExecutionRequest is used to reset workflow execution state for Persistence Interface
type InternalCreateDomainRequest ¶ added in v0.5.8
type InternalCreateDomainRequest struct { Info *DomainInfo Config *InternalDomainConfig ReplicationConfig *DomainReplicationConfig IsGlobalDomain bool ConfigVersion int64 FailoverVersion int64 LastUpdatedTime time.Time }
InternalCreateDomainRequest is used to create the domain
type InternalCreateShardRequest ¶ added in v0.16.0
type InternalCreateShardRequest struct {
ShardInfo *InternalShardInfo
}
InternalCreateShardRequest is request to CreateShard
type InternalCreateTasksInfo ¶ added in v0.16.0
type InternalCreateTasksInfo struct { Data *InternalTaskInfo TaskID int64 }
InternalCreateTasksInfo describes a task to be created in InternalCreateTasksRequest
type InternalCreateTasksRequest ¶ added in v0.16.0
type InternalCreateTasksRequest struct { TaskListInfo *TaskListInfo Tasks []*InternalCreateTasksInfo }
InternalCreateTasksRequest is request to CreateTasks
type InternalCreateWorkflowExecutionRequest ¶ added in v0.5.7
type InternalCreateWorkflowExecutionRequest struct { RangeID int64 Mode CreateWorkflowMode PreviousRunID string PreviousLastWriteVersion int64 NewWorkflowSnapshot InternalWorkflowSnapshot WorkflowRequestMode CreateWorkflowRequestMode }
InternalCreateWorkflowExecutionRequest is used to write a new workflow execution
type InternalDeleteHistoryBranchRequest ¶ added in v0.5.0
type InternalDeleteHistoryBranchRequest struct { // branch to be deleted BranchInfo types.HistoryBranch // Used in sharded data stores to identify which shard to use ShardID int }
InternalDeleteHistoryBranchRequest is used to remove a history branch
type InternalDomainConfig ¶ added in v0.5.8
type InternalDomainConfig struct { Retention time.Duration EmitMetric bool // deprecated ArchivalBucket string // deprecated ArchivalStatus types.ArchivalStatus // deprecated HistoryArchivalStatus types.ArchivalStatus HistoryArchivalURI string VisibilityArchivalStatus types.ArchivalStatus VisibilityArchivalURI string BadBinaries *DataBlob IsolationGroups *DataBlob AsyncWorkflowsConfig *DataBlob }
InternalDomainConfig describes the domain configuration
type InternalForkHistoryBranchRequest ¶ added in v0.5.0
type InternalForkHistoryBranchRequest struct { // The base branch to fork from ForkBranchInfo types.HistoryBranch // The nodeID to fork from, the new branch will start from ( inclusive ), the base branch will stop at(exclusive) ForkNodeID int64 // branchID of the new branch NewBranchID string // the info for clean up data in background Info string // Used in sharded data stores to identify which shard to use ShardID int }
InternalForkHistoryBranchRequest is used to fork a history branch
type InternalForkHistoryBranchResponse ¶ added in v0.5.0
type InternalForkHistoryBranchResponse struct { // branchInfo to represent the new branch NewBranchInfo types.HistoryBranch }
InternalForkHistoryBranchResponse is the response to ForkHistoryBranchRequest
type InternalGetClosedWorkflowExecutionRequest ¶ added in v0.16.0
type InternalGetClosedWorkflowExecutionRequest struct { DomainUUID string Domain string // domain name is not persisted, but used as config filter key Execution types.WorkflowExecution }
InternalGetClosedWorkflowExecutionRequest is used retrieve the record for a specific execution
type InternalGetClosedWorkflowExecutionResponse ¶ added in v0.5.7
type InternalGetClosedWorkflowExecutionResponse struct {
Execution *InternalVisibilityWorkflowExecutionInfo
}
InternalGetClosedWorkflowExecutionResponse is response from GetWorkflowExecution
type InternalGetDomainResponse ¶ added in v0.5.8
type InternalGetDomainResponse struct { Info *DomainInfo Config *InternalDomainConfig ReplicationConfig *DomainReplicationConfig IsGlobalDomain bool ConfigVersion int64 FailoverVersion int64 FailoverNotificationVersion int64 PreviousFailoverVersion int64 FailoverEndTime *time.Time LastUpdatedTime time.Time NotificationVersion int64 }
InternalGetDomainResponse is the response for GetDomain
type InternalGetHistoryTreeRequest ¶ added in v0.16.0
type InternalGetHistoryTreeRequest struct { // A UUID of a tree TreeID string // Get data from this shard ShardID *int // optional: can provide treeID via branchToken if treeID is empty BranchToken []byte }
InternalGetHistoryTreeRequest is used to get history tree
type InternalGetHistoryTreeResponse ¶ added in v0.16.0
type InternalGetHistoryTreeResponse struct { // all branches of a tree Branches []*types.HistoryBranch }
InternalGetHistoryTreeResponse is the response to GetHistoryTree
type InternalGetReplicationTasksFromDLQResponse ¶ added in v0.16.0
type InternalGetReplicationTasksFromDLQResponse = InternalGetReplicationTasksResponse
InternalGetReplicationTasksFromDLQResponse is the response for GetReplicationTasksFromDLQ
type InternalGetReplicationTasksResponse ¶ added in v0.16.0
type InternalGetReplicationTasksResponse struct { Tasks []*InternalReplicationTaskInfo NextPageToken []byte }
InternalGetReplicationTasksResponse is the response to GetReplicationTask
type InternalGetShardRequest ¶ added in v0.16.0
type InternalGetShardRequest struct {
ShardID int
}
InternalGetShardRequest is used to get shard information
type InternalGetShardResponse ¶ added in v0.16.0
type InternalGetShardResponse struct {
ShardInfo *InternalShardInfo
}
InternalGetShardResponse is the response to GetShard
type InternalGetTasksResponse ¶ added in v0.16.0
type InternalGetTasksResponse struct {
Tasks []*InternalTaskInfo
}
InternalGetTasksResponse is response from GetTasks
type InternalGetWorkflowExecutionRequest ¶ added in v0.16.0
type InternalGetWorkflowExecutionRequest struct { DomainID string Execution types.WorkflowExecution RangeID int64 }
InternalGetWorkflowExecutionRequest is used to retrieve the info of a workflow execution
type InternalGetWorkflowExecutionResponse ¶ added in v0.4.0
type InternalGetWorkflowExecutionResponse struct {
State *InternalWorkflowMutableState
}
InternalGetWorkflowExecutionResponse is the response to GetWorkflowExecution for Persistence Interface
type InternalListAllWorkflowExecutionsByTypeRequest ¶ added in v1.2.11
type InternalListAllWorkflowExecutionsByTypeRequest struct { InternalListWorkflowExecutionsRequest StatusFilter []types.WorkflowExecutionCloseStatus PartialMatch bool WorkflowSearchValue string // This value will be searched across workflow type, workflow ID and runID SortColumn string // This should be a valid search attribute SortOrder string // DESC or ASC }
InternalListAllWorkflowExecutionsByTypeRequest is used to list all open and closed executions with specific filters in a domain
type InternalListClosedWorkflowExecutionsByStatusRequest ¶ added in v0.16.0
type InternalListClosedWorkflowExecutionsByStatusRequest struct { InternalListWorkflowExecutionsRequest Status types.WorkflowExecutionCloseStatus }
InternalListClosedWorkflowExecutionsByStatusRequest is used to list executions that have specific close status
type InternalListConcreteExecutionsEntity ¶ added in v0.13.0
type InternalListConcreteExecutionsEntity struct { ExecutionInfo *InternalWorkflowExecutionInfo VersionHistories *DataBlob }
InternalListConcreteExecutionsEntity is a single entity in InternalListConcreteExecutionsResponse
type InternalListConcreteExecutionsResponse ¶ added in v0.13.0
type InternalListConcreteExecutionsResponse struct { Executions []*InternalListConcreteExecutionsEntity NextPageToken []byte }
InternalListConcreteExecutionsResponse is the response to ListConcreteExecutions for Persistence Interface
type InternalListDomainsResponse ¶ added in v0.5.8
type InternalListDomainsResponse struct { Domains []*InternalGetDomainResponse NextPageToken []byte }
InternalListDomainsResponse is the response for GetDomain
type InternalListWorkflowExecutionsByTypeRequest ¶ added in v0.16.0
type InternalListWorkflowExecutionsByTypeRequest struct { InternalListWorkflowExecutionsRequest WorkflowTypeName string }
InternalListWorkflowExecutionsByTypeRequest is used to list executions of a specific type in a domain
type InternalListWorkflowExecutionsByWorkflowIDRequest ¶ added in v0.16.0
type InternalListWorkflowExecutionsByWorkflowIDRequest struct { InternalListWorkflowExecutionsRequest WorkflowID string }
InternalListWorkflowExecutionsByWorkflowIDRequest is used to list executions that have specific WorkflowID in a domain
type InternalListWorkflowExecutionsRequest ¶ added in v0.16.0
type InternalListWorkflowExecutionsRequest struct { DomainUUID string Domain string // domain name is not persisted, but used as config filter key // The earliest end of the time range EarliestTime time.Time // The latest end of the time range LatestTime time.Time // Maximum number of workflow executions per page PageSize int // Token to continue reading next page of workflow executions. // Pass in empty slice for first page. NextPageToken []byte }
InternalListWorkflowExecutionsRequest is used to list executions in a domain
type InternalListWorkflowExecutionsResponse ¶ added in v0.5.7
type InternalListWorkflowExecutionsResponse struct { Executions []*InternalVisibilityWorkflowExecutionInfo // Token to read next page if there are more workflow executions beyond page size. // Use this to set NextPageToken on ListWorkflowExecutionsRequest to read the next page. NextPageToken []byte }
InternalListWorkflowExecutionsResponse is response from ListWorkflowExecutions
type InternalPutReplicationTaskToDLQRequest ¶ added in v0.16.0
type InternalPutReplicationTaskToDLQRequest struct { SourceClusterName string TaskInfo *InternalReplicationTaskInfo }
InternalPutReplicationTaskToDLQRequest is used to put a replication task to dlq
type InternalQueueMessage ¶ added in v0.16.0
type InternalQueueMessage struct { ID int64 `json:"message_id"` QueueType QueueType `json:"queue_type"` Payload []byte `json:"message_payload"` }
InternalQueueMessage is the message that stores in the queue
type InternalReadHistoryBranchRequest ¶ added in v0.5.0
type InternalReadHistoryBranchRequest struct { // The tree of branch range to be read TreeID string // The branch range to be read BranchID string // Get the history nodes from MinNodeID. Inclusive. MinNodeID int64 // Get the history nodes upto MaxNodeID. Exclusive. MaxNodeID int64 // passing thru for pagination PageSize int // Pagination token NextPageToken []byte // LastNodeID is the last known node ID attached to a history node LastNodeID int64 // LastTransactionID is the last known transaction ID attached to a history node LastTransactionID int64 // Used in sharded data stores to identify which shard to use ShardID int }
InternalReadHistoryBranchRequest is used to read a history branch
type InternalReadHistoryBranchResponse ¶ added in v0.5.0
type InternalReadHistoryBranchResponse struct { // History events History []*DataBlob // Pagination token NextPageToken []byte // LastNodeID is the last known node ID attached to a history node LastNodeID int64 // LastTransactionID is the last known transaction ID attached to a history node LastTransactionID int64 }
InternalReadHistoryBranchResponse is the response to ReadHistoryBranchRequest
type InternalRecordWorkflowExecutionClosedRequest ¶ added in v0.5.7
type InternalRecordWorkflowExecutionClosedRequest struct { DomainUUID string WorkflowID string RunID string WorkflowTypeName string StartTimestamp time.Time ExecutionTimestamp time.Time TaskID int64 Memo *DataBlob TaskList string SearchAttributes map[string][]byte CloseTimestamp time.Time Status types.WorkflowExecutionCloseStatus HistoryLength int64 RetentionPeriod time.Duration IsCron bool NumClusters int16 UpdateTimestamp time.Time ShardID int16 }
InternalRecordWorkflowExecutionClosedRequest is request to RecordWorkflowExecutionClosed
type InternalRecordWorkflowExecutionStartedRequest ¶ added in v0.5.7
type InternalRecordWorkflowExecutionStartedRequest struct { DomainUUID string WorkflowID string RunID string WorkflowTypeName string StartTimestamp time.Time ExecutionTimestamp time.Time WorkflowTimeout time.Duration TaskID int64 Memo *DataBlob TaskList string IsCron bool NumClusters int16 UpdateTimestamp time.Time SearchAttributes map[string][]byte ShardID int16 }
InternalRecordWorkflowExecutionStartedRequest request to RecordWorkflowExecutionStarted
type InternalRecordWorkflowExecutionUninitializedRequest ¶ added in v0.25.0
type InternalRecordWorkflowExecutionUninitializedRequest struct { DomainUUID string WorkflowID string RunID string WorkflowTypeName string UpdateTimestamp time.Time ShardID int64 }
InternalRecordWorkflowExecutionUninitializedRequest is used to add a record of a newly uninitialized execution
type InternalReplicationTaskInfo ¶ added in v0.16.0
type InternalReplicationTaskInfo struct { DomainID string WorkflowID string RunID string TaskID int64 TaskType int FirstEventID int64 NextEventID int64 Version int64 ScheduledID int64 BranchToken []byte NewRunBranchToken []byte CreationTime time.Time }
InternalReplicationTaskInfo describes the replication task created for replication of history events
type InternalShardInfo ¶ added in v0.16.0
type InternalShardInfo struct { ShardID int `json:"shard_id"` Owner string `json:"owner"` RangeID int64 `json:"range_id"` StolenSinceRenew int `json:"stolen_since_renew"` UpdatedAt time.Time `json:"updated_at"` ReplicationAckLevel int64 `json:"replication_ack_level"` ReplicationDLQAckLevel map[string]int64 `json:"replication_dlq_ack_level"` TransferAckLevel int64 `json:"transfer_ack_level"` TimerAckLevel time.Time `json:"timer_ack_level"` ClusterTransferAckLevel map[string]int64 `json:"cluster_transfer_ack_level"` ClusterTimerAckLevel map[string]time.Time `json:"cluster_timer_ack_level"` TransferProcessingQueueStates *DataBlob `json:"transfer_processing_queue_states"` CrossClusterProcessingQueueStates *DataBlob `json:"cross_cluster_processing_queue_states"` TimerProcessingQueueStates *DataBlob `json:"timer_processing_queue_states"` ClusterReplicationLevel map[string]int64 `json:"cluster_replication_level"` DomainNotificationVersion int64 `json:"domain_notification_version"` PendingFailoverMarkers *DataBlob `json:"pending_failover_markers"` }
InternalShardInfo describes a shard
type InternalTaskInfo ¶ added in v0.16.0
type InternalTaskInfo struct { DomainID string WorkflowID string RunID string TaskID int64 ScheduleID int64 ScheduleToStartTimeout time.Duration Expiry time.Time CreatedTime time.Time PartitionConfig map[string]string }
InternalTaskInfo describes a Task
type InternalUpdateDomainRequest ¶ added in v0.5.8
type InternalUpdateDomainRequest struct { Info *DomainInfo Config *InternalDomainConfig ReplicationConfig *DomainReplicationConfig ConfigVersion int64 FailoverVersion int64 FailoverNotificationVersion int64 PreviousFailoverVersion int64 FailoverEndTime *time.Time LastUpdatedTime time.Time NotificationVersion int64 }
InternalUpdateDomainRequest is used to update domain
type InternalUpdateShardRequest ¶ added in v0.16.0
type InternalUpdateShardRequest struct { ShardInfo *InternalShardInfo PreviousRangeID int64 }
InternalUpdateShardRequest is used to update shard information
type InternalUpdateWorkflowExecutionRequest ¶ added in v0.4.0
type InternalUpdateWorkflowExecutionRequest struct { RangeID int64 Mode UpdateWorkflowMode UpdateWorkflowMutation InternalWorkflowMutation NewWorkflowSnapshot *InternalWorkflowSnapshot WorkflowRequestMode CreateWorkflowRequestMode }
InternalUpdateWorkflowExecutionRequest is used to update a workflow execution for Persistence Interface
type InternalUpsertWorkflowExecutionRequest ¶ added in v0.6.0
type InternalUpsertWorkflowExecutionRequest struct { DomainUUID string WorkflowID string RunID string WorkflowTypeName string StartTimestamp time.Time ExecutionTimestamp time.Time WorkflowTimeout time.Duration TaskID int64 Memo *DataBlob TaskList string IsCron bool NumClusters int16 UpdateTimestamp time.Time SearchAttributes map[string][]byte ShardID int64 }
InternalUpsertWorkflowExecutionRequest is request to UpsertWorkflowExecution
type InternalVisibilityWorkflowExecutionInfo ¶ added in v0.16.0
type InternalVisibilityWorkflowExecutionInfo struct { DomainID string WorkflowType string WorkflowID string RunID string TypeName string StartTime time.Time ExecutionTime time.Time CloseTime time.Time Status *types.WorkflowExecutionCloseStatus HistoryLength int64 Memo *DataBlob TaskList string IsCron bool NumClusters int16 UpdateTime time.Time SearchAttributes map[string]interface{} ShardID int16 }
InternalVisibilityWorkflowExecutionInfo is visibility info for internal response
type InternalWorkflowExecutionInfo ¶ added in v0.4.0
type InternalWorkflowExecutionInfo struct { DomainID string WorkflowID string RunID string FirstExecutionRunID string ParentDomainID string ParentWorkflowID string ParentRunID string InitiatedID int64 CompletionEventBatchID int64 CompletionEvent *DataBlob TaskList string WorkflowTypeName string WorkflowTimeout time.Duration DecisionStartToCloseTimeout time.Duration ExecutionContext []byte State int CloseStatus int LastFirstEventID int64 LastEventTaskID int64 NextEventID int64 LastProcessedEvent int64 StartTimestamp time.Time LastUpdatedTimestamp time.Time CreateRequestID string SignalCount int32 DecisionVersion int64 DecisionScheduleID int64 DecisionStartedID int64 DecisionRequestID string DecisionTimeout time.Duration DecisionAttempt int64 DecisionStartedTimestamp time.Time DecisionScheduledTimestamp time.Time DecisionOriginalScheduledTimestamp time.Time CancelRequested bool CancelRequestID string StickyTaskList string StickyScheduleToStartTimeout time.Duration ClientLibraryVersion string ClientFeatureVersion string ClientImpl string AutoResetPoints *DataBlob // for retry Attempt int32 HasRetryPolicy bool InitialInterval time.Duration BackoffCoefficient float64 MaximumInterval time.Duration ExpirationTime time.Time MaximumAttempts int32 NonRetriableErrors []string BranchToken []byte CronSchedule string ExpirationInterval time.Duration Memo map[string][]byte SearchAttributes map[string][]byte PartitionConfig map[string]string // attributes which are not related to mutable state at all HistorySize int64 IsCron bool }
InternalWorkflowExecutionInfo describes a workflow execution for Persistence Interface
type InternalWorkflowMutableState ¶ added in v0.4.0
type InternalWorkflowMutableState struct { ExecutionInfo *InternalWorkflowExecutionInfo VersionHistories *DataBlob ReplicationState *ReplicationState // TODO: remove this after all 2DC workflows complete ActivityInfos map[int64]*InternalActivityInfo TimerInfos map[string]*TimerInfo ChildExecutionInfos map[int64]*InternalChildExecutionInfo RequestCancelInfos map[int64]*RequestCancelInfo SignalInfos map[int64]*SignalInfo SignalRequestedIDs map[string]struct{} BufferedEvents []*DataBlob // Checksum field is used by Cassandra storage // ChecksumData is used by All SQL storage Checksum checksum.Checksum ChecksumData *DataBlob }
InternalWorkflowMutableState indicates workflow related state for Persistence Interface
type InternalWorkflowMutation ¶ added in v0.6.0
type InternalWorkflowMutation struct { ExecutionInfo *InternalWorkflowExecutionInfo VersionHistories *DataBlob StartVersion int64 LastWriteVersion int64 UpsertActivityInfos []*InternalActivityInfo DeleteActivityInfos []int64 UpsertTimerInfos []*TimerInfo DeleteTimerInfos []string UpsertChildExecutionInfos []*InternalChildExecutionInfo DeleteChildExecutionInfos []int64 UpsertRequestCancelInfos []*RequestCancelInfo DeleteRequestCancelInfos []int64 UpsertSignalInfos []*SignalInfo DeleteSignalInfos []int64 UpsertSignalRequestedIDs []string DeleteSignalRequestedIDs []string NewBufferedEvents *DataBlob ClearBufferedEvents bool TransferTasks []Task CrossClusterTasks []Task TimerTasks []Task ReplicationTasks []Task WorkflowRequests []*WorkflowRequest Condition int64 Checksum checksum.Checksum ChecksumData *DataBlob }
InternalWorkflowMutation is used as generic workflow execution state mutation for Persistence Interface
type InternalWorkflowSnapshot ¶ added in v0.6.0
type InternalWorkflowSnapshot struct { ExecutionInfo *InternalWorkflowExecutionInfo VersionHistories *DataBlob StartVersion int64 LastWriteVersion int64 ActivityInfos []*InternalActivityInfo TimerInfos []*TimerInfo ChildExecutionInfos []*InternalChildExecutionInfo RequestCancelInfos []*RequestCancelInfo SignalInfos []*SignalInfo SignalRequestedIDs []string TransferTasks []Task CrossClusterTasks []Task TimerTasks []Task ReplicationTasks []Task WorkflowRequests []*WorkflowRequest Condition int64 Checksum checksum.Checksum ChecksumData *DataBlob }
InternalWorkflowSnapshot is used as generic workflow execution state snapshot for Persistence Interface
type InvalidPersistenceRequestError ¶ added in v0.5.0
type InvalidPersistenceRequestError struct {
Msg string
}
InvalidPersistenceRequestError represents invalid request to persistence
func (*InvalidPersistenceRequestError) Error ¶ added in v0.5.0
func (e *InvalidPersistenceRequestError) Error() string
type IsWorkflowExecutionExistsRequest ¶ added in v0.14.0
type IsWorkflowExecutionExistsRequest struct { DomainID string DomainName string WorkflowID string RunID string }
IsWorkflowExecutionExistsRequest is used to check if the concrete execution exists
func (*IsWorkflowExecutionExistsRequest) GetDomainName ¶ added in v1.2.7
func (r *IsWorkflowExecutionExistsRequest) GetDomainName() string
type IsWorkflowExecutionExistsResponse ¶ added in v0.14.0
type IsWorkflowExecutionExistsResponse struct {
Exists bool
}
IsWorkflowExecutionExistsResponse is the response to IsWorkflowExecutionExists
type LeaseTaskListRequest ¶
type LeaseTaskListRequest struct { DomainID string DomainName string TaskList string TaskType int TaskListKind int RangeID int64 }
LeaseTaskListRequest is used to request lease of a task list
func (LeaseTaskListRequest) MetricTags ¶ added in v1.2.7
func (r LeaseTaskListRequest) MetricTags() []metrics.Tag
type LeaseTaskListResponse ¶
type LeaseTaskListResponse struct {
TaskListInfo *TaskListInfo
}
LeaseTaskListResponse is response to LeaseTaskListRequest
type ListAllWorkflowExecutionsRequest ¶ added in v1.2.11
type ListAllWorkflowExecutionsRequest struct { ListWorkflowExecutionsRequest PartialMatch bool StatusFilter []types.WorkflowExecutionCloseStatus WorkflowSearchValue string // This value will be searched across workflow type, workflow ID and runID SortColumn string // This should be a valid search attribute SortOrder string // DESC or ASC }
ListAllWorkflowExecutionsRequest is used to list all executions in a domain
type ListClosedWorkflowExecutionsByStatusRequest ¶
type ListClosedWorkflowExecutionsByStatusRequest struct { ListWorkflowExecutionsRequest Status types.WorkflowExecutionCloseStatus }
ListClosedWorkflowExecutionsByStatusRequest is used to list executions that have specific close status
type ListConcreteExecutionsEntity ¶ added in v0.13.0
type ListConcreteExecutionsEntity struct { ExecutionInfo *WorkflowExecutionInfo VersionHistories *VersionHistories }
ListConcreteExecutionsEntity is a single entity in ListConcreteExecutionsResponse
type ListConcreteExecutionsRequest ¶ added in v0.13.0
ListConcreteExecutionsRequest is request to ListConcreteExecutions
type ListConcreteExecutionsResponse ¶ added in v0.13.0
type ListConcreteExecutionsResponse struct { Executions []*ListConcreteExecutionsEntity PageToken []byte }
ListConcreteExecutionsResponse is response to ListConcreteExecutions
type ListCurrentExecutionsRequest ¶ added in v0.14.0
ListCurrentExecutionsRequest is request to ListCurrentExecutions
type ListCurrentExecutionsResponse ¶ added in v0.14.0
type ListCurrentExecutionsResponse struct { Executions []*CurrentWorkflowExecution PageToken []byte }
ListCurrentExecutionsResponse is the response to ListCurrentExecutionsRequest
func (*ListCurrentExecutionsResponse) Len ¶ added in v1.2.7
func (r *ListCurrentExecutionsResponse) Len() int
type ListDomainsRequest ¶ added in v0.3.14
ListDomainsRequest is used to list domains
type ListDomainsResponse ¶ added in v0.3.14
type ListDomainsResponse struct { Domains []*GetDomainResponse NextPageToken []byte }
ListDomainsResponse is the response for GetDomain
func (*ListDomainsResponse) Len ¶ added in v1.2.7
func (r *ListDomainsResponse) Len() int
type ListTaskListRequest ¶ added in v0.5.4
ListTaskListRequest contains the request params needed to invoke ListTaskList API
type ListTaskListResponse ¶ added in v0.5.4
type ListTaskListResponse struct { Items []TaskListInfo NextPageToken []byte }
ListTaskListResponse is the response from ListTaskList API
type ListWorkflowExecutionsByQueryRequest ¶ added in v0.17.0
type ListWorkflowExecutionsByQueryRequest struct { DomainUUID string Domain string // domain name is not persisted, but used as config filter key PageSize int // Maximum number of workflow executions per page // Token to continue reading next page of workflow executions. // Pass in empty slice for first page. NextPageToken []byte Query string }
ListWorkflowExecutionsByQueryRequest is used to list executions in a domain
type ListWorkflowExecutionsByTypeRequest ¶
type ListWorkflowExecutionsByTypeRequest struct { ListWorkflowExecutionsRequest WorkflowTypeName string }
ListWorkflowExecutionsByTypeRequest is used to list executions of a specific type in a domain
type ListWorkflowExecutionsByWorkflowIDRequest ¶
type ListWorkflowExecutionsByWorkflowIDRequest struct { ListWorkflowExecutionsRequest WorkflowID string }
ListWorkflowExecutionsByWorkflowIDRequest is used to list executions that have specific WorkflowID in a domain
type ListWorkflowExecutionsRequest ¶
type ListWorkflowExecutionsRequest struct { DomainUUID string Domain string // domain name is not persisted, but used as config filter key // The earliest end of the time range EarliestTime int64 // The latest end of the time range LatestTime int64 // Maximum number of workflow executions per page PageSize int // Token to continue reading next page of workflow executions. // Pass in empty slice for first page. NextPageToken []byte }
ListWorkflowExecutionsRequest is used to list executions in a domain
type ListWorkflowExecutionsResponse ¶
type ListWorkflowExecutionsResponse struct { Executions []*types.WorkflowExecutionInfo // Token to read next page if there are more workflow executions beyond page size. // Use this to set NextPageToken on ListWorkflowExecutionsRequest to read the next page. NextPageToken []byte }
ListWorkflowExecutionsResponse is the response to ListWorkflowExecutionsRequest
type MockConfigStoreManager ¶ added in v0.23.1
type MockConfigStoreManager struct {
// contains filtered or unexported fields
}
MockConfigStoreManager is a mock of ConfigStoreManager interface.
func NewMockConfigStoreManager ¶ added in v0.23.1
func NewMockConfigStoreManager(ctrl *gomock.Controller) *MockConfigStoreManager
NewMockConfigStoreManager creates a new mock instance.
func (*MockConfigStoreManager) Close ¶ added in v0.23.1
func (m *MockConfigStoreManager) Close()
Close mocks base method.
func (*MockConfigStoreManager) EXPECT ¶ added in v0.23.1
func (m *MockConfigStoreManager) EXPECT() *MockConfigStoreManagerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockConfigStoreManager) FetchDynamicConfig ¶ added in v0.23.1
func (m *MockConfigStoreManager) FetchDynamicConfig(arg0 context.Context, arg1 ConfigType) (*FetchDynamicConfigResponse, error)
FetchDynamicConfig mocks base method.
func (*MockConfigStoreManager) UpdateDynamicConfig ¶ added in v0.23.1
func (m *MockConfigStoreManager) UpdateDynamicConfig(arg0 context.Context, arg1 *UpdateDynamicConfigRequest, arg2 ConfigType) error
UpdateDynamicConfig mocks base method.
type MockConfigStoreManagerMockRecorder ¶ added in v0.23.1
type MockConfigStoreManagerMockRecorder struct {
// contains filtered or unexported fields
}
MockConfigStoreManagerMockRecorder is the mock recorder for MockConfigStoreManager.
func (*MockConfigStoreManagerMockRecorder) Close ¶ added in v0.23.1
func (mr *MockConfigStoreManagerMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockConfigStoreManagerMockRecorder) FetchDynamicConfig ¶ added in v0.23.1
func (mr *MockConfigStoreManagerMockRecorder) FetchDynamicConfig(arg0, arg1 interface{}) *gomock.Call
FetchDynamicConfig indicates an expected call of FetchDynamicConfig.
func (*MockConfigStoreManagerMockRecorder) UpdateDynamicConfig ¶ added in v0.23.1
func (mr *MockConfigStoreManagerMockRecorder) UpdateDynamicConfig(arg0, arg1, arg2 interface{}) *gomock.Call
UpdateDynamicConfig indicates an expected call of UpdateDynamicConfig.
type MockDomainManager ¶ added in v0.23.1
type MockDomainManager struct {
// contains filtered or unexported fields
}
MockDomainManager is a mock of DomainManager interface.
func NewMockDomainManager ¶ added in v0.23.1
func NewMockDomainManager(ctrl *gomock.Controller) *MockDomainManager
NewMockDomainManager creates a new mock instance.
func (*MockDomainManager) Close ¶ added in v0.23.1
func (m *MockDomainManager) Close()
Close mocks base method.
func (*MockDomainManager) CreateDomain ¶ added in v0.23.1
func (m *MockDomainManager) CreateDomain(arg0 context.Context, arg1 *CreateDomainRequest) (*CreateDomainResponse, error)
CreateDomain mocks base method.
func (*MockDomainManager) DeleteDomain ¶ added in v0.23.1
func (m *MockDomainManager) DeleteDomain(arg0 context.Context, arg1 *DeleteDomainRequest) error
DeleteDomain mocks base method.
func (*MockDomainManager) DeleteDomainByName ¶ added in v0.23.1
func (m *MockDomainManager) DeleteDomainByName(arg0 context.Context, arg1 *DeleteDomainByNameRequest) error
DeleteDomainByName mocks base method.
func (*MockDomainManager) EXPECT ¶ added in v0.23.1
func (m *MockDomainManager) EXPECT() *MockDomainManagerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockDomainManager) GetDomain ¶ added in v0.23.1
func (m *MockDomainManager) GetDomain(arg0 context.Context, arg1 *GetDomainRequest) (*GetDomainResponse, error)
GetDomain mocks base method.
func (*MockDomainManager) GetMetadata ¶ added in v0.23.1
func (m *MockDomainManager) GetMetadata(arg0 context.Context) (*GetMetadataResponse, error)
GetMetadata mocks base method.
func (*MockDomainManager) GetName ¶ added in v0.23.1
func (m *MockDomainManager) GetName() string
GetName mocks base method.
func (*MockDomainManager) ListDomains ¶ added in v0.23.1
func (m *MockDomainManager) ListDomains(arg0 context.Context, arg1 *ListDomainsRequest) (*ListDomainsResponse, error)
ListDomains mocks base method.
func (*MockDomainManager) UpdateDomain ¶ added in v0.23.1
func (m *MockDomainManager) UpdateDomain(arg0 context.Context, arg1 *UpdateDomainRequest) error
UpdateDomain mocks base method.
type MockDomainManagerMockRecorder ¶ added in v0.23.1
type MockDomainManagerMockRecorder struct {
// contains filtered or unexported fields
}
MockDomainManagerMockRecorder is the mock recorder for MockDomainManager.
func (*MockDomainManagerMockRecorder) Close ¶ added in v0.23.1
func (mr *MockDomainManagerMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockDomainManagerMockRecorder) CreateDomain ¶ added in v0.23.1
func (mr *MockDomainManagerMockRecorder) CreateDomain(arg0, arg1 interface{}) *gomock.Call
CreateDomain indicates an expected call of CreateDomain.
func (*MockDomainManagerMockRecorder) DeleteDomain ¶ added in v0.23.1
func (mr *MockDomainManagerMockRecorder) DeleteDomain(arg0, arg1 interface{}) *gomock.Call
DeleteDomain indicates an expected call of DeleteDomain.
func (*MockDomainManagerMockRecorder) DeleteDomainByName ¶ added in v0.23.1
func (mr *MockDomainManagerMockRecorder) DeleteDomainByName(arg0, arg1 interface{}) *gomock.Call
DeleteDomainByName indicates an expected call of DeleteDomainByName.
func (*MockDomainManagerMockRecorder) GetDomain ¶ added in v0.23.1
func (mr *MockDomainManagerMockRecorder) GetDomain(arg0, arg1 interface{}) *gomock.Call
GetDomain indicates an expected call of GetDomain.
func (*MockDomainManagerMockRecorder) GetMetadata ¶ added in v0.23.1
func (mr *MockDomainManagerMockRecorder) GetMetadata(arg0 interface{}) *gomock.Call
GetMetadata indicates an expected call of GetMetadata.
func (*MockDomainManagerMockRecorder) GetName ¶ added in v0.23.1
func (mr *MockDomainManagerMockRecorder) GetName() *gomock.Call
GetName indicates an expected call of GetName.
func (*MockDomainManagerMockRecorder) ListDomains ¶ added in v0.23.1
func (mr *MockDomainManagerMockRecorder) ListDomains(arg0, arg1 interface{}) *gomock.Call
ListDomains indicates an expected call of ListDomains.
func (*MockDomainManagerMockRecorder) UpdateDomain ¶ added in v0.23.1
func (mr *MockDomainManagerMockRecorder) UpdateDomain(arg0, arg1 interface{}) *gomock.Call
UpdateDomain indicates an expected call of UpdateDomain.
type MockExecutionManager ¶ added in v0.23.1
type MockExecutionManager struct {
// contains filtered or unexported fields
}
MockExecutionManager is a mock of ExecutionManager interface.
func NewMockExecutionManager ¶ added in v0.23.1
func NewMockExecutionManager(ctrl *gomock.Controller) *MockExecutionManager
NewMockExecutionManager creates a new mock instance.
func (*MockExecutionManager) Close ¶ added in v0.23.1
func (m *MockExecutionManager) Close()
Close mocks base method.
func (*MockExecutionManager) CompleteCrossClusterTask ¶ added in v0.23.1
func (m *MockExecutionManager) CompleteCrossClusterTask(arg0 context.Context, arg1 *CompleteCrossClusterTaskRequest) error
CompleteCrossClusterTask mocks base method.
func (*MockExecutionManager) CompleteReplicationTask ¶ added in v0.23.1
func (m *MockExecutionManager) CompleteReplicationTask(arg0 context.Context, arg1 *CompleteReplicationTaskRequest) error
CompleteReplicationTask mocks base method.
func (*MockExecutionManager) CompleteTimerTask ¶ added in v0.23.1
func (m *MockExecutionManager) CompleteTimerTask(arg0 context.Context, arg1 *CompleteTimerTaskRequest) error
CompleteTimerTask mocks base method.
func (*MockExecutionManager) CompleteTransferTask ¶ added in v0.23.1
func (m *MockExecutionManager) CompleteTransferTask(arg0 context.Context, arg1 *CompleteTransferTaskRequest) error
CompleteTransferTask mocks base method.
func (*MockExecutionManager) ConflictResolveWorkflowExecution ¶ added in v0.23.1
func (m *MockExecutionManager) ConflictResolveWorkflowExecution(arg0 context.Context, arg1 *ConflictResolveWorkflowExecutionRequest) (*ConflictResolveWorkflowExecutionResponse, error)
ConflictResolveWorkflowExecution mocks base method.
func (*MockExecutionManager) CreateFailoverMarkerTasks ¶ added in v0.23.1
func (m *MockExecutionManager) CreateFailoverMarkerTasks(arg0 context.Context, arg1 *CreateFailoverMarkersRequest) error
CreateFailoverMarkerTasks mocks base method.
func (*MockExecutionManager) CreateWorkflowExecution ¶ added in v0.23.1
func (m *MockExecutionManager) CreateWorkflowExecution(arg0 context.Context, arg1 *CreateWorkflowExecutionRequest) (*CreateWorkflowExecutionResponse, error)
CreateWorkflowExecution mocks base method.
func (*MockExecutionManager) DeleteCurrentWorkflowExecution ¶ added in v0.23.1
func (m *MockExecutionManager) DeleteCurrentWorkflowExecution(arg0 context.Context, arg1 *DeleteCurrentWorkflowExecutionRequest) error
DeleteCurrentWorkflowExecution mocks base method.
func (*MockExecutionManager) DeleteReplicationTaskFromDLQ ¶ added in v0.23.1
func (m *MockExecutionManager) DeleteReplicationTaskFromDLQ(arg0 context.Context, arg1 *DeleteReplicationTaskFromDLQRequest) error
DeleteReplicationTaskFromDLQ mocks base method.
func (*MockExecutionManager) DeleteWorkflowExecution ¶ added in v0.23.1
func (m *MockExecutionManager) DeleteWorkflowExecution(arg0 context.Context, arg1 *DeleteWorkflowExecutionRequest) error
DeleteWorkflowExecution mocks base method.
func (*MockExecutionManager) EXPECT ¶ added in v0.23.1
func (m *MockExecutionManager) EXPECT() *MockExecutionManagerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockExecutionManager) GetCrossClusterTasks ¶ added in v0.23.1
func (m *MockExecutionManager) GetCrossClusterTasks(arg0 context.Context, arg1 *GetCrossClusterTasksRequest) (*GetCrossClusterTasksResponse, error)
GetCrossClusterTasks mocks base method.
func (*MockExecutionManager) GetCurrentExecution ¶ added in v0.23.1
func (m *MockExecutionManager) GetCurrentExecution(arg0 context.Context, arg1 *GetCurrentExecutionRequest) (*GetCurrentExecutionResponse, error)
GetCurrentExecution mocks base method.
func (*MockExecutionManager) GetName ¶ added in v0.23.1
func (m *MockExecutionManager) GetName() string
GetName mocks base method.
func (*MockExecutionManager) GetReplicationDLQSize ¶ added in v0.23.1
func (m *MockExecutionManager) GetReplicationDLQSize(arg0 context.Context, arg1 *GetReplicationDLQSizeRequest) (*GetReplicationDLQSizeResponse, error)
GetReplicationDLQSize mocks base method.
func (*MockExecutionManager) GetReplicationTasks ¶ added in v0.23.1
func (m *MockExecutionManager) GetReplicationTasks(arg0 context.Context, arg1 *GetReplicationTasksRequest) (*GetReplicationTasksResponse, error)
GetReplicationTasks mocks base method.
func (*MockExecutionManager) GetReplicationTasksFromDLQ ¶ added in v0.23.1
func (m *MockExecutionManager) GetReplicationTasksFromDLQ(arg0 context.Context, arg1 *GetReplicationTasksFromDLQRequest) (*GetReplicationTasksResponse, error)
GetReplicationTasksFromDLQ mocks base method.
func (*MockExecutionManager) GetShardID ¶ added in v0.23.1
func (m *MockExecutionManager) GetShardID() int
GetShardID mocks base method.
func (*MockExecutionManager) GetTimerIndexTasks ¶ added in v0.23.1
func (m *MockExecutionManager) GetTimerIndexTasks(arg0 context.Context, arg1 *GetTimerIndexTasksRequest) (*GetTimerIndexTasksResponse, error)
GetTimerIndexTasks mocks base method.
func (*MockExecutionManager) GetTransferTasks ¶ added in v0.23.1
func (m *MockExecutionManager) GetTransferTasks(arg0 context.Context, arg1 *GetTransferTasksRequest) (*GetTransferTasksResponse, error)
GetTransferTasks mocks base method.
func (*MockExecutionManager) GetWorkflowExecution ¶ added in v0.23.1
func (m *MockExecutionManager) GetWorkflowExecution(arg0 context.Context, arg1 *GetWorkflowExecutionRequest) (*GetWorkflowExecutionResponse, error)
GetWorkflowExecution mocks base method.
func (*MockExecutionManager) IsWorkflowExecutionExists ¶ added in v0.23.1
func (m *MockExecutionManager) IsWorkflowExecutionExists(arg0 context.Context, arg1 *IsWorkflowExecutionExistsRequest) (*IsWorkflowExecutionExistsResponse, error)
IsWorkflowExecutionExists mocks base method.
func (*MockExecutionManager) ListConcreteExecutions ¶ added in v0.23.1
func (m *MockExecutionManager) ListConcreteExecutions(arg0 context.Context, arg1 *ListConcreteExecutionsRequest) (*ListConcreteExecutionsResponse, error)
ListConcreteExecutions mocks base method.
func (*MockExecutionManager) ListCurrentExecutions ¶ added in v0.23.1
func (m *MockExecutionManager) ListCurrentExecutions(arg0 context.Context, arg1 *ListCurrentExecutionsRequest) (*ListCurrentExecutionsResponse, error)
ListCurrentExecutions mocks base method.
func (*MockExecutionManager) PutReplicationTaskToDLQ ¶ added in v0.23.1
func (m *MockExecutionManager) PutReplicationTaskToDLQ(arg0 context.Context, arg1 *PutReplicationTaskToDLQRequest) error
PutReplicationTaskToDLQ mocks base method.
func (*MockExecutionManager) RangeCompleteCrossClusterTask ¶ added in v0.23.1
func (m *MockExecutionManager) RangeCompleteCrossClusterTask(arg0 context.Context, arg1 *RangeCompleteCrossClusterTaskRequest) (*RangeCompleteCrossClusterTaskResponse, error)
RangeCompleteCrossClusterTask mocks base method.
func (*MockExecutionManager) RangeCompleteReplicationTask ¶ added in v0.23.1
func (m *MockExecutionManager) RangeCompleteReplicationTask(arg0 context.Context, arg1 *RangeCompleteReplicationTaskRequest) (*RangeCompleteReplicationTaskResponse, error)
RangeCompleteReplicationTask mocks base method.
func (*MockExecutionManager) RangeCompleteTimerTask ¶ added in v0.23.1
func (m *MockExecutionManager) RangeCompleteTimerTask(arg0 context.Context, arg1 *RangeCompleteTimerTaskRequest) (*RangeCompleteTimerTaskResponse, error)
RangeCompleteTimerTask mocks base method.
func (*MockExecutionManager) RangeCompleteTransferTask ¶ added in v0.23.1
func (m *MockExecutionManager) RangeCompleteTransferTask(arg0 context.Context, arg1 *RangeCompleteTransferTaskRequest) (*RangeCompleteTransferTaskResponse, error)
RangeCompleteTransferTask mocks base method.
func (*MockExecutionManager) RangeDeleteReplicationTaskFromDLQ ¶ added in v0.23.1
func (m *MockExecutionManager) RangeDeleteReplicationTaskFromDLQ(arg0 context.Context, arg1 *RangeDeleteReplicationTaskFromDLQRequest) (*RangeDeleteReplicationTaskFromDLQResponse, error)
RangeDeleteReplicationTaskFromDLQ mocks base method.
func (*MockExecutionManager) UpdateWorkflowExecution ¶ added in v0.23.1
func (m *MockExecutionManager) UpdateWorkflowExecution(arg0 context.Context, arg1 *UpdateWorkflowExecutionRequest) (*UpdateWorkflowExecutionResponse, error)
UpdateWorkflowExecution mocks base method.
type MockExecutionManagerFactory ¶ added in v0.23.1
type MockExecutionManagerFactory struct {
// contains filtered or unexported fields
}
MockExecutionManagerFactory is a mock of ExecutionManagerFactory interface.
func NewMockExecutionManagerFactory ¶ added in v0.23.1
func NewMockExecutionManagerFactory(ctrl *gomock.Controller) *MockExecutionManagerFactory
NewMockExecutionManagerFactory creates a new mock instance.
func (*MockExecutionManagerFactory) Close ¶ added in v0.23.1
func (m *MockExecutionManagerFactory) Close()
Close mocks base method.
func (*MockExecutionManagerFactory) EXPECT ¶ added in v0.23.1
func (m *MockExecutionManagerFactory) EXPECT() *MockExecutionManagerFactoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockExecutionManagerFactory) NewExecutionManager ¶ added in v0.23.1
func (m *MockExecutionManagerFactory) NewExecutionManager(arg0 int) (ExecutionManager, error)
NewExecutionManager mocks base method.
type MockExecutionManagerFactoryMockRecorder ¶ added in v0.23.1
type MockExecutionManagerFactoryMockRecorder struct {
// contains filtered or unexported fields
}
MockExecutionManagerFactoryMockRecorder is the mock recorder for MockExecutionManagerFactory.
func (*MockExecutionManagerFactoryMockRecorder) Close ¶ added in v0.23.1
func (mr *MockExecutionManagerFactoryMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockExecutionManagerFactoryMockRecorder) NewExecutionManager ¶ added in v0.23.1
func (mr *MockExecutionManagerFactoryMockRecorder) NewExecutionManager(arg0 interface{}) *gomock.Call
NewExecutionManager indicates an expected call of NewExecutionManager.
type MockExecutionManagerMockRecorder ¶ added in v0.23.1
type MockExecutionManagerMockRecorder struct {
// contains filtered or unexported fields
}
MockExecutionManagerMockRecorder is the mock recorder for MockExecutionManager.
func (*MockExecutionManagerMockRecorder) Close ¶ added in v0.23.1
func (mr *MockExecutionManagerMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockExecutionManagerMockRecorder) CompleteCrossClusterTask ¶ added in v0.23.1
func (mr *MockExecutionManagerMockRecorder) CompleteCrossClusterTask(arg0, arg1 interface{}) *gomock.Call
CompleteCrossClusterTask indicates an expected call of CompleteCrossClusterTask.
func (*MockExecutionManagerMockRecorder) CompleteReplicationTask ¶ added in v0.23.1
func (mr *MockExecutionManagerMockRecorder) CompleteReplicationTask(arg0, arg1 interface{}) *gomock.Call
CompleteReplicationTask indicates an expected call of CompleteReplicationTask.
func (*MockExecutionManagerMockRecorder) CompleteTimerTask ¶ added in v0.23.1
func (mr *MockExecutionManagerMockRecorder) CompleteTimerTask(arg0, arg1 interface{}) *gomock.Call
CompleteTimerTask indicates an expected call of CompleteTimerTask.
func (*MockExecutionManagerMockRecorder) CompleteTransferTask ¶ added in v0.23.1
func (mr *MockExecutionManagerMockRecorder) CompleteTransferTask(arg0, arg1 interface{}) *gomock.Call
CompleteTransferTask indicates an expected call of CompleteTransferTask.
func (*MockExecutionManagerMockRecorder) ConflictResolveWorkflowExecution ¶ added in v0.23.1
func (mr *MockExecutionManagerMockRecorder) ConflictResolveWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
ConflictResolveWorkflowExecution indicates an expected call of ConflictResolveWorkflowExecution.
func (*MockExecutionManagerMockRecorder) CreateFailoverMarkerTasks ¶ added in v0.23.1
func (mr *MockExecutionManagerMockRecorder) CreateFailoverMarkerTasks(arg0, arg1 interface{}) *gomock.Call
CreateFailoverMarkerTasks indicates an expected call of CreateFailoverMarkerTasks.
func (*MockExecutionManagerMockRecorder) CreateWorkflowExecution ¶ added in v0.23.1
func (mr *MockExecutionManagerMockRecorder) CreateWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
CreateWorkflowExecution indicates an expected call of CreateWorkflowExecution.
func (*MockExecutionManagerMockRecorder) DeleteCurrentWorkflowExecution ¶ added in v0.23.1
func (mr *MockExecutionManagerMockRecorder) DeleteCurrentWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
DeleteCurrentWorkflowExecution indicates an expected call of DeleteCurrentWorkflowExecution.
func (*MockExecutionManagerMockRecorder) DeleteReplicationTaskFromDLQ ¶ added in v0.23.1
func (mr *MockExecutionManagerMockRecorder) DeleteReplicationTaskFromDLQ(arg0, arg1 interface{}) *gomock.Call
DeleteReplicationTaskFromDLQ indicates an expected call of DeleteReplicationTaskFromDLQ.
func (*MockExecutionManagerMockRecorder) DeleteWorkflowExecution ¶ added in v0.23.1
func (mr *MockExecutionManagerMockRecorder) DeleteWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
DeleteWorkflowExecution indicates an expected call of DeleteWorkflowExecution.
func (*MockExecutionManagerMockRecorder) GetCrossClusterTasks ¶ added in v0.23.1
func (mr *MockExecutionManagerMockRecorder) GetCrossClusterTasks(arg0, arg1 interface{}) *gomock.Call
GetCrossClusterTasks indicates an expected call of GetCrossClusterTasks.
func (*MockExecutionManagerMockRecorder) GetCurrentExecution ¶ added in v0.23.1
func (mr *MockExecutionManagerMockRecorder) GetCurrentExecution(arg0, arg1 interface{}) *gomock.Call
GetCurrentExecution indicates an expected call of GetCurrentExecution.
func (*MockExecutionManagerMockRecorder) GetName ¶ added in v0.23.1
func (mr *MockExecutionManagerMockRecorder) GetName() *gomock.Call
GetName indicates an expected call of GetName.
func (*MockExecutionManagerMockRecorder) GetReplicationDLQSize ¶ added in v0.23.1
func (mr *MockExecutionManagerMockRecorder) GetReplicationDLQSize(arg0, arg1 interface{}) *gomock.Call
GetReplicationDLQSize indicates an expected call of GetReplicationDLQSize.
func (*MockExecutionManagerMockRecorder) GetReplicationTasks ¶ added in v0.23.1
func (mr *MockExecutionManagerMockRecorder) GetReplicationTasks(arg0, arg1 interface{}) *gomock.Call
GetReplicationTasks indicates an expected call of GetReplicationTasks.
func (*MockExecutionManagerMockRecorder) GetReplicationTasksFromDLQ ¶ added in v0.23.1
func (mr *MockExecutionManagerMockRecorder) GetReplicationTasksFromDLQ(arg0, arg1 interface{}) *gomock.Call
GetReplicationTasksFromDLQ indicates an expected call of GetReplicationTasksFromDLQ.
func (*MockExecutionManagerMockRecorder) GetShardID ¶ added in v0.23.1
func (mr *MockExecutionManagerMockRecorder) GetShardID() *gomock.Call
GetShardID indicates an expected call of GetShardID.
func (*MockExecutionManagerMockRecorder) GetTimerIndexTasks ¶ added in v0.23.1
func (mr *MockExecutionManagerMockRecorder) GetTimerIndexTasks(arg0, arg1 interface{}) *gomock.Call
GetTimerIndexTasks indicates an expected call of GetTimerIndexTasks.
func (*MockExecutionManagerMockRecorder) GetTransferTasks ¶ added in v0.23.1
func (mr *MockExecutionManagerMockRecorder) GetTransferTasks(arg0, arg1 interface{}) *gomock.Call
GetTransferTasks indicates an expected call of GetTransferTasks.
func (*MockExecutionManagerMockRecorder) GetWorkflowExecution ¶ added in v0.23.1
func (mr *MockExecutionManagerMockRecorder) GetWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
GetWorkflowExecution indicates an expected call of GetWorkflowExecution.
func (*MockExecutionManagerMockRecorder) IsWorkflowExecutionExists ¶ added in v0.23.1
func (mr *MockExecutionManagerMockRecorder) IsWorkflowExecutionExists(arg0, arg1 interface{}) *gomock.Call
IsWorkflowExecutionExists indicates an expected call of IsWorkflowExecutionExists.
func (*MockExecutionManagerMockRecorder) ListConcreteExecutions ¶ added in v0.23.1
func (mr *MockExecutionManagerMockRecorder) ListConcreteExecutions(arg0, arg1 interface{}) *gomock.Call
ListConcreteExecutions indicates an expected call of ListConcreteExecutions.
func (*MockExecutionManagerMockRecorder) ListCurrentExecutions ¶ added in v0.23.1
func (mr *MockExecutionManagerMockRecorder) ListCurrentExecutions(arg0, arg1 interface{}) *gomock.Call
ListCurrentExecutions indicates an expected call of ListCurrentExecutions.
func (*MockExecutionManagerMockRecorder) PutReplicationTaskToDLQ ¶ added in v0.23.1
func (mr *MockExecutionManagerMockRecorder) PutReplicationTaskToDLQ(arg0, arg1 interface{}) *gomock.Call
PutReplicationTaskToDLQ indicates an expected call of PutReplicationTaskToDLQ.
func (*MockExecutionManagerMockRecorder) RangeCompleteCrossClusterTask ¶ added in v0.23.1
func (mr *MockExecutionManagerMockRecorder) RangeCompleteCrossClusterTask(arg0, arg1 interface{}) *gomock.Call
RangeCompleteCrossClusterTask indicates an expected call of RangeCompleteCrossClusterTask.
func (*MockExecutionManagerMockRecorder) RangeCompleteReplicationTask ¶ added in v0.23.1
func (mr *MockExecutionManagerMockRecorder) RangeCompleteReplicationTask(arg0, arg1 interface{}) *gomock.Call
RangeCompleteReplicationTask indicates an expected call of RangeCompleteReplicationTask.
func (*MockExecutionManagerMockRecorder) RangeCompleteTimerTask ¶ added in v0.23.1
func (mr *MockExecutionManagerMockRecorder) RangeCompleteTimerTask(arg0, arg1 interface{}) *gomock.Call
RangeCompleteTimerTask indicates an expected call of RangeCompleteTimerTask.
func (*MockExecutionManagerMockRecorder) RangeCompleteTransferTask ¶ added in v0.23.1
func (mr *MockExecutionManagerMockRecorder) RangeCompleteTransferTask(arg0, arg1 interface{}) *gomock.Call
RangeCompleteTransferTask indicates an expected call of RangeCompleteTransferTask.
func (*MockExecutionManagerMockRecorder) RangeDeleteReplicationTaskFromDLQ ¶ added in v0.23.1
func (mr *MockExecutionManagerMockRecorder) RangeDeleteReplicationTaskFromDLQ(arg0, arg1 interface{}) *gomock.Call
RangeDeleteReplicationTaskFromDLQ indicates an expected call of RangeDeleteReplicationTaskFromDLQ.
func (*MockExecutionManagerMockRecorder) UpdateWorkflowExecution ¶ added in v0.23.1
func (mr *MockExecutionManagerMockRecorder) UpdateWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
UpdateWorkflowExecution indicates an expected call of UpdateWorkflowExecution.
type MockExecutionStore ¶ added in v1.2.9
type MockExecutionStore struct {
// contains filtered or unexported fields
}
MockExecutionStore is a mock of ExecutionStore interface.
func NewMockExecutionStore ¶ added in v1.2.9
func NewMockExecutionStore(ctrl *gomock.Controller) *MockExecutionStore
NewMockExecutionStore creates a new mock instance.
func (*MockExecutionStore) Close ¶ added in v1.2.9
func (m *MockExecutionStore) Close()
Close mocks base method.
func (*MockExecutionStore) CompleteCrossClusterTask ¶ added in v1.2.9
func (m *MockExecutionStore) CompleteCrossClusterTask(arg0 context.Context, arg1 *CompleteCrossClusterTaskRequest) error
CompleteCrossClusterTask mocks base method.
func (*MockExecutionStore) CompleteReplicationTask ¶ added in v1.2.9
func (m *MockExecutionStore) CompleteReplicationTask(arg0 context.Context, arg1 *CompleteReplicationTaskRequest) error
CompleteReplicationTask mocks base method.
func (*MockExecutionStore) CompleteTimerTask ¶ added in v1.2.9
func (m *MockExecutionStore) CompleteTimerTask(arg0 context.Context, arg1 *CompleteTimerTaskRequest) error
CompleteTimerTask mocks base method.
func (*MockExecutionStore) CompleteTransferTask ¶ added in v1.2.9
func (m *MockExecutionStore) CompleteTransferTask(arg0 context.Context, arg1 *CompleteTransferTaskRequest) error
CompleteTransferTask mocks base method.
func (*MockExecutionStore) ConflictResolveWorkflowExecution ¶ added in v1.2.9
func (m *MockExecutionStore) ConflictResolveWorkflowExecution(arg0 context.Context, arg1 *InternalConflictResolveWorkflowExecutionRequest) error
ConflictResolveWorkflowExecution mocks base method.
func (*MockExecutionStore) CreateFailoverMarkerTasks ¶ added in v1.2.9
func (m *MockExecutionStore) CreateFailoverMarkerTasks(arg0 context.Context, arg1 *CreateFailoverMarkersRequest) error
CreateFailoverMarkerTasks mocks base method.
func (*MockExecutionStore) CreateWorkflowExecution ¶ added in v1.2.9
func (m *MockExecutionStore) CreateWorkflowExecution(arg0 context.Context, arg1 *InternalCreateWorkflowExecutionRequest) (*CreateWorkflowExecutionResponse, error)
CreateWorkflowExecution mocks base method.
func (*MockExecutionStore) DeleteCurrentWorkflowExecution ¶ added in v1.2.9
func (m *MockExecutionStore) DeleteCurrentWorkflowExecution(arg0 context.Context, arg1 *DeleteCurrentWorkflowExecutionRequest) error
DeleteCurrentWorkflowExecution mocks base method.
func (*MockExecutionStore) DeleteReplicationTaskFromDLQ ¶ added in v1.2.9
func (m *MockExecutionStore) DeleteReplicationTaskFromDLQ(arg0 context.Context, arg1 *DeleteReplicationTaskFromDLQRequest) error
DeleteReplicationTaskFromDLQ mocks base method.
func (*MockExecutionStore) DeleteWorkflowExecution ¶ added in v1.2.9
func (m *MockExecutionStore) DeleteWorkflowExecution(arg0 context.Context, arg1 *DeleteWorkflowExecutionRequest) error
DeleteWorkflowExecution mocks base method.
func (*MockExecutionStore) EXPECT ¶ added in v1.2.9
func (m *MockExecutionStore) EXPECT() *MockExecutionStoreMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockExecutionStore) GetCrossClusterTasks ¶ added in v1.2.9
func (m *MockExecutionStore) GetCrossClusterTasks(arg0 context.Context, arg1 *GetCrossClusterTasksRequest) (*GetCrossClusterTasksResponse, error)
GetCrossClusterTasks mocks base method.
func (*MockExecutionStore) GetCurrentExecution ¶ added in v1.2.9
func (m *MockExecutionStore) GetCurrentExecution(arg0 context.Context, arg1 *GetCurrentExecutionRequest) (*GetCurrentExecutionResponse, error)
GetCurrentExecution mocks base method.
func (*MockExecutionStore) GetName ¶ added in v1.2.9
func (m *MockExecutionStore) GetName() string
GetName mocks base method.
func (*MockExecutionStore) GetReplicationDLQSize ¶ added in v1.2.9
func (m *MockExecutionStore) GetReplicationDLQSize(arg0 context.Context, arg1 *GetReplicationDLQSizeRequest) (*GetReplicationDLQSizeResponse, error)
GetReplicationDLQSize mocks base method.
func (*MockExecutionStore) GetReplicationTasks ¶ added in v1.2.9
func (m *MockExecutionStore) GetReplicationTasks(arg0 context.Context, arg1 *GetReplicationTasksRequest) (*InternalGetReplicationTasksResponse, error)
GetReplicationTasks mocks base method.
func (*MockExecutionStore) GetReplicationTasksFromDLQ ¶ added in v1.2.9
func (m *MockExecutionStore) GetReplicationTasksFromDLQ(arg0 context.Context, arg1 *GetReplicationTasksFromDLQRequest) (*InternalGetReplicationTasksResponse, error)
GetReplicationTasksFromDLQ mocks base method.
func (*MockExecutionStore) GetShardID ¶ added in v1.2.9
func (m *MockExecutionStore) GetShardID() int
GetShardID mocks base method.
func (*MockExecutionStore) GetTimerIndexTasks ¶ added in v1.2.9
func (m *MockExecutionStore) GetTimerIndexTasks(arg0 context.Context, arg1 *GetTimerIndexTasksRequest) (*GetTimerIndexTasksResponse, error)
GetTimerIndexTasks mocks base method.
func (*MockExecutionStore) GetTransferTasks ¶ added in v1.2.9
func (m *MockExecutionStore) GetTransferTasks(arg0 context.Context, arg1 *GetTransferTasksRequest) (*GetTransferTasksResponse, error)
GetTransferTasks mocks base method.
func (*MockExecutionStore) GetWorkflowExecution ¶ added in v1.2.9
func (m *MockExecutionStore) GetWorkflowExecution(arg0 context.Context, arg1 *InternalGetWorkflowExecutionRequest) (*InternalGetWorkflowExecutionResponse, error)
GetWorkflowExecution mocks base method.
func (*MockExecutionStore) IsWorkflowExecutionExists ¶ added in v1.2.9
func (m *MockExecutionStore) IsWorkflowExecutionExists(arg0 context.Context, arg1 *IsWorkflowExecutionExistsRequest) (*IsWorkflowExecutionExistsResponse, error)
IsWorkflowExecutionExists mocks base method.
func (*MockExecutionStore) ListConcreteExecutions ¶ added in v1.2.9
func (m *MockExecutionStore) ListConcreteExecutions(arg0 context.Context, arg1 *ListConcreteExecutionsRequest) (*InternalListConcreteExecutionsResponse, error)
ListConcreteExecutions mocks base method.
func (*MockExecutionStore) ListCurrentExecutions ¶ added in v1.2.9
func (m *MockExecutionStore) ListCurrentExecutions(arg0 context.Context, arg1 *ListCurrentExecutionsRequest) (*ListCurrentExecutionsResponse, error)
ListCurrentExecutions mocks base method.
func (*MockExecutionStore) PutReplicationTaskToDLQ ¶ added in v1.2.9
func (m *MockExecutionStore) PutReplicationTaskToDLQ(arg0 context.Context, arg1 *InternalPutReplicationTaskToDLQRequest) error
PutReplicationTaskToDLQ mocks base method.
func (*MockExecutionStore) RangeCompleteCrossClusterTask ¶ added in v1.2.9
func (m *MockExecutionStore) RangeCompleteCrossClusterTask(arg0 context.Context, arg1 *RangeCompleteCrossClusterTaskRequest) (*RangeCompleteCrossClusterTaskResponse, error)
RangeCompleteCrossClusterTask mocks base method.
func (*MockExecutionStore) RangeCompleteReplicationTask ¶ added in v1.2.9
func (m *MockExecutionStore) RangeCompleteReplicationTask(arg0 context.Context, arg1 *RangeCompleteReplicationTaskRequest) (*RangeCompleteReplicationTaskResponse, error)
RangeCompleteReplicationTask mocks base method.
func (*MockExecutionStore) RangeCompleteTimerTask ¶ added in v1.2.9
func (m *MockExecutionStore) RangeCompleteTimerTask(arg0 context.Context, arg1 *RangeCompleteTimerTaskRequest) (*RangeCompleteTimerTaskResponse, error)
RangeCompleteTimerTask mocks base method.
func (*MockExecutionStore) RangeCompleteTransferTask ¶ added in v1.2.9
func (m *MockExecutionStore) RangeCompleteTransferTask(arg0 context.Context, arg1 *RangeCompleteTransferTaskRequest) (*RangeCompleteTransferTaskResponse, error)
RangeCompleteTransferTask mocks base method.
func (*MockExecutionStore) RangeDeleteReplicationTaskFromDLQ ¶ added in v1.2.9
func (m *MockExecutionStore) RangeDeleteReplicationTaskFromDLQ(arg0 context.Context, arg1 *RangeDeleteReplicationTaskFromDLQRequest) (*RangeDeleteReplicationTaskFromDLQResponse, error)
RangeDeleteReplicationTaskFromDLQ mocks base method.
func (*MockExecutionStore) UpdateWorkflowExecution ¶ added in v1.2.9
func (m *MockExecutionStore) UpdateWorkflowExecution(arg0 context.Context, arg1 *InternalUpdateWorkflowExecutionRequest) error
UpdateWorkflowExecution mocks base method.
type MockExecutionStoreMockRecorder ¶ added in v1.2.9
type MockExecutionStoreMockRecorder struct {
// contains filtered or unexported fields
}
MockExecutionStoreMockRecorder is the mock recorder for MockExecutionStore.
func (*MockExecutionStoreMockRecorder) Close ¶ added in v1.2.9
func (mr *MockExecutionStoreMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockExecutionStoreMockRecorder) CompleteCrossClusterTask ¶ added in v1.2.9
func (mr *MockExecutionStoreMockRecorder) CompleteCrossClusterTask(arg0, arg1 interface{}) *gomock.Call
CompleteCrossClusterTask indicates an expected call of CompleteCrossClusterTask.
func (*MockExecutionStoreMockRecorder) CompleteReplicationTask ¶ added in v1.2.9
func (mr *MockExecutionStoreMockRecorder) CompleteReplicationTask(arg0, arg1 interface{}) *gomock.Call
CompleteReplicationTask indicates an expected call of CompleteReplicationTask.
func (*MockExecutionStoreMockRecorder) CompleteTimerTask ¶ added in v1.2.9
func (mr *MockExecutionStoreMockRecorder) CompleteTimerTask(arg0, arg1 interface{}) *gomock.Call
CompleteTimerTask indicates an expected call of CompleteTimerTask.
func (*MockExecutionStoreMockRecorder) CompleteTransferTask ¶ added in v1.2.9
func (mr *MockExecutionStoreMockRecorder) CompleteTransferTask(arg0, arg1 interface{}) *gomock.Call
CompleteTransferTask indicates an expected call of CompleteTransferTask.
func (*MockExecutionStoreMockRecorder) ConflictResolveWorkflowExecution ¶ added in v1.2.9
func (mr *MockExecutionStoreMockRecorder) ConflictResolveWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
ConflictResolveWorkflowExecution indicates an expected call of ConflictResolveWorkflowExecution.
func (*MockExecutionStoreMockRecorder) CreateFailoverMarkerTasks ¶ added in v1.2.9
func (mr *MockExecutionStoreMockRecorder) CreateFailoverMarkerTasks(arg0, arg1 interface{}) *gomock.Call
CreateFailoverMarkerTasks indicates an expected call of CreateFailoverMarkerTasks.
func (*MockExecutionStoreMockRecorder) CreateWorkflowExecution ¶ added in v1.2.9
func (mr *MockExecutionStoreMockRecorder) CreateWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
CreateWorkflowExecution indicates an expected call of CreateWorkflowExecution.
func (*MockExecutionStoreMockRecorder) DeleteCurrentWorkflowExecution ¶ added in v1.2.9
func (mr *MockExecutionStoreMockRecorder) DeleteCurrentWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
DeleteCurrentWorkflowExecution indicates an expected call of DeleteCurrentWorkflowExecution.
func (*MockExecutionStoreMockRecorder) DeleteReplicationTaskFromDLQ ¶ added in v1.2.9
func (mr *MockExecutionStoreMockRecorder) DeleteReplicationTaskFromDLQ(arg0, arg1 interface{}) *gomock.Call
DeleteReplicationTaskFromDLQ indicates an expected call of DeleteReplicationTaskFromDLQ.
func (*MockExecutionStoreMockRecorder) DeleteWorkflowExecution ¶ added in v1.2.9
func (mr *MockExecutionStoreMockRecorder) DeleteWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
DeleteWorkflowExecution indicates an expected call of DeleteWorkflowExecution.
func (*MockExecutionStoreMockRecorder) GetCrossClusterTasks ¶ added in v1.2.9
func (mr *MockExecutionStoreMockRecorder) GetCrossClusterTasks(arg0, arg1 interface{}) *gomock.Call
GetCrossClusterTasks indicates an expected call of GetCrossClusterTasks.
func (*MockExecutionStoreMockRecorder) GetCurrentExecution ¶ added in v1.2.9
func (mr *MockExecutionStoreMockRecorder) GetCurrentExecution(arg0, arg1 interface{}) *gomock.Call
GetCurrentExecution indicates an expected call of GetCurrentExecution.
func (*MockExecutionStoreMockRecorder) GetName ¶ added in v1.2.9
func (mr *MockExecutionStoreMockRecorder) GetName() *gomock.Call
GetName indicates an expected call of GetName.
func (*MockExecutionStoreMockRecorder) GetReplicationDLQSize ¶ added in v1.2.9
func (mr *MockExecutionStoreMockRecorder) GetReplicationDLQSize(arg0, arg1 interface{}) *gomock.Call
GetReplicationDLQSize indicates an expected call of GetReplicationDLQSize.
func (*MockExecutionStoreMockRecorder) GetReplicationTasks ¶ added in v1.2.9
func (mr *MockExecutionStoreMockRecorder) GetReplicationTasks(arg0, arg1 interface{}) *gomock.Call
GetReplicationTasks indicates an expected call of GetReplicationTasks.
func (*MockExecutionStoreMockRecorder) GetReplicationTasksFromDLQ ¶ added in v1.2.9
func (mr *MockExecutionStoreMockRecorder) GetReplicationTasksFromDLQ(arg0, arg1 interface{}) *gomock.Call
GetReplicationTasksFromDLQ indicates an expected call of GetReplicationTasksFromDLQ.
func (*MockExecutionStoreMockRecorder) GetShardID ¶ added in v1.2.9
func (mr *MockExecutionStoreMockRecorder) GetShardID() *gomock.Call
GetShardID indicates an expected call of GetShardID.
func (*MockExecutionStoreMockRecorder) GetTimerIndexTasks ¶ added in v1.2.9
func (mr *MockExecutionStoreMockRecorder) GetTimerIndexTasks(arg0, arg1 interface{}) *gomock.Call
GetTimerIndexTasks indicates an expected call of GetTimerIndexTasks.
func (*MockExecutionStoreMockRecorder) GetTransferTasks ¶ added in v1.2.9
func (mr *MockExecutionStoreMockRecorder) GetTransferTasks(arg0, arg1 interface{}) *gomock.Call
GetTransferTasks indicates an expected call of GetTransferTasks.
func (*MockExecutionStoreMockRecorder) GetWorkflowExecution ¶ added in v1.2.9
func (mr *MockExecutionStoreMockRecorder) GetWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
GetWorkflowExecution indicates an expected call of GetWorkflowExecution.
func (*MockExecutionStoreMockRecorder) IsWorkflowExecutionExists ¶ added in v1.2.9
func (mr *MockExecutionStoreMockRecorder) IsWorkflowExecutionExists(arg0, arg1 interface{}) *gomock.Call
IsWorkflowExecutionExists indicates an expected call of IsWorkflowExecutionExists.
func (*MockExecutionStoreMockRecorder) ListConcreteExecutions ¶ added in v1.2.9
func (mr *MockExecutionStoreMockRecorder) ListConcreteExecutions(arg0, arg1 interface{}) *gomock.Call
ListConcreteExecutions indicates an expected call of ListConcreteExecutions.
func (*MockExecutionStoreMockRecorder) ListCurrentExecutions ¶ added in v1.2.9
func (mr *MockExecutionStoreMockRecorder) ListCurrentExecutions(arg0, arg1 interface{}) *gomock.Call
ListCurrentExecutions indicates an expected call of ListCurrentExecutions.
func (*MockExecutionStoreMockRecorder) PutReplicationTaskToDLQ ¶ added in v1.2.9
func (mr *MockExecutionStoreMockRecorder) PutReplicationTaskToDLQ(arg0, arg1 interface{}) *gomock.Call
PutReplicationTaskToDLQ indicates an expected call of PutReplicationTaskToDLQ.
func (*MockExecutionStoreMockRecorder) RangeCompleteCrossClusterTask ¶ added in v1.2.9
func (mr *MockExecutionStoreMockRecorder) RangeCompleteCrossClusterTask(arg0, arg1 interface{}) *gomock.Call
RangeCompleteCrossClusterTask indicates an expected call of RangeCompleteCrossClusterTask.
func (*MockExecutionStoreMockRecorder) RangeCompleteReplicationTask ¶ added in v1.2.9
func (mr *MockExecutionStoreMockRecorder) RangeCompleteReplicationTask(arg0, arg1 interface{}) *gomock.Call
RangeCompleteReplicationTask indicates an expected call of RangeCompleteReplicationTask.
func (*MockExecutionStoreMockRecorder) RangeCompleteTimerTask ¶ added in v1.2.9
func (mr *MockExecutionStoreMockRecorder) RangeCompleteTimerTask(arg0, arg1 interface{}) *gomock.Call
RangeCompleteTimerTask indicates an expected call of RangeCompleteTimerTask.
func (*MockExecutionStoreMockRecorder) RangeCompleteTransferTask ¶ added in v1.2.9
func (mr *MockExecutionStoreMockRecorder) RangeCompleteTransferTask(arg0, arg1 interface{}) *gomock.Call
RangeCompleteTransferTask indicates an expected call of RangeCompleteTransferTask.
func (*MockExecutionStoreMockRecorder) RangeDeleteReplicationTaskFromDLQ ¶ added in v1.2.9
func (mr *MockExecutionStoreMockRecorder) RangeDeleteReplicationTaskFromDLQ(arg0, arg1 interface{}) *gomock.Call
RangeDeleteReplicationTaskFromDLQ indicates an expected call of RangeDeleteReplicationTaskFromDLQ.
func (*MockExecutionStoreMockRecorder) UpdateWorkflowExecution ¶ added in v1.2.9
func (mr *MockExecutionStoreMockRecorder) UpdateWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
UpdateWorkflowExecution indicates an expected call of UpdateWorkflowExecution.
type MockHistoryManager ¶ added in v0.23.1
type MockHistoryManager struct {
// contains filtered or unexported fields
}
MockHistoryManager is a mock of HistoryManager interface.
func NewMockHistoryManager ¶ added in v0.23.1
func NewMockHistoryManager(ctrl *gomock.Controller) *MockHistoryManager
NewMockHistoryManager creates a new mock instance.
func (*MockHistoryManager) AppendHistoryNodes ¶ added in v0.23.1
func (m *MockHistoryManager) AppendHistoryNodes(arg0 context.Context, arg1 *AppendHistoryNodesRequest) (*AppendHistoryNodesResponse, error)
AppendHistoryNodes mocks base method.
func (*MockHistoryManager) Close ¶ added in v0.23.1
func (m *MockHistoryManager) Close()
Close mocks base method.
func (*MockHistoryManager) DeleteHistoryBranch ¶ added in v0.23.1
func (m *MockHistoryManager) DeleteHistoryBranch(arg0 context.Context, arg1 *DeleteHistoryBranchRequest) error
DeleteHistoryBranch mocks base method.
func (*MockHistoryManager) EXPECT ¶ added in v0.23.1
func (m *MockHistoryManager) EXPECT() *MockHistoryManagerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockHistoryManager) ForkHistoryBranch ¶ added in v0.23.1
func (m *MockHistoryManager) ForkHistoryBranch(arg0 context.Context, arg1 *ForkHistoryBranchRequest) (*ForkHistoryBranchResponse, error)
ForkHistoryBranch mocks base method.
func (*MockHistoryManager) GetAllHistoryTreeBranches ¶ added in v0.23.1
func (m *MockHistoryManager) GetAllHistoryTreeBranches(arg0 context.Context, arg1 *GetAllHistoryTreeBranchesRequest) (*GetAllHistoryTreeBranchesResponse, error)
GetAllHistoryTreeBranches mocks base method.
func (*MockHistoryManager) GetHistoryTree ¶ added in v0.23.1
func (m *MockHistoryManager) GetHistoryTree(arg0 context.Context, arg1 *GetHistoryTreeRequest) (*GetHistoryTreeResponse, error)
GetHistoryTree mocks base method.
func (*MockHistoryManager) GetName ¶ added in v0.23.1
func (m *MockHistoryManager) GetName() string
GetName mocks base method.
func (*MockHistoryManager) ReadHistoryBranch ¶ added in v0.23.1
func (m *MockHistoryManager) ReadHistoryBranch(arg0 context.Context, arg1 *ReadHistoryBranchRequest) (*ReadHistoryBranchResponse, error)
ReadHistoryBranch mocks base method.
func (*MockHistoryManager) ReadHistoryBranchByBatch ¶ added in v0.23.1
func (m *MockHistoryManager) ReadHistoryBranchByBatch(arg0 context.Context, arg1 *ReadHistoryBranchRequest) (*ReadHistoryBranchByBatchResponse, error)
ReadHistoryBranchByBatch mocks base method.
func (*MockHistoryManager) ReadRawHistoryBranch ¶ added in v0.23.1
func (m *MockHistoryManager) ReadRawHistoryBranch(arg0 context.Context, arg1 *ReadHistoryBranchRequest) (*ReadRawHistoryBranchResponse, error)
ReadRawHistoryBranch mocks base method.
type MockHistoryManagerMockRecorder ¶ added in v0.23.1
type MockHistoryManagerMockRecorder struct {
// contains filtered or unexported fields
}
MockHistoryManagerMockRecorder is the mock recorder for MockHistoryManager.
func (*MockHistoryManagerMockRecorder) AppendHistoryNodes ¶ added in v0.23.1
func (mr *MockHistoryManagerMockRecorder) AppendHistoryNodes(arg0, arg1 interface{}) *gomock.Call
AppendHistoryNodes indicates an expected call of AppendHistoryNodes.
func (*MockHistoryManagerMockRecorder) Close ¶ added in v0.23.1
func (mr *MockHistoryManagerMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockHistoryManagerMockRecorder) DeleteHistoryBranch ¶ added in v0.23.1
func (mr *MockHistoryManagerMockRecorder) DeleteHistoryBranch(arg0, arg1 interface{}) *gomock.Call
DeleteHistoryBranch indicates an expected call of DeleteHistoryBranch.
func (*MockHistoryManagerMockRecorder) ForkHistoryBranch ¶ added in v0.23.1
func (mr *MockHistoryManagerMockRecorder) ForkHistoryBranch(arg0, arg1 interface{}) *gomock.Call
ForkHistoryBranch indicates an expected call of ForkHistoryBranch.
func (*MockHistoryManagerMockRecorder) GetAllHistoryTreeBranches ¶ added in v0.23.1
func (mr *MockHistoryManagerMockRecorder) GetAllHistoryTreeBranches(arg0, arg1 interface{}) *gomock.Call
GetAllHistoryTreeBranches indicates an expected call of GetAllHistoryTreeBranches.
func (*MockHistoryManagerMockRecorder) GetHistoryTree ¶ added in v0.23.1
func (mr *MockHistoryManagerMockRecorder) GetHistoryTree(arg0, arg1 interface{}) *gomock.Call
GetHistoryTree indicates an expected call of GetHistoryTree.
func (*MockHistoryManagerMockRecorder) GetName ¶ added in v0.23.1
func (mr *MockHistoryManagerMockRecorder) GetName() *gomock.Call
GetName indicates an expected call of GetName.
func (*MockHistoryManagerMockRecorder) ReadHistoryBranch ¶ added in v0.23.1
func (mr *MockHistoryManagerMockRecorder) ReadHistoryBranch(arg0, arg1 interface{}) *gomock.Call
ReadHistoryBranch indicates an expected call of ReadHistoryBranch.
func (*MockHistoryManagerMockRecorder) ReadHistoryBranchByBatch ¶ added in v0.23.1
func (mr *MockHistoryManagerMockRecorder) ReadHistoryBranchByBatch(arg0, arg1 interface{}) *gomock.Call
ReadHistoryBranchByBatch indicates an expected call of ReadHistoryBranchByBatch.
func (*MockHistoryManagerMockRecorder) ReadRawHistoryBranch ¶ added in v0.23.1
func (mr *MockHistoryManagerMockRecorder) ReadRawHistoryBranch(arg0, arg1 interface{}) *gomock.Call
ReadRawHistoryBranch indicates an expected call of ReadRawHistoryBranch.
type MockPayloadSerializer ¶ added in v1.2.9
type MockPayloadSerializer struct {
// contains filtered or unexported fields
}
MockPayloadSerializer is a mock of PayloadSerializer interface.
func NewMockPayloadSerializer ¶ added in v1.2.9
func NewMockPayloadSerializer(ctrl *gomock.Controller) *MockPayloadSerializer
NewMockPayloadSerializer creates a new mock instance.
func (*MockPayloadSerializer) DeserializeAsyncWorkflowsConfig ¶ added in v1.2.9
func (m *MockPayloadSerializer) DeserializeAsyncWorkflowsConfig(arg0 *DataBlob) (*types.AsyncWorkflowConfiguration, error)
DeserializeAsyncWorkflowsConfig mocks base method.
func (*MockPayloadSerializer) DeserializeBadBinaries ¶ added in v1.2.9
func (m *MockPayloadSerializer) DeserializeBadBinaries(arg0 *DataBlob) (*types.BadBinaries, error)
DeserializeBadBinaries mocks base method.
func (*MockPayloadSerializer) DeserializeBatchEvents ¶ added in v1.2.9
func (m *MockPayloadSerializer) DeserializeBatchEvents(arg0 *DataBlob) ([]*types.HistoryEvent, error)
DeserializeBatchEvents mocks base method.
func (*MockPayloadSerializer) DeserializeChecksum ¶ added in v1.2.9
func (m *MockPayloadSerializer) DeserializeChecksum(arg0 *DataBlob) (checksum.Checksum, error)
DeserializeChecksum mocks base method.
func (*MockPayloadSerializer) DeserializeDynamicConfigBlob ¶ added in v1.2.9
func (m *MockPayloadSerializer) DeserializeDynamicConfigBlob(arg0 *DataBlob) (*types.DynamicConfigBlob, error)
DeserializeDynamicConfigBlob mocks base method.
func (*MockPayloadSerializer) DeserializeEvent ¶ added in v1.2.9
func (m *MockPayloadSerializer) DeserializeEvent(arg0 *DataBlob) (*types.HistoryEvent, error)
DeserializeEvent mocks base method.
func (*MockPayloadSerializer) DeserializeIsolationGroups ¶ added in v1.2.9
func (m *MockPayloadSerializer) DeserializeIsolationGroups(arg0 *DataBlob) (*types.IsolationGroupConfiguration, error)
DeserializeIsolationGroups mocks base method.
func (*MockPayloadSerializer) DeserializePendingFailoverMarkers ¶ added in v1.2.9
func (m *MockPayloadSerializer) DeserializePendingFailoverMarkers(arg0 *DataBlob) ([]*types.FailoverMarkerAttributes, error)
DeserializePendingFailoverMarkers mocks base method.
func (*MockPayloadSerializer) DeserializeProcessingQueueStates ¶ added in v1.2.9
func (m *MockPayloadSerializer) DeserializeProcessingQueueStates(arg0 *DataBlob) (*types.ProcessingQueueStates, error)
DeserializeProcessingQueueStates mocks base method.
func (*MockPayloadSerializer) DeserializeResetPoints ¶ added in v1.2.9
func (m *MockPayloadSerializer) DeserializeResetPoints(arg0 *DataBlob) (*types.ResetPoints, error)
DeserializeResetPoints mocks base method.
func (*MockPayloadSerializer) DeserializeVersionHistories ¶ added in v1.2.9
func (m *MockPayloadSerializer) DeserializeVersionHistories(arg0 *DataBlob) (*types.VersionHistories, error)
DeserializeVersionHistories mocks base method.
func (*MockPayloadSerializer) DeserializeVisibilityMemo ¶ added in v1.2.9
func (m *MockPayloadSerializer) DeserializeVisibilityMemo(arg0 *DataBlob) (*types.Memo, error)
DeserializeVisibilityMemo mocks base method.
func (*MockPayloadSerializer) EXPECT ¶ added in v1.2.9
func (m *MockPayloadSerializer) EXPECT() *MockPayloadSerializerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockPayloadSerializer) SerializeAsyncWorkflowsConfig ¶ added in v1.2.9
func (m *MockPayloadSerializer) SerializeAsyncWorkflowsConfig(arg0 *types.AsyncWorkflowConfiguration, arg1 common.EncodingType) (*DataBlob, error)
SerializeAsyncWorkflowsConfig mocks base method.
func (*MockPayloadSerializer) SerializeBadBinaries ¶ added in v1.2.9
func (m *MockPayloadSerializer) SerializeBadBinaries(arg0 *types.BadBinaries, arg1 common.EncodingType) (*DataBlob, error)
SerializeBadBinaries mocks base method.
func (*MockPayloadSerializer) SerializeBatchEvents ¶ added in v1.2.9
func (m *MockPayloadSerializer) SerializeBatchEvents(arg0 []*types.HistoryEvent, arg1 common.EncodingType) (*DataBlob, error)
SerializeBatchEvents mocks base method.
func (*MockPayloadSerializer) SerializeChecksum ¶ added in v1.2.9
func (m *MockPayloadSerializer) SerializeChecksum(arg0 checksum.Checksum, arg1 common.EncodingType) (*DataBlob, error)
SerializeChecksum mocks base method.
func (*MockPayloadSerializer) SerializeDynamicConfigBlob ¶ added in v1.2.9
func (m *MockPayloadSerializer) SerializeDynamicConfigBlob(arg0 *types.DynamicConfigBlob, arg1 common.EncodingType) (*DataBlob, error)
SerializeDynamicConfigBlob mocks base method.
func (*MockPayloadSerializer) SerializeEvent ¶ added in v1.2.9
func (m *MockPayloadSerializer) SerializeEvent(arg0 *types.HistoryEvent, arg1 common.EncodingType) (*DataBlob, error)
SerializeEvent mocks base method.
func (*MockPayloadSerializer) SerializeIsolationGroups ¶ added in v1.2.9
func (m *MockPayloadSerializer) SerializeIsolationGroups(arg0 *types.IsolationGroupConfiguration, arg1 common.EncodingType) (*DataBlob, error)
SerializeIsolationGroups mocks base method.
func (*MockPayloadSerializer) SerializePendingFailoverMarkers ¶ added in v1.2.9
func (m *MockPayloadSerializer) SerializePendingFailoverMarkers(arg0 []*types.FailoverMarkerAttributes, arg1 common.EncodingType) (*DataBlob, error)
SerializePendingFailoverMarkers mocks base method.
func (*MockPayloadSerializer) SerializeProcessingQueueStates ¶ added in v1.2.9
func (m *MockPayloadSerializer) SerializeProcessingQueueStates(arg0 *types.ProcessingQueueStates, arg1 common.EncodingType) (*DataBlob, error)
SerializeProcessingQueueStates mocks base method.
func (*MockPayloadSerializer) SerializeResetPoints ¶ added in v1.2.9
func (m *MockPayloadSerializer) SerializeResetPoints(arg0 *types.ResetPoints, arg1 common.EncodingType) (*DataBlob, error)
SerializeResetPoints mocks base method.
func (*MockPayloadSerializer) SerializeVersionHistories ¶ added in v1.2.9
func (m *MockPayloadSerializer) SerializeVersionHistories(arg0 *types.VersionHistories, arg1 common.EncodingType) (*DataBlob, error)
SerializeVersionHistories mocks base method.
func (*MockPayloadSerializer) SerializeVisibilityMemo ¶ added in v1.2.9
func (m *MockPayloadSerializer) SerializeVisibilityMemo(arg0 *types.Memo, arg1 common.EncodingType) (*DataBlob, error)
SerializeVisibilityMemo mocks base method.
type MockPayloadSerializerMockRecorder ¶ added in v1.2.9
type MockPayloadSerializerMockRecorder struct {
// contains filtered or unexported fields
}
MockPayloadSerializerMockRecorder is the mock recorder for MockPayloadSerializer.
func (*MockPayloadSerializerMockRecorder) DeserializeAsyncWorkflowsConfig ¶ added in v1.2.9
func (mr *MockPayloadSerializerMockRecorder) DeserializeAsyncWorkflowsConfig(arg0 interface{}) *gomock.Call
DeserializeAsyncWorkflowsConfig indicates an expected call of DeserializeAsyncWorkflowsConfig.
func (*MockPayloadSerializerMockRecorder) DeserializeBadBinaries ¶ added in v1.2.9
func (mr *MockPayloadSerializerMockRecorder) DeserializeBadBinaries(arg0 interface{}) *gomock.Call
DeserializeBadBinaries indicates an expected call of DeserializeBadBinaries.
func (*MockPayloadSerializerMockRecorder) DeserializeBatchEvents ¶ added in v1.2.9
func (mr *MockPayloadSerializerMockRecorder) DeserializeBatchEvents(arg0 interface{}) *gomock.Call
DeserializeBatchEvents indicates an expected call of DeserializeBatchEvents.
func (*MockPayloadSerializerMockRecorder) DeserializeChecksum ¶ added in v1.2.9
func (mr *MockPayloadSerializerMockRecorder) DeserializeChecksum(arg0 interface{}) *gomock.Call
DeserializeChecksum indicates an expected call of DeserializeChecksum.
func (*MockPayloadSerializerMockRecorder) DeserializeDynamicConfigBlob ¶ added in v1.2.9
func (mr *MockPayloadSerializerMockRecorder) DeserializeDynamicConfigBlob(arg0 interface{}) *gomock.Call
DeserializeDynamicConfigBlob indicates an expected call of DeserializeDynamicConfigBlob.
func (*MockPayloadSerializerMockRecorder) DeserializeEvent ¶ added in v1.2.9
func (mr *MockPayloadSerializerMockRecorder) DeserializeEvent(arg0 interface{}) *gomock.Call
DeserializeEvent indicates an expected call of DeserializeEvent.
func (*MockPayloadSerializerMockRecorder) DeserializeIsolationGroups ¶ added in v1.2.9
func (mr *MockPayloadSerializerMockRecorder) DeserializeIsolationGroups(arg0 interface{}) *gomock.Call
DeserializeIsolationGroups indicates an expected call of DeserializeIsolationGroups.
func (*MockPayloadSerializerMockRecorder) DeserializePendingFailoverMarkers ¶ added in v1.2.9
func (mr *MockPayloadSerializerMockRecorder) DeserializePendingFailoverMarkers(arg0 interface{}) *gomock.Call
DeserializePendingFailoverMarkers indicates an expected call of DeserializePendingFailoverMarkers.
func (*MockPayloadSerializerMockRecorder) DeserializeProcessingQueueStates ¶ added in v1.2.9
func (mr *MockPayloadSerializerMockRecorder) DeserializeProcessingQueueStates(arg0 interface{}) *gomock.Call
DeserializeProcessingQueueStates indicates an expected call of DeserializeProcessingQueueStates.
func (*MockPayloadSerializerMockRecorder) DeserializeResetPoints ¶ added in v1.2.9
func (mr *MockPayloadSerializerMockRecorder) DeserializeResetPoints(arg0 interface{}) *gomock.Call
DeserializeResetPoints indicates an expected call of DeserializeResetPoints.
func (*MockPayloadSerializerMockRecorder) DeserializeVersionHistories ¶ added in v1.2.9
func (mr *MockPayloadSerializerMockRecorder) DeserializeVersionHistories(arg0 interface{}) *gomock.Call
DeserializeVersionHistories indicates an expected call of DeserializeVersionHistories.
func (*MockPayloadSerializerMockRecorder) DeserializeVisibilityMemo ¶ added in v1.2.9
func (mr *MockPayloadSerializerMockRecorder) DeserializeVisibilityMemo(arg0 interface{}) *gomock.Call
DeserializeVisibilityMemo indicates an expected call of DeserializeVisibilityMemo.
func (*MockPayloadSerializerMockRecorder) SerializeAsyncWorkflowsConfig ¶ added in v1.2.9
func (mr *MockPayloadSerializerMockRecorder) SerializeAsyncWorkflowsConfig(arg0, arg1 interface{}) *gomock.Call
SerializeAsyncWorkflowsConfig indicates an expected call of SerializeAsyncWorkflowsConfig.
func (*MockPayloadSerializerMockRecorder) SerializeBadBinaries ¶ added in v1.2.9
func (mr *MockPayloadSerializerMockRecorder) SerializeBadBinaries(arg0, arg1 interface{}) *gomock.Call
SerializeBadBinaries indicates an expected call of SerializeBadBinaries.
func (*MockPayloadSerializerMockRecorder) SerializeBatchEvents ¶ added in v1.2.9
func (mr *MockPayloadSerializerMockRecorder) SerializeBatchEvents(arg0, arg1 interface{}) *gomock.Call
SerializeBatchEvents indicates an expected call of SerializeBatchEvents.
func (*MockPayloadSerializerMockRecorder) SerializeChecksum ¶ added in v1.2.9
func (mr *MockPayloadSerializerMockRecorder) SerializeChecksum(arg0, arg1 interface{}) *gomock.Call
SerializeChecksum indicates an expected call of SerializeChecksum.
func (*MockPayloadSerializerMockRecorder) SerializeDynamicConfigBlob ¶ added in v1.2.9
func (mr *MockPayloadSerializerMockRecorder) SerializeDynamicConfigBlob(arg0, arg1 interface{}) *gomock.Call
SerializeDynamicConfigBlob indicates an expected call of SerializeDynamicConfigBlob.
func (*MockPayloadSerializerMockRecorder) SerializeEvent ¶ added in v1.2.9
func (mr *MockPayloadSerializerMockRecorder) SerializeEvent(arg0, arg1 interface{}) *gomock.Call
SerializeEvent indicates an expected call of SerializeEvent.
func (*MockPayloadSerializerMockRecorder) SerializeIsolationGroups ¶ added in v1.2.9
func (mr *MockPayloadSerializerMockRecorder) SerializeIsolationGroups(arg0, arg1 interface{}) *gomock.Call
SerializeIsolationGroups indicates an expected call of SerializeIsolationGroups.
func (*MockPayloadSerializerMockRecorder) SerializePendingFailoverMarkers ¶ added in v1.2.9
func (mr *MockPayloadSerializerMockRecorder) SerializePendingFailoverMarkers(arg0, arg1 interface{}) *gomock.Call
SerializePendingFailoverMarkers indicates an expected call of SerializePendingFailoverMarkers.
func (*MockPayloadSerializerMockRecorder) SerializeProcessingQueueStates ¶ added in v1.2.9
func (mr *MockPayloadSerializerMockRecorder) SerializeProcessingQueueStates(arg0, arg1 interface{}) *gomock.Call
SerializeProcessingQueueStates indicates an expected call of SerializeProcessingQueueStates.
func (*MockPayloadSerializerMockRecorder) SerializeResetPoints ¶ added in v1.2.9
func (mr *MockPayloadSerializerMockRecorder) SerializeResetPoints(arg0, arg1 interface{}) *gomock.Call
SerializeResetPoints indicates an expected call of SerializeResetPoints.
func (*MockPayloadSerializerMockRecorder) SerializeVersionHistories ¶ added in v1.2.9
func (mr *MockPayloadSerializerMockRecorder) SerializeVersionHistories(arg0, arg1 interface{}) *gomock.Call
SerializeVersionHistories indicates an expected call of SerializeVersionHistories.
func (*MockPayloadSerializerMockRecorder) SerializeVisibilityMemo ¶ added in v1.2.9
func (mr *MockPayloadSerializerMockRecorder) SerializeVisibilityMemo(arg0, arg1 interface{}) *gomock.Call
SerializeVisibilityMemo indicates an expected call of SerializeVisibilityMemo.
type MockQueueManager ¶ added in v0.23.1
type MockQueueManager struct {
// contains filtered or unexported fields
}
MockQueueManager is a mock of QueueManager interface.
func NewMockQueueManager ¶ added in v0.23.1
func NewMockQueueManager(ctrl *gomock.Controller) *MockQueueManager
NewMockQueueManager creates a new mock instance.
func (*MockQueueManager) Close ¶ added in v0.23.1
func (m *MockQueueManager) Close()
Close mocks base method.
func (*MockQueueManager) DeleteMessageFromDLQ ¶ added in v0.23.1
func (m *MockQueueManager) DeleteMessageFromDLQ(arg0 context.Context, arg1 int64) error
DeleteMessageFromDLQ mocks base method.
func (*MockQueueManager) DeleteMessagesBefore ¶ added in v0.23.1
func (m *MockQueueManager) DeleteMessagesBefore(arg0 context.Context, arg1 int64) error
DeleteMessagesBefore mocks base method.
func (*MockQueueManager) EXPECT ¶ added in v0.23.1
func (m *MockQueueManager) EXPECT() *MockQueueManagerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockQueueManager) EnqueueMessage ¶ added in v0.23.1
func (m *MockQueueManager) EnqueueMessage(arg0 context.Context, arg1 []byte) error
EnqueueMessage mocks base method.
func (*MockQueueManager) EnqueueMessageToDLQ ¶ added in v0.23.1
func (m *MockQueueManager) EnqueueMessageToDLQ(arg0 context.Context, arg1 []byte) error
EnqueueMessageToDLQ mocks base method.
func (*MockQueueManager) GetAckLevels ¶ added in v0.23.1
GetAckLevels mocks base method.
func (*MockQueueManager) GetDLQAckLevels ¶ added in v0.23.1
GetDLQAckLevels mocks base method.
func (*MockQueueManager) GetDLQSize ¶ added in v0.23.1
func (m *MockQueueManager) GetDLQSize(arg0 context.Context) (int64, error)
GetDLQSize mocks base method.
func (*MockQueueManager) RangeDeleteMessagesFromDLQ ¶ added in v0.23.1
func (m *MockQueueManager) RangeDeleteMessagesFromDLQ(arg0 context.Context, arg1, arg2 int64) error
RangeDeleteMessagesFromDLQ mocks base method.
func (*MockQueueManager) ReadMessages ¶ added in v0.23.1
func (m *MockQueueManager) ReadMessages(arg0 context.Context, arg1 int64, arg2 int) (QueueMessageList, error)
ReadMessages mocks base method.
func (*MockQueueManager) ReadMessagesFromDLQ ¶ added in v0.23.1
func (m *MockQueueManager) ReadMessagesFromDLQ(arg0 context.Context, arg1, arg2 int64, arg3 int, arg4 []byte) ([]*QueueMessage, []byte, error)
ReadMessagesFromDLQ mocks base method.
func (*MockQueueManager) UpdateAckLevel ¶ added in v0.23.1
UpdateAckLevel mocks base method.
func (*MockQueueManager) UpdateDLQAckLevel ¶ added in v0.23.1
UpdateDLQAckLevel mocks base method.
type MockQueueManagerMockRecorder ¶ added in v0.23.1
type MockQueueManagerMockRecorder struct {
// contains filtered or unexported fields
}
MockQueueManagerMockRecorder is the mock recorder for MockQueueManager.
func (*MockQueueManagerMockRecorder) Close ¶ added in v0.23.1
func (mr *MockQueueManagerMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockQueueManagerMockRecorder) DeleteMessageFromDLQ ¶ added in v0.23.1
func (mr *MockQueueManagerMockRecorder) DeleteMessageFromDLQ(arg0, arg1 interface{}) *gomock.Call
DeleteMessageFromDLQ indicates an expected call of DeleteMessageFromDLQ.
func (*MockQueueManagerMockRecorder) DeleteMessagesBefore ¶ added in v0.23.1
func (mr *MockQueueManagerMockRecorder) DeleteMessagesBefore(arg0, arg1 interface{}) *gomock.Call
DeleteMessagesBefore indicates an expected call of DeleteMessagesBefore.
func (*MockQueueManagerMockRecorder) EnqueueMessage ¶ added in v0.23.1
func (mr *MockQueueManagerMockRecorder) EnqueueMessage(arg0, arg1 interface{}) *gomock.Call
EnqueueMessage indicates an expected call of EnqueueMessage.
func (*MockQueueManagerMockRecorder) EnqueueMessageToDLQ ¶ added in v0.23.1
func (mr *MockQueueManagerMockRecorder) EnqueueMessageToDLQ(arg0, arg1 interface{}) *gomock.Call
EnqueueMessageToDLQ indicates an expected call of EnqueueMessageToDLQ.
func (*MockQueueManagerMockRecorder) GetAckLevels ¶ added in v0.23.1
func (mr *MockQueueManagerMockRecorder) GetAckLevels(arg0 interface{}) *gomock.Call
GetAckLevels indicates an expected call of GetAckLevels.
func (*MockQueueManagerMockRecorder) GetDLQAckLevels ¶ added in v0.23.1
func (mr *MockQueueManagerMockRecorder) GetDLQAckLevels(arg0 interface{}) *gomock.Call
GetDLQAckLevels indicates an expected call of GetDLQAckLevels.
func (*MockQueueManagerMockRecorder) GetDLQSize ¶ added in v0.23.1
func (mr *MockQueueManagerMockRecorder) GetDLQSize(arg0 interface{}) *gomock.Call
GetDLQSize indicates an expected call of GetDLQSize.
func (*MockQueueManagerMockRecorder) RangeDeleteMessagesFromDLQ ¶ added in v0.23.1
func (mr *MockQueueManagerMockRecorder) RangeDeleteMessagesFromDLQ(arg0, arg1, arg2 interface{}) *gomock.Call
RangeDeleteMessagesFromDLQ indicates an expected call of RangeDeleteMessagesFromDLQ.
func (*MockQueueManagerMockRecorder) ReadMessages ¶ added in v0.23.1
func (mr *MockQueueManagerMockRecorder) ReadMessages(arg0, arg1, arg2 interface{}) *gomock.Call
ReadMessages indicates an expected call of ReadMessages.
func (*MockQueueManagerMockRecorder) ReadMessagesFromDLQ ¶ added in v0.23.1
func (mr *MockQueueManagerMockRecorder) ReadMessagesFromDLQ(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call
ReadMessagesFromDLQ indicates an expected call of ReadMessagesFromDLQ.
func (*MockQueueManagerMockRecorder) UpdateAckLevel ¶ added in v0.23.1
func (mr *MockQueueManagerMockRecorder) UpdateAckLevel(arg0, arg1, arg2 interface{}) *gomock.Call
UpdateAckLevel indicates an expected call of UpdateAckLevel.
func (*MockQueueManagerMockRecorder) UpdateDLQAckLevel ¶ added in v0.23.1
func (mr *MockQueueManagerMockRecorder) UpdateDLQAckLevel(arg0, arg1, arg2 interface{}) *gomock.Call
UpdateDLQAckLevel indicates an expected call of UpdateDLQAckLevel.
type MockRetryer ¶ added in v1.2.5
type MockRetryer struct {
// contains filtered or unexported fields
}
MockRetryer is a mock of Retryer interface.
func NewMockRetryer ¶ added in v1.2.5
func NewMockRetryer(ctrl *gomock.Controller) *MockRetryer
NewMockRetryer creates a new mock instance.
func (*MockRetryer) CompleteTimerTask ¶ added in v1.2.5
func (m *MockRetryer) CompleteTimerTask(ctx context.Context, request *CompleteTimerTaskRequest) error
CompleteTimerTask mocks base method.
func (*MockRetryer) DeleteCurrentWorkflowExecution ¶ added in v1.2.5
func (m *MockRetryer) DeleteCurrentWorkflowExecution(arg0 context.Context, arg1 *DeleteCurrentWorkflowExecutionRequest) error
DeleteCurrentWorkflowExecution mocks base method.
func (*MockRetryer) DeleteWorkflowExecution ¶ added in v1.2.5
func (m *MockRetryer) DeleteWorkflowExecution(arg0 context.Context, arg1 *DeleteWorkflowExecutionRequest) error
DeleteWorkflowExecution mocks base method.
func (*MockRetryer) EXPECT ¶ added in v1.2.5
func (m *MockRetryer) EXPECT() *MockRetryerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockRetryer) GetCurrentExecution ¶ added in v1.2.5
func (m *MockRetryer) GetCurrentExecution(arg0 context.Context, arg1 *GetCurrentExecutionRequest) (*GetCurrentExecutionResponse, error)
GetCurrentExecution mocks base method.
func (*MockRetryer) GetShardID ¶ added in v1.2.5
func (m *MockRetryer) GetShardID() int
GetShardID mocks base method.
func (*MockRetryer) GetTimerIndexTasks ¶ added in v1.2.5
func (m *MockRetryer) GetTimerIndexTasks(arg0 context.Context, arg1 *GetTimerIndexTasksRequest) (*GetTimerIndexTasksResponse, error)
GetTimerIndexTasks mocks base method.
func (*MockRetryer) GetWorkflowExecution ¶ added in v1.2.5
func (m *MockRetryer) GetWorkflowExecution(arg0 context.Context, arg1 *GetWorkflowExecutionRequest) (*GetWorkflowExecutionResponse, error)
GetWorkflowExecution mocks base method.
func (*MockRetryer) IsWorkflowExecutionExists ¶ added in v1.2.5
func (m *MockRetryer) IsWorkflowExecutionExists(arg0 context.Context, arg1 *IsWorkflowExecutionExistsRequest) (*IsWorkflowExecutionExistsResponse, error)
IsWorkflowExecutionExists mocks base method.
func (*MockRetryer) ListConcreteExecutions ¶ added in v1.2.5
func (m *MockRetryer) ListConcreteExecutions(arg0 context.Context, arg1 *ListConcreteExecutionsRequest) (*ListConcreteExecutionsResponse, error)
ListConcreteExecutions mocks base method.
func (*MockRetryer) ListCurrentExecutions ¶ added in v1.2.5
func (m *MockRetryer) ListCurrentExecutions(arg0 context.Context, arg1 *ListCurrentExecutionsRequest) (*ListCurrentExecutionsResponse, error)
ListCurrentExecutions mocks base method.
func (*MockRetryer) ReadHistoryBranch ¶ added in v1.2.5
func (m *MockRetryer) ReadHistoryBranch(arg0 context.Context, arg1 *ReadHistoryBranchRequest) (*ReadHistoryBranchResponse, error)
ReadHistoryBranch mocks base method.
type MockRetryerMockRecorder ¶ added in v1.2.5
type MockRetryerMockRecorder struct {
// contains filtered or unexported fields
}
MockRetryerMockRecorder is the mock recorder for MockRetryer.
func (*MockRetryerMockRecorder) CompleteTimerTask ¶ added in v1.2.5
func (mr *MockRetryerMockRecorder) CompleteTimerTask(ctx, request interface{}) *gomock.Call
CompleteTimerTask indicates an expected call of CompleteTimerTask.
func (*MockRetryerMockRecorder) DeleteCurrentWorkflowExecution ¶ added in v1.2.5
func (mr *MockRetryerMockRecorder) DeleteCurrentWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
DeleteCurrentWorkflowExecution indicates an expected call of DeleteCurrentWorkflowExecution.
func (*MockRetryerMockRecorder) DeleteWorkflowExecution ¶ added in v1.2.5
func (mr *MockRetryerMockRecorder) DeleteWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
DeleteWorkflowExecution indicates an expected call of DeleteWorkflowExecution.
func (*MockRetryerMockRecorder) GetCurrentExecution ¶ added in v1.2.5
func (mr *MockRetryerMockRecorder) GetCurrentExecution(arg0, arg1 interface{}) *gomock.Call
GetCurrentExecution indicates an expected call of GetCurrentExecution.
func (*MockRetryerMockRecorder) GetShardID ¶ added in v1.2.5
func (mr *MockRetryerMockRecorder) GetShardID() *gomock.Call
GetShardID indicates an expected call of GetShardID.
func (*MockRetryerMockRecorder) GetTimerIndexTasks ¶ added in v1.2.5
func (mr *MockRetryerMockRecorder) GetTimerIndexTasks(arg0, arg1 interface{}) *gomock.Call
GetTimerIndexTasks indicates an expected call of GetTimerIndexTasks.
func (*MockRetryerMockRecorder) GetWorkflowExecution ¶ added in v1.2.5
func (mr *MockRetryerMockRecorder) GetWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
GetWorkflowExecution indicates an expected call of GetWorkflowExecution.
func (*MockRetryerMockRecorder) IsWorkflowExecutionExists ¶ added in v1.2.5
func (mr *MockRetryerMockRecorder) IsWorkflowExecutionExists(arg0, arg1 interface{}) *gomock.Call
IsWorkflowExecutionExists indicates an expected call of IsWorkflowExecutionExists.
func (*MockRetryerMockRecorder) ListConcreteExecutions ¶ added in v1.2.5
func (mr *MockRetryerMockRecorder) ListConcreteExecutions(arg0, arg1 interface{}) *gomock.Call
ListConcreteExecutions indicates an expected call of ListConcreteExecutions.
func (*MockRetryerMockRecorder) ListCurrentExecutions ¶ added in v1.2.5
func (mr *MockRetryerMockRecorder) ListCurrentExecutions(arg0, arg1 interface{}) *gomock.Call
ListCurrentExecutions indicates an expected call of ListCurrentExecutions.
func (*MockRetryerMockRecorder) ReadHistoryBranch ¶ added in v1.2.5
func (mr *MockRetryerMockRecorder) ReadHistoryBranch(arg0, arg1 interface{}) *gomock.Call
ReadHistoryBranch indicates an expected call of ReadHistoryBranch.
type MockShardManager ¶ added in v0.23.1
type MockShardManager struct {
// contains filtered or unexported fields
}
MockShardManager is a mock of ShardManager interface.
func NewMockShardManager ¶ added in v0.23.1
func NewMockShardManager(ctrl *gomock.Controller) *MockShardManager
NewMockShardManager creates a new mock instance.
func (*MockShardManager) Close ¶ added in v0.23.1
func (m *MockShardManager) Close()
Close mocks base method.
func (*MockShardManager) CreateShard ¶ added in v0.23.1
func (m *MockShardManager) CreateShard(arg0 context.Context, arg1 *CreateShardRequest) error
CreateShard mocks base method.
func (*MockShardManager) EXPECT ¶ added in v0.23.1
func (m *MockShardManager) EXPECT() *MockShardManagerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockShardManager) GetName ¶ added in v0.23.1
func (m *MockShardManager) GetName() string
GetName mocks base method.
func (*MockShardManager) GetShard ¶ added in v0.23.1
func (m *MockShardManager) GetShard(arg0 context.Context, arg1 *GetShardRequest) (*GetShardResponse, error)
GetShard mocks base method.
func (*MockShardManager) UpdateShard ¶ added in v0.23.1
func (m *MockShardManager) UpdateShard(arg0 context.Context, arg1 *UpdateShardRequest) error
UpdateShard mocks base method.
type MockShardManagerMockRecorder ¶ added in v0.23.1
type MockShardManagerMockRecorder struct {
// contains filtered or unexported fields
}
MockShardManagerMockRecorder is the mock recorder for MockShardManager.
func (*MockShardManagerMockRecorder) Close ¶ added in v0.23.1
func (mr *MockShardManagerMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockShardManagerMockRecorder) CreateShard ¶ added in v0.23.1
func (mr *MockShardManagerMockRecorder) CreateShard(arg0, arg1 interface{}) *gomock.Call
CreateShard indicates an expected call of CreateShard.
func (*MockShardManagerMockRecorder) GetName ¶ added in v0.23.1
func (mr *MockShardManagerMockRecorder) GetName() *gomock.Call
GetName indicates an expected call of GetName.
func (*MockShardManagerMockRecorder) GetShard ¶ added in v0.23.1
func (mr *MockShardManagerMockRecorder) GetShard(arg0, arg1 interface{}) *gomock.Call
GetShard indicates an expected call of GetShard.
func (*MockShardManagerMockRecorder) UpdateShard ¶ added in v0.23.1
func (mr *MockShardManagerMockRecorder) UpdateShard(arg0, arg1 interface{}) *gomock.Call
UpdateShard indicates an expected call of UpdateShard.
type MockShardStore ¶ added in v1.2.10
type MockShardStore struct {
// contains filtered or unexported fields
}
MockShardStore is a mock of ShardStore interface.
func NewMockShardStore ¶ added in v1.2.10
func NewMockShardStore(ctrl *gomock.Controller) *MockShardStore
NewMockShardStore creates a new mock instance.
func (*MockShardStore) Close ¶ added in v1.2.10
func (m *MockShardStore) Close()
Close mocks base method.
func (*MockShardStore) CreateShard ¶ added in v1.2.10
func (m *MockShardStore) CreateShard(arg0 context.Context, arg1 *InternalCreateShardRequest) error
CreateShard mocks base method.
func (*MockShardStore) EXPECT ¶ added in v1.2.10
func (m *MockShardStore) EXPECT() *MockShardStoreMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockShardStore) GetName ¶ added in v1.2.10
func (m *MockShardStore) GetName() string
GetName mocks base method.
func (*MockShardStore) GetShard ¶ added in v1.2.10
func (m *MockShardStore) GetShard(arg0 context.Context, arg1 *InternalGetShardRequest) (*InternalGetShardResponse, error)
GetShard mocks base method.
func (*MockShardStore) UpdateShard ¶ added in v1.2.10
func (m *MockShardStore) UpdateShard(arg0 context.Context, arg1 *InternalUpdateShardRequest) error
UpdateShard mocks base method.
type MockShardStoreMockRecorder ¶ added in v1.2.10
type MockShardStoreMockRecorder struct {
// contains filtered or unexported fields
}
MockShardStoreMockRecorder is the mock recorder for MockShardStore.
func (*MockShardStoreMockRecorder) Close ¶ added in v1.2.10
func (mr *MockShardStoreMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockShardStoreMockRecorder) CreateShard ¶ added in v1.2.10
func (mr *MockShardStoreMockRecorder) CreateShard(arg0, arg1 interface{}) *gomock.Call
CreateShard indicates an expected call of CreateShard.
func (*MockShardStoreMockRecorder) GetName ¶ added in v1.2.10
func (mr *MockShardStoreMockRecorder) GetName() *gomock.Call
GetName indicates an expected call of GetName.
func (*MockShardStoreMockRecorder) GetShard ¶ added in v1.2.10
func (mr *MockShardStoreMockRecorder) GetShard(arg0, arg1 interface{}) *gomock.Call
GetShard indicates an expected call of GetShard.
func (*MockShardStoreMockRecorder) UpdateShard ¶ added in v1.2.10
func (mr *MockShardStoreMockRecorder) UpdateShard(arg0, arg1 interface{}) *gomock.Call
UpdateShard indicates an expected call of UpdateShard.
type MockTask ¶ added in v0.23.1
type MockTask struct {
// contains filtered or unexported fields
}
MockTask is a mock of Task interface.
func NewMockTask ¶ added in v0.23.1
func NewMockTask(ctrl *gomock.Controller) *MockTask
NewMockTask creates a new mock instance.
func (*MockTask) EXPECT ¶ added in v0.23.1
func (m *MockTask) EXPECT() *MockTaskMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockTask) GetVersion ¶ added in v0.23.1
GetVersion mocks base method.
func (*MockTask) GetVisibilityTimestamp ¶ added in v0.23.1
GetVisibilityTimestamp mocks base method.
func (*MockTask) SetVersion ¶ added in v0.23.1
SetVersion mocks base method.
func (*MockTask) SetVisibilityTimestamp ¶ added in v0.23.1
SetVisibilityTimestamp mocks base method.
type MockTaskManager ¶ added in v0.23.1
type MockTaskManager struct {
// contains filtered or unexported fields
}
MockTaskManager is a mock of TaskManager interface.
func NewMockTaskManager ¶ added in v0.23.1
func NewMockTaskManager(ctrl *gomock.Controller) *MockTaskManager
NewMockTaskManager creates a new mock instance.
func (*MockTaskManager) Close ¶ added in v0.23.1
func (m *MockTaskManager) Close()
Close mocks base method.
func (*MockTaskManager) CompleteTask ¶ added in v0.23.1
func (m *MockTaskManager) CompleteTask(arg0 context.Context, arg1 *CompleteTaskRequest) error
CompleteTask mocks base method.
func (*MockTaskManager) CompleteTasksLessThan ¶ added in v0.23.1
func (m *MockTaskManager) CompleteTasksLessThan(arg0 context.Context, arg1 *CompleteTasksLessThanRequest) (*CompleteTasksLessThanResponse, error)
CompleteTasksLessThan mocks base method.
func (*MockTaskManager) CreateTasks ¶ added in v0.23.1
func (m *MockTaskManager) CreateTasks(arg0 context.Context, arg1 *CreateTasksRequest) (*CreateTasksResponse, error)
CreateTasks mocks base method.
func (*MockTaskManager) DeleteTaskList ¶ added in v0.23.1
func (m *MockTaskManager) DeleteTaskList(arg0 context.Context, arg1 *DeleteTaskListRequest) error
DeleteTaskList mocks base method.
func (*MockTaskManager) EXPECT ¶ added in v0.23.1
func (m *MockTaskManager) EXPECT() *MockTaskManagerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockTaskManager) GetName ¶ added in v0.23.1
func (m *MockTaskManager) GetName() string
GetName mocks base method.
func (*MockTaskManager) GetOrphanTasks ¶ added in v0.23.1
func (m *MockTaskManager) GetOrphanTasks(arg0 context.Context, arg1 *GetOrphanTasksRequest) (*GetOrphanTasksResponse, error)
GetOrphanTasks mocks base method.
func (*MockTaskManager) GetTaskListSize ¶ added in v1.2.6
func (m *MockTaskManager) GetTaskListSize(arg0 context.Context, arg1 *GetTaskListSizeRequest) (*GetTaskListSizeResponse, error)
GetTaskListSize mocks base method.
func (*MockTaskManager) GetTasks ¶ added in v0.23.1
func (m *MockTaskManager) GetTasks(arg0 context.Context, arg1 *GetTasksRequest) (*GetTasksResponse, error)
GetTasks mocks base method.
func (*MockTaskManager) LeaseTaskList ¶ added in v0.23.1
func (m *MockTaskManager) LeaseTaskList(arg0 context.Context, arg1 *LeaseTaskListRequest) (*LeaseTaskListResponse, error)
LeaseTaskList mocks base method.
func (*MockTaskManager) ListTaskList ¶ added in v0.23.1
func (m *MockTaskManager) ListTaskList(arg0 context.Context, arg1 *ListTaskListRequest) (*ListTaskListResponse, error)
ListTaskList mocks base method.
func (*MockTaskManager) UpdateTaskList ¶ added in v0.23.1
func (m *MockTaskManager) UpdateTaskList(arg0 context.Context, arg1 *UpdateTaskListRequest) (*UpdateTaskListResponse, error)
UpdateTaskList mocks base method.
type MockTaskManagerMockRecorder ¶ added in v0.23.1
type MockTaskManagerMockRecorder struct {
// contains filtered or unexported fields
}
MockTaskManagerMockRecorder is the mock recorder for MockTaskManager.
func (*MockTaskManagerMockRecorder) Close ¶ added in v0.23.1
func (mr *MockTaskManagerMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockTaskManagerMockRecorder) CompleteTask ¶ added in v0.23.1
func (mr *MockTaskManagerMockRecorder) CompleteTask(arg0, arg1 interface{}) *gomock.Call
CompleteTask indicates an expected call of CompleteTask.
func (*MockTaskManagerMockRecorder) CompleteTasksLessThan ¶ added in v0.23.1
func (mr *MockTaskManagerMockRecorder) CompleteTasksLessThan(arg0, arg1 interface{}) *gomock.Call
CompleteTasksLessThan indicates an expected call of CompleteTasksLessThan.
func (*MockTaskManagerMockRecorder) CreateTasks ¶ added in v0.23.1
func (mr *MockTaskManagerMockRecorder) CreateTasks(arg0, arg1 interface{}) *gomock.Call
CreateTasks indicates an expected call of CreateTasks.
func (*MockTaskManagerMockRecorder) DeleteTaskList ¶ added in v0.23.1
func (mr *MockTaskManagerMockRecorder) DeleteTaskList(arg0, arg1 interface{}) *gomock.Call
DeleteTaskList indicates an expected call of DeleteTaskList.
func (*MockTaskManagerMockRecorder) GetName ¶ added in v0.23.1
func (mr *MockTaskManagerMockRecorder) GetName() *gomock.Call
GetName indicates an expected call of GetName.
func (*MockTaskManagerMockRecorder) GetOrphanTasks ¶ added in v0.23.1
func (mr *MockTaskManagerMockRecorder) GetOrphanTasks(arg0, arg1 interface{}) *gomock.Call
GetOrphanTasks indicates an expected call of GetOrphanTasks.
func (*MockTaskManagerMockRecorder) GetTaskListSize ¶ added in v1.2.6
func (mr *MockTaskManagerMockRecorder) GetTaskListSize(arg0, arg1 interface{}) *gomock.Call
GetTaskListSize indicates an expected call of GetTaskListSize.
func (*MockTaskManagerMockRecorder) GetTasks ¶ added in v0.23.1
func (mr *MockTaskManagerMockRecorder) GetTasks(arg0, arg1 interface{}) *gomock.Call
GetTasks indicates an expected call of GetTasks.
func (*MockTaskManagerMockRecorder) LeaseTaskList ¶ added in v0.23.1
func (mr *MockTaskManagerMockRecorder) LeaseTaskList(arg0, arg1 interface{}) *gomock.Call
LeaseTaskList indicates an expected call of LeaseTaskList.
func (*MockTaskManagerMockRecorder) ListTaskList ¶ added in v0.23.1
func (mr *MockTaskManagerMockRecorder) ListTaskList(arg0, arg1 interface{}) *gomock.Call
ListTaskList indicates an expected call of ListTaskList.
func (*MockTaskManagerMockRecorder) UpdateTaskList ¶ added in v0.23.1
func (mr *MockTaskManagerMockRecorder) UpdateTaskList(arg0, arg1 interface{}) *gomock.Call
UpdateTaskList indicates an expected call of UpdateTaskList.
type MockTaskMockRecorder ¶ added in v0.23.1
type MockTaskMockRecorder struct {
// contains filtered or unexported fields
}
MockTaskMockRecorder is the mock recorder for MockTask.
func (*MockTaskMockRecorder) GetTaskID ¶ added in v0.23.1
func (mr *MockTaskMockRecorder) GetTaskID() *gomock.Call
GetTaskID indicates an expected call of GetTaskID.
func (*MockTaskMockRecorder) GetType ¶ added in v0.23.1
func (mr *MockTaskMockRecorder) GetType() *gomock.Call
GetType indicates an expected call of GetType.
func (*MockTaskMockRecorder) GetVersion ¶ added in v0.23.1
func (mr *MockTaskMockRecorder) GetVersion() *gomock.Call
GetVersion indicates an expected call of GetVersion.
func (*MockTaskMockRecorder) GetVisibilityTimestamp ¶ added in v0.23.1
func (mr *MockTaskMockRecorder) GetVisibilityTimestamp() *gomock.Call
GetVisibilityTimestamp indicates an expected call of GetVisibilityTimestamp.
func (*MockTaskMockRecorder) SetTaskID ¶ added in v0.23.1
func (mr *MockTaskMockRecorder) SetTaskID(arg0 interface{}) *gomock.Call
SetTaskID indicates an expected call of SetTaskID.
func (*MockTaskMockRecorder) SetVersion ¶ added in v0.23.1
func (mr *MockTaskMockRecorder) SetVersion(arg0 interface{}) *gomock.Call
SetVersion indicates an expected call of SetVersion.
func (*MockTaskMockRecorder) SetVisibilityTimestamp ¶ added in v0.23.1
func (mr *MockTaskMockRecorder) SetVisibilityTimestamp(arg0 interface{}) *gomock.Call
SetVisibilityTimestamp indicates an expected call of SetVisibilityTimestamp.
type MockVisibilityManager ¶ added in v1.2.7
type MockVisibilityManager struct {
// contains filtered or unexported fields
}
MockVisibilityManager is a mock of VisibilityManager interface.
func NewMockVisibilityManager ¶ added in v1.2.7
func NewMockVisibilityManager(ctrl *gomock.Controller) *MockVisibilityManager
NewMockVisibilityManager creates a new mock instance.
func (*MockVisibilityManager) Close ¶ added in v1.2.7
func (m *MockVisibilityManager) Close()
Close mocks base method.
func (*MockVisibilityManager) CountWorkflowExecutions ¶ added in v1.2.7
func (m *MockVisibilityManager) CountWorkflowExecutions(arg0 context.Context, arg1 *CountWorkflowExecutionsRequest) (*CountWorkflowExecutionsResponse, error)
CountWorkflowExecutions mocks base method.
func (*MockVisibilityManager) DeleteUninitializedWorkflowExecution ¶ added in v1.2.7
func (m *MockVisibilityManager) DeleteUninitializedWorkflowExecution(arg0 context.Context, arg1 *VisibilityDeleteWorkflowExecutionRequest) error
DeleteUninitializedWorkflowExecution mocks base method.
func (*MockVisibilityManager) DeleteWorkflowExecution ¶ added in v1.2.7
func (m *MockVisibilityManager) DeleteWorkflowExecution(arg0 context.Context, arg1 *VisibilityDeleteWorkflowExecutionRequest) error
DeleteWorkflowExecution mocks base method.
func (*MockVisibilityManager) EXPECT ¶ added in v1.2.7
func (m *MockVisibilityManager) EXPECT() *MockVisibilityManagerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockVisibilityManager) GetClosedWorkflowExecution ¶ added in v1.2.7
func (m *MockVisibilityManager) GetClosedWorkflowExecution(arg0 context.Context, arg1 *GetClosedWorkflowExecutionRequest) (*GetClosedWorkflowExecutionResponse, error)
GetClosedWorkflowExecution mocks base method.
func (*MockVisibilityManager) GetName ¶ added in v1.2.7
func (m *MockVisibilityManager) GetName() string
GetName mocks base method.
func (*MockVisibilityManager) ListAllWorkflowExecutions ¶ added in v1.2.11
func (m *MockVisibilityManager) ListAllWorkflowExecutions(arg0 context.Context, arg1 *ListAllWorkflowExecutionsRequest) (*ListWorkflowExecutionsResponse, error)
ListAllWorkflowExecutions mocks base method.
func (*MockVisibilityManager) ListClosedWorkflowExecutions ¶ added in v1.2.7
func (m *MockVisibilityManager) ListClosedWorkflowExecutions(arg0 context.Context, arg1 *ListWorkflowExecutionsRequest) (*ListWorkflowExecutionsResponse, error)
ListClosedWorkflowExecutions mocks base method.
func (*MockVisibilityManager) ListClosedWorkflowExecutionsByStatus ¶ added in v1.2.7
func (m *MockVisibilityManager) ListClosedWorkflowExecutionsByStatus(arg0 context.Context, arg1 *ListClosedWorkflowExecutionsByStatusRequest) (*ListWorkflowExecutionsResponse, error)
ListClosedWorkflowExecutionsByStatus mocks base method.
func (*MockVisibilityManager) ListClosedWorkflowExecutionsByType ¶ added in v1.2.7
func (m *MockVisibilityManager) ListClosedWorkflowExecutionsByType(arg0 context.Context, arg1 *ListWorkflowExecutionsByTypeRequest) (*ListWorkflowExecutionsResponse, error)
ListClosedWorkflowExecutionsByType mocks base method.
func (*MockVisibilityManager) ListClosedWorkflowExecutionsByWorkflowID ¶ added in v1.2.7
func (m *MockVisibilityManager) ListClosedWorkflowExecutionsByWorkflowID(arg0 context.Context, arg1 *ListWorkflowExecutionsByWorkflowIDRequest) (*ListWorkflowExecutionsResponse, error)
ListClosedWorkflowExecutionsByWorkflowID mocks base method.
func (*MockVisibilityManager) ListOpenWorkflowExecutions ¶ added in v1.2.7
func (m *MockVisibilityManager) ListOpenWorkflowExecutions(arg0 context.Context, arg1 *ListWorkflowExecutionsRequest) (*ListWorkflowExecutionsResponse, error)
ListOpenWorkflowExecutions mocks base method.
func (*MockVisibilityManager) ListOpenWorkflowExecutionsByType ¶ added in v1.2.7
func (m *MockVisibilityManager) ListOpenWorkflowExecutionsByType(arg0 context.Context, arg1 *ListWorkflowExecutionsByTypeRequest) (*ListWorkflowExecutionsResponse, error)
ListOpenWorkflowExecutionsByType mocks base method.
func (*MockVisibilityManager) ListOpenWorkflowExecutionsByWorkflowID ¶ added in v1.2.7
func (m *MockVisibilityManager) ListOpenWorkflowExecutionsByWorkflowID(arg0 context.Context, arg1 *ListWorkflowExecutionsByWorkflowIDRequest) (*ListWorkflowExecutionsResponse, error)
ListOpenWorkflowExecutionsByWorkflowID mocks base method.
func (*MockVisibilityManager) ListWorkflowExecutions ¶ added in v1.2.7
func (m *MockVisibilityManager) ListWorkflowExecutions(arg0 context.Context, arg1 *ListWorkflowExecutionsByQueryRequest) (*ListWorkflowExecutionsResponse, error)
ListWorkflowExecutions mocks base method.
func (*MockVisibilityManager) RecordWorkflowExecutionClosed ¶ added in v1.2.7
func (m *MockVisibilityManager) RecordWorkflowExecutionClosed(arg0 context.Context, arg1 *RecordWorkflowExecutionClosedRequest) error
RecordWorkflowExecutionClosed mocks base method.
func (*MockVisibilityManager) RecordWorkflowExecutionStarted ¶ added in v1.2.7
func (m *MockVisibilityManager) RecordWorkflowExecutionStarted(arg0 context.Context, arg1 *RecordWorkflowExecutionStartedRequest) error
RecordWorkflowExecutionStarted mocks base method.
func (*MockVisibilityManager) RecordWorkflowExecutionUninitialized ¶ added in v1.2.7
func (m *MockVisibilityManager) RecordWorkflowExecutionUninitialized(arg0 context.Context, arg1 *RecordWorkflowExecutionUninitializedRequest) error
RecordWorkflowExecutionUninitialized mocks base method.
func (*MockVisibilityManager) ScanWorkflowExecutions ¶ added in v1.2.7
func (m *MockVisibilityManager) ScanWorkflowExecutions(arg0 context.Context, arg1 *ListWorkflowExecutionsByQueryRequest) (*ListWorkflowExecutionsResponse, error)
ScanWorkflowExecutions mocks base method.
func (*MockVisibilityManager) UpsertWorkflowExecution ¶ added in v1.2.7
func (m *MockVisibilityManager) UpsertWorkflowExecution(arg0 context.Context, arg1 *UpsertWorkflowExecutionRequest) error
UpsertWorkflowExecution mocks base method.
type MockVisibilityManagerMockRecorder ¶ added in v1.2.7
type MockVisibilityManagerMockRecorder struct {
// contains filtered or unexported fields
}
MockVisibilityManagerMockRecorder is the mock recorder for MockVisibilityManager.
func (*MockVisibilityManagerMockRecorder) Close ¶ added in v1.2.7
func (mr *MockVisibilityManagerMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockVisibilityManagerMockRecorder) CountWorkflowExecutions ¶ added in v1.2.7
func (mr *MockVisibilityManagerMockRecorder) CountWorkflowExecutions(arg0, arg1 interface{}) *gomock.Call
CountWorkflowExecutions indicates an expected call of CountWorkflowExecutions.
func (*MockVisibilityManagerMockRecorder) DeleteUninitializedWorkflowExecution ¶ added in v1.2.7
func (mr *MockVisibilityManagerMockRecorder) DeleteUninitializedWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
DeleteUninitializedWorkflowExecution indicates an expected call of DeleteUninitializedWorkflowExecution.
func (*MockVisibilityManagerMockRecorder) DeleteWorkflowExecution ¶ added in v1.2.7
func (mr *MockVisibilityManagerMockRecorder) DeleteWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
DeleteWorkflowExecution indicates an expected call of DeleteWorkflowExecution.
func (*MockVisibilityManagerMockRecorder) GetClosedWorkflowExecution ¶ added in v1.2.7
func (mr *MockVisibilityManagerMockRecorder) GetClosedWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
GetClosedWorkflowExecution indicates an expected call of GetClosedWorkflowExecution.
func (*MockVisibilityManagerMockRecorder) GetName ¶ added in v1.2.7
func (mr *MockVisibilityManagerMockRecorder) GetName() *gomock.Call
GetName indicates an expected call of GetName.
func (*MockVisibilityManagerMockRecorder) ListAllWorkflowExecutions ¶ added in v1.2.11
func (mr *MockVisibilityManagerMockRecorder) ListAllWorkflowExecutions(arg0, arg1 interface{}) *gomock.Call
ListAllWorkflowExecutions indicates an expected call of ListAllWorkflowExecutions.
func (*MockVisibilityManagerMockRecorder) ListClosedWorkflowExecutions ¶ added in v1.2.7
func (mr *MockVisibilityManagerMockRecorder) ListClosedWorkflowExecutions(arg0, arg1 interface{}) *gomock.Call
ListClosedWorkflowExecutions indicates an expected call of ListClosedWorkflowExecutions.
func (*MockVisibilityManagerMockRecorder) ListClosedWorkflowExecutionsByStatus ¶ added in v1.2.7
func (mr *MockVisibilityManagerMockRecorder) ListClosedWorkflowExecutionsByStatus(arg0, arg1 interface{}) *gomock.Call
ListClosedWorkflowExecutionsByStatus indicates an expected call of ListClosedWorkflowExecutionsByStatus.
func (*MockVisibilityManagerMockRecorder) ListClosedWorkflowExecutionsByType ¶ added in v1.2.7
func (mr *MockVisibilityManagerMockRecorder) ListClosedWorkflowExecutionsByType(arg0, arg1 interface{}) *gomock.Call
ListClosedWorkflowExecutionsByType indicates an expected call of ListClosedWorkflowExecutionsByType.
func (*MockVisibilityManagerMockRecorder) ListClosedWorkflowExecutionsByWorkflowID ¶ added in v1.2.7
func (mr *MockVisibilityManagerMockRecorder) ListClosedWorkflowExecutionsByWorkflowID(arg0, arg1 interface{}) *gomock.Call
ListClosedWorkflowExecutionsByWorkflowID indicates an expected call of ListClosedWorkflowExecutionsByWorkflowID.
func (*MockVisibilityManagerMockRecorder) ListOpenWorkflowExecutions ¶ added in v1.2.7
func (mr *MockVisibilityManagerMockRecorder) ListOpenWorkflowExecutions(arg0, arg1 interface{}) *gomock.Call
ListOpenWorkflowExecutions indicates an expected call of ListOpenWorkflowExecutions.
func (*MockVisibilityManagerMockRecorder) ListOpenWorkflowExecutionsByType ¶ added in v1.2.7
func (mr *MockVisibilityManagerMockRecorder) ListOpenWorkflowExecutionsByType(arg0, arg1 interface{}) *gomock.Call
ListOpenWorkflowExecutionsByType indicates an expected call of ListOpenWorkflowExecutionsByType.
func (*MockVisibilityManagerMockRecorder) ListOpenWorkflowExecutionsByWorkflowID ¶ added in v1.2.7
func (mr *MockVisibilityManagerMockRecorder) ListOpenWorkflowExecutionsByWorkflowID(arg0, arg1 interface{}) *gomock.Call
ListOpenWorkflowExecutionsByWorkflowID indicates an expected call of ListOpenWorkflowExecutionsByWorkflowID.
func (*MockVisibilityManagerMockRecorder) ListWorkflowExecutions ¶ added in v1.2.7
func (mr *MockVisibilityManagerMockRecorder) ListWorkflowExecutions(arg0, arg1 interface{}) *gomock.Call
ListWorkflowExecutions indicates an expected call of ListWorkflowExecutions.
func (*MockVisibilityManagerMockRecorder) RecordWorkflowExecutionClosed ¶ added in v1.2.7
func (mr *MockVisibilityManagerMockRecorder) RecordWorkflowExecutionClosed(arg0, arg1 interface{}) *gomock.Call
RecordWorkflowExecutionClosed indicates an expected call of RecordWorkflowExecutionClosed.
func (*MockVisibilityManagerMockRecorder) RecordWorkflowExecutionStarted ¶ added in v1.2.7
func (mr *MockVisibilityManagerMockRecorder) RecordWorkflowExecutionStarted(arg0, arg1 interface{}) *gomock.Call
RecordWorkflowExecutionStarted indicates an expected call of RecordWorkflowExecutionStarted.
func (*MockVisibilityManagerMockRecorder) RecordWorkflowExecutionUninitialized ¶ added in v1.2.7
func (mr *MockVisibilityManagerMockRecorder) RecordWorkflowExecutionUninitialized(arg0, arg1 interface{}) *gomock.Call
RecordWorkflowExecutionUninitialized indicates an expected call of RecordWorkflowExecutionUninitialized.
func (*MockVisibilityManagerMockRecorder) ScanWorkflowExecutions ¶ added in v1.2.7
func (mr *MockVisibilityManagerMockRecorder) ScanWorkflowExecutions(arg0, arg1 interface{}) *gomock.Call
ScanWorkflowExecutions indicates an expected call of ScanWorkflowExecutions.
func (*MockVisibilityManagerMockRecorder) UpsertWorkflowExecution ¶ added in v1.2.7
func (mr *MockVisibilityManagerMockRecorder) UpsertWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
UpsertWorkflowExecution indicates an expected call of UpsertWorkflowExecution.
type MockVisibilityStore ¶ added in v1.2.9
type MockVisibilityStore struct {
// contains filtered or unexported fields
}
MockVisibilityStore is a mock of VisibilityStore interface.
func NewMockVisibilityStore ¶ added in v1.2.9
func NewMockVisibilityStore(ctrl *gomock.Controller) *MockVisibilityStore
NewMockVisibilityStore creates a new mock instance.
func (*MockVisibilityStore) Close ¶ added in v1.2.9
func (m *MockVisibilityStore) Close()
Close mocks base method.
func (*MockVisibilityStore) CountWorkflowExecutions ¶ added in v1.2.9
func (m *MockVisibilityStore) CountWorkflowExecutions(arg0 context.Context, arg1 *CountWorkflowExecutionsRequest) (*CountWorkflowExecutionsResponse, error)
CountWorkflowExecutions mocks base method.
func (*MockVisibilityStore) DeleteUninitializedWorkflowExecution ¶ added in v1.2.9
func (m *MockVisibilityStore) DeleteUninitializedWorkflowExecution(arg0 context.Context, arg1 *VisibilityDeleteWorkflowExecutionRequest) error
DeleteUninitializedWorkflowExecution mocks base method.
func (*MockVisibilityStore) DeleteWorkflowExecution ¶ added in v1.2.9
func (m *MockVisibilityStore) DeleteWorkflowExecution(arg0 context.Context, arg1 *VisibilityDeleteWorkflowExecutionRequest) error
DeleteWorkflowExecution mocks base method.
func (*MockVisibilityStore) EXPECT ¶ added in v1.2.9
func (m *MockVisibilityStore) EXPECT() *MockVisibilityStoreMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockVisibilityStore) GetClosedWorkflowExecution ¶ added in v1.2.9
func (m *MockVisibilityStore) GetClosedWorkflowExecution(arg0 context.Context, arg1 *InternalGetClosedWorkflowExecutionRequest) (*InternalGetClosedWorkflowExecutionResponse, error)
GetClosedWorkflowExecution mocks base method.
func (*MockVisibilityStore) GetName ¶ added in v1.2.9
func (m *MockVisibilityStore) GetName() string
GetName mocks base method.
func (*MockVisibilityStore) ListAllWorkflowExecutions ¶ added in v1.2.11
func (m *MockVisibilityStore) ListAllWorkflowExecutions(arg0 context.Context, arg1 *InternalListAllWorkflowExecutionsByTypeRequest) (*InternalListWorkflowExecutionsResponse, error)
ListAllWorkflowExecutions mocks base method.
func (*MockVisibilityStore) ListClosedWorkflowExecutions ¶ added in v1.2.9
func (m *MockVisibilityStore) ListClosedWorkflowExecutions(arg0 context.Context, arg1 *InternalListWorkflowExecutionsRequest) (*InternalListWorkflowExecutionsResponse, error)
ListClosedWorkflowExecutions mocks base method.
func (*MockVisibilityStore) ListClosedWorkflowExecutionsByStatus ¶ added in v1.2.9
func (m *MockVisibilityStore) ListClosedWorkflowExecutionsByStatus(arg0 context.Context, arg1 *InternalListClosedWorkflowExecutionsByStatusRequest) (*InternalListWorkflowExecutionsResponse, error)
ListClosedWorkflowExecutionsByStatus mocks base method.
func (*MockVisibilityStore) ListClosedWorkflowExecutionsByType ¶ added in v1.2.9
func (m *MockVisibilityStore) ListClosedWorkflowExecutionsByType(arg0 context.Context, arg1 *InternalListWorkflowExecutionsByTypeRequest) (*InternalListWorkflowExecutionsResponse, error)
ListClosedWorkflowExecutionsByType mocks base method.
func (*MockVisibilityStore) ListClosedWorkflowExecutionsByWorkflowID ¶ added in v1.2.9
func (m *MockVisibilityStore) ListClosedWorkflowExecutionsByWorkflowID(arg0 context.Context, arg1 *InternalListWorkflowExecutionsByWorkflowIDRequest) (*InternalListWorkflowExecutionsResponse, error)
ListClosedWorkflowExecutionsByWorkflowID mocks base method.
func (*MockVisibilityStore) ListOpenWorkflowExecutions ¶ added in v1.2.9
func (m *MockVisibilityStore) ListOpenWorkflowExecutions(arg0 context.Context, arg1 *InternalListWorkflowExecutionsRequest) (*InternalListWorkflowExecutionsResponse, error)
ListOpenWorkflowExecutions mocks base method.
func (*MockVisibilityStore) ListOpenWorkflowExecutionsByType ¶ added in v1.2.9
func (m *MockVisibilityStore) ListOpenWorkflowExecutionsByType(arg0 context.Context, arg1 *InternalListWorkflowExecutionsByTypeRequest) (*InternalListWorkflowExecutionsResponse, error)
ListOpenWorkflowExecutionsByType mocks base method.
func (*MockVisibilityStore) ListOpenWorkflowExecutionsByWorkflowID ¶ added in v1.2.9
func (m *MockVisibilityStore) ListOpenWorkflowExecutionsByWorkflowID(arg0 context.Context, arg1 *InternalListWorkflowExecutionsByWorkflowIDRequest) (*InternalListWorkflowExecutionsResponse, error)
ListOpenWorkflowExecutionsByWorkflowID mocks base method.
func (*MockVisibilityStore) ListWorkflowExecutions ¶ added in v1.2.9
func (m *MockVisibilityStore) ListWorkflowExecutions(arg0 context.Context, arg1 *ListWorkflowExecutionsByQueryRequest) (*InternalListWorkflowExecutionsResponse, error)
ListWorkflowExecutions mocks base method.
func (*MockVisibilityStore) RecordWorkflowExecutionClosed ¶ added in v1.2.9
func (m *MockVisibilityStore) RecordWorkflowExecutionClosed(arg0 context.Context, arg1 *InternalRecordWorkflowExecutionClosedRequest) error
RecordWorkflowExecutionClosed mocks base method.
func (*MockVisibilityStore) RecordWorkflowExecutionStarted ¶ added in v1.2.9
func (m *MockVisibilityStore) RecordWorkflowExecutionStarted(arg0 context.Context, arg1 *InternalRecordWorkflowExecutionStartedRequest) error
RecordWorkflowExecutionStarted mocks base method.
func (*MockVisibilityStore) RecordWorkflowExecutionUninitialized ¶ added in v1.2.9
func (m *MockVisibilityStore) RecordWorkflowExecutionUninitialized(arg0 context.Context, arg1 *InternalRecordWorkflowExecutionUninitializedRequest) error
RecordWorkflowExecutionUninitialized mocks base method.
func (*MockVisibilityStore) ScanWorkflowExecutions ¶ added in v1.2.9
func (m *MockVisibilityStore) ScanWorkflowExecutions(arg0 context.Context, arg1 *ListWorkflowExecutionsByQueryRequest) (*InternalListWorkflowExecutionsResponse, error)
ScanWorkflowExecutions mocks base method.
func (*MockVisibilityStore) UpsertWorkflowExecution ¶ added in v1.2.9
func (m *MockVisibilityStore) UpsertWorkflowExecution(arg0 context.Context, arg1 *InternalUpsertWorkflowExecutionRequest) error
UpsertWorkflowExecution mocks base method.
type MockVisibilityStoreMockRecorder ¶ added in v1.2.9
type MockVisibilityStoreMockRecorder struct {
// contains filtered or unexported fields
}
MockVisibilityStoreMockRecorder is the mock recorder for MockVisibilityStore.
func (*MockVisibilityStoreMockRecorder) Close ¶ added in v1.2.9
func (mr *MockVisibilityStoreMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockVisibilityStoreMockRecorder) CountWorkflowExecutions ¶ added in v1.2.9
func (mr *MockVisibilityStoreMockRecorder) CountWorkflowExecutions(arg0, arg1 interface{}) *gomock.Call
CountWorkflowExecutions indicates an expected call of CountWorkflowExecutions.
func (*MockVisibilityStoreMockRecorder) DeleteUninitializedWorkflowExecution ¶ added in v1.2.9
func (mr *MockVisibilityStoreMockRecorder) DeleteUninitializedWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
DeleteUninitializedWorkflowExecution indicates an expected call of DeleteUninitializedWorkflowExecution.
func (*MockVisibilityStoreMockRecorder) DeleteWorkflowExecution ¶ added in v1.2.9
func (mr *MockVisibilityStoreMockRecorder) DeleteWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
DeleteWorkflowExecution indicates an expected call of DeleteWorkflowExecution.
func (*MockVisibilityStoreMockRecorder) GetClosedWorkflowExecution ¶ added in v1.2.9
func (mr *MockVisibilityStoreMockRecorder) GetClosedWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
GetClosedWorkflowExecution indicates an expected call of GetClosedWorkflowExecution.
func (*MockVisibilityStoreMockRecorder) GetName ¶ added in v1.2.9
func (mr *MockVisibilityStoreMockRecorder) GetName() *gomock.Call
GetName indicates an expected call of GetName.
func (*MockVisibilityStoreMockRecorder) ListAllWorkflowExecutions ¶ added in v1.2.11
func (mr *MockVisibilityStoreMockRecorder) ListAllWorkflowExecutions(arg0, arg1 interface{}) *gomock.Call
ListAllWorkflowExecutions indicates an expected call of ListAllWorkflowExecutions.
func (*MockVisibilityStoreMockRecorder) ListClosedWorkflowExecutions ¶ added in v1.2.9
func (mr *MockVisibilityStoreMockRecorder) ListClosedWorkflowExecutions(arg0, arg1 interface{}) *gomock.Call
ListClosedWorkflowExecutions indicates an expected call of ListClosedWorkflowExecutions.
func (*MockVisibilityStoreMockRecorder) ListClosedWorkflowExecutionsByStatus ¶ added in v1.2.9
func (mr *MockVisibilityStoreMockRecorder) ListClosedWorkflowExecutionsByStatus(arg0, arg1 interface{}) *gomock.Call
ListClosedWorkflowExecutionsByStatus indicates an expected call of ListClosedWorkflowExecutionsByStatus.
func (*MockVisibilityStoreMockRecorder) ListClosedWorkflowExecutionsByType ¶ added in v1.2.9
func (mr *MockVisibilityStoreMockRecorder) ListClosedWorkflowExecutionsByType(arg0, arg1 interface{}) *gomock.Call
ListClosedWorkflowExecutionsByType indicates an expected call of ListClosedWorkflowExecutionsByType.
func (*MockVisibilityStoreMockRecorder) ListClosedWorkflowExecutionsByWorkflowID ¶ added in v1.2.9
func (mr *MockVisibilityStoreMockRecorder) ListClosedWorkflowExecutionsByWorkflowID(arg0, arg1 interface{}) *gomock.Call
ListClosedWorkflowExecutionsByWorkflowID indicates an expected call of ListClosedWorkflowExecutionsByWorkflowID.
func (*MockVisibilityStoreMockRecorder) ListOpenWorkflowExecutions ¶ added in v1.2.9
func (mr *MockVisibilityStoreMockRecorder) ListOpenWorkflowExecutions(arg0, arg1 interface{}) *gomock.Call
ListOpenWorkflowExecutions indicates an expected call of ListOpenWorkflowExecutions.
func (*MockVisibilityStoreMockRecorder) ListOpenWorkflowExecutionsByType ¶ added in v1.2.9
func (mr *MockVisibilityStoreMockRecorder) ListOpenWorkflowExecutionsByType(arg0, arg1 interface{}) *gomock.Call
ListOpenWorkflowExecutionsByType indicates an expected call of ListOpenWorkflowExecutionsByType.
func (*MockVisibilityStoreMockRecorder) ListOpenWorkflowExecutionsByWorkflowID ¶ added in v1.2.9
func (mr *MockVisibilityStoreMockRecorder) ListOpenWorkflowExecutionsByWorkflowID(arg0, arg1 interface{}) *gomock.Call
ListOpenWorkflowExecutionsByWorkflowID indicates an expected call of ListOpenWorkflowExecutionsByWorkflowID.
func (*MockVisibilityStoreMockRecorder) ListWorkflowExecutions ¶ added in v1.2.9
func (mr *MockVisibilityStoreMockRecorder) ListWorkflowExecutions(arg0, arg1 interface{}) *gomock.Call
ListWorkflowExecutions indicates an expected call of ListWorkflowExecutions.
func (*MockVisibilityStoreMockRecorder) RecordWorkflowExecutionClosed ¶ added in v1.2.9
func (mr *MockVisibilityStoreMockRecorder) RecordWorkflowExecutionClosed(arg0, arg1 interface{}) *gomock.Call
RecordWorkflowExecutionClosed indicates an expected call of RecordWorkflowExecutionClosed.
func (*MockVisibilityStoreMockRecorder) RecordWorkflowExecutionStarted ¶ added in v1.2.9
func (mr *MockVisibilityStoreMockRecorder) RecordWorkflowExecutionStarted(arg0, arg1 interface{}) *gomock.Call
RecordWorkflowExecutionStarted indicates an expected call of RecordWorkflowExecutionStarted.
func (*MockVisibilityStoreMockRecorder) RecordWorkflowExecutionUninitialized ¶ added in v1.2.9
func (mr *MockVisibilityStoreMockRecorder) RecordWorkflowExecutionUninitialized(arg0, arg1 interface{}) *gomock.Call
RecordWorkflowExecutionUninitialized indicates an expected call of RecordWorkflowExecutionUninitialized.
func (*MockVisibilityStoreMockRecorder) ScanWorkflowExecutions ¶ added in v1.2.9
func (mr *MockVisibilityStoreMockRecorder) ScanWorkflowExecutions(arg0, arg1 interface{}) *gomock.Call
ScanWorkflowExecutions indicates an expected call of ScanWorkflowExecutions.
func (*MockVisibilityStoreMockRecorder) UpsertWorkflowExecution ¶ added in v1.2.9
func (mr *MockVisibilityStoreMockRecorder) UpsertWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
UpsertWorkflowExecution indicates an expected call of UpsertWorkflowExecution.
type MutableStateStats ¶ added in v0.4.0
type MutableStateStats struct { // Total size of mutable state MutableStateSize int // Breakdown of size into more granular stats ExecutionInfoSize int ActivityInfoSize int TimerInfoSize int ChildInfoSize int SignalInfoSize int BufferedEventsSize int // Item count for various information captured within mutable state ActivityInfoCount int TimerInfoCount int ChildInfoCount int SignalInfoCount int RequestCancelInfoCount int BufferedEventsCount int }
MutableStateStats is the size stats for MutableState
type MutableStateUpdateSessionStats ¶ added in v0.4.0
type MutableStateUpdateSessionStats struct { MutableStateSize int // Total size of mutable state update // Breakdown of mutable state size update for more granular stats ExecutionInfoSize int ActivityInfoSize int TimerInfoSize int ChildInfoSize int SignalInfoSize int BufferedEventsSize int // Item counts in this session update ActivityInfoCount int TimerInfoCount int ChildInfoCount int SignalInfoCount int RequestCancelInfoCount int // Deleted item counts in this session update DeleteActivityInfoCount int DeleteTimerInfoCount int DeleteChildInfoCount int DeleteSignalInfoCount int DeleteRequestCancelInfoCount int TransferTasksCount int CrossClusterTaskCount int TimerTasksCount int ReplicationTasksCount int }
MutableStateUpdateSessionStats is size stats for mutableState updating session
type OperationType ¶ added in v1.2.6
type OperationType string
type PayloadSerializer ¶ added in v0.5.7
type PayloadSerializer interface { // serialize/deserialize history events SerializeBatchEvents(batch []*types.HistoryEvent, encodingType common.EncodingType) (*DataBlob, error) DeserializeBatchEvents(data *DataBlob) ([]*types.HistoryEvent, error) // serialize/deserialize a single history event SerializeEvent(event *types.HistoryEvent, encodingType common.EncodingType) (*DataBlob, error) DeserializeEvent(data *DataBlob) (*types.HistoryEvent, error) // serialize/deserialize visibility memo fields SerializeVisibilityMemo(memo *types.Memo, encodingType common.EncodingType) (*DataBlob, error) DeserializeVisibilityMemo(data *DataBlob) (*types.Memo, error) // serialize/deserialize reset points SerializeResetPoints(event *types.ResetPoints, encodingType common.EncodingType) (*DataBlob, error) DeserializeResetPoints(data *DataBlob) (*types.ResetPoints, error) // serialize/deserialize bad binaries SerializeBadBinaries(event *types.BadBinaries, encodingType common.EncodingType) (*DataBlob, error) DeserializeBadBinaries(data *DataBlob) (*types.BadBinaries, error) // serialize/deserialize version histories SerializeVersionHistories(histories *types.VersionHistories, encodingType common.EncodingType) (*DataBlob, error) DeserializeVersionHistories(data *DataBlob) (*types.VersionHistories, error) // serialize/deserialize pending failover markers SerializePendingFailoverMarkers(markers []*types.FailoverMarkerAttributes, encodingType common.EncodingType) (*DataBlob, error) DeserializePendingFailoverMarkers(data *DataBlob) ([]*types.FailoverMarkerAttributes, error) // serialize/deserialize processing queue statesss SerializeProcessingQueueStates(states *types.ProcessingQueueStates, encodingType common.EncodingType) (*DataBlob, error) DeserializeProcessingQueueStates(data *DataBlob) (*types.ProcessingQueueStates, error) // serialize/deserialize DynamicConfigBlob SerializeDynamicConfigBlob(blob *types.DynamicConfigBlob, encodingType common.EncodingType) (*DataBlob, error) DeserializeDynamicConfigBlob(data *DataBlob) (*types.DynamicConfigBlob, error) // serialize/deserialize IsolationGroupConfiguration SerializeIsolationGroups(event *types.IsolationGroupConfiguration, encodingType common.EncodingType) (*DataBlob, error) DeserializeIsolationGroups(data *DataBlob) (*types.IsolationGroupConfiguration, error) // serialize/deserialize async workflow configuration SerializeAsyncWorkflowsConfig(config *types.AsyncWorkflowConfiguration, encodingType common.EncodingType) (*DataBlob, error) DeserializeAsyncWorkflowsConfig(data *DataBlob) (*types.AsyncWorkflowConfiguration, error) // serialize/deserialize checksum SerializeChecksum(sum checksum.Checksum, encodingType common.EncodingType) (*DataBlob, error) DeserializeChecksum(data *DataBlob) (checksum.Checksum, error) }
PayloadSerializer is used by persistence to serialize/deserialize history event(s) and others It will only be used inside persistence, so that serialize/deserialize is transparent for application
func NewPayloadSerializer ¶ added in v0.5.7
func NewPayloadSerializer() PayloadSerializer
NewPayloadSerializer returns a PayloadSerializer
type PutReplicationTaskToDLQRequest ¶ added in v0.11.0
type PutReplicationTaskToDLQRequest struct { SourceClusterName string TaskInfo *ReplicationTaskInfo DomainName string }
PutReplicationTaskToDLQRequest is used to put a replication task to dlq
func (*PutReplicationTaskToDLQRequest) MetricTags ¶ added in v1.2.7
func (r *PutReplicationTaskToDLQRequest) MetricTags() []metrics.Tag
type Queue ¶ added in v0.9.3
type Queue interface { Closeable EnqueueMessage(ctx context.Context, messagePayload []byte) error ReadMessages(ctx context.Context, lastMessageID int64, maxCount int) ([]*InternalQueueMessage, error) DeleteMessagesBefore(ctx context.Context, messageID int64) error UpdateAckLevel(ctx context.Context, messageID int64, clusterName string) error GetAckLevels(ctx context.Context) (map[string]int64, error) EnqueueMessageToDLQ(ctx context.Context, messagePayload []byte) error ReadMessagesFromDLQ(ctx context.Context, firstMessageID int64, lastMessageID int64, pageSize int, pageToken []byte) ([]*InternalQueueMessage, []byte, error) DeleteMessageFromDLQ(ctx context.Context, messageID int64) error RangeDeleteMessagesFromDLQ(ctx context.Context, firstMessageID int64, lastMessageID int64) error UpdateDLQAckLevel(ctx context.Context, messageID int64, clusterName string) error GetDLQAckLevels(ctx context.Context) (map[string]int64, error) GetDLQSize(ctx context.Context) (int64, error) }
Queue is a store to enqueue and get messages
type QueueManager ¶ added in v0.16.0
type QueueManager interface { Closeable EnqueueMessage(ctx context.Context, messagePayload []byte) error ReadMessages(ctx context.Context, lastMessageID int64, maxCount int) (QueueMessageList, error) DeleteMessagesBefore(ctx context.Context, messageID int64) error UpdateAckLevel(ctx context.Context, messageID int64, clusterName string) error GetAckLevels(ctx context.Context) (map[string]int64, error) EnqueueMessageToDLQ(ctx context.Context, messagePayload []byte) error ReadMessagesFromDLQ(ctx context.Context, firstMessageID int64, lastMessageID int64, pageSize int, pageToken []byte) ([]*QueueMessage, []byte, error) DeleteMessageFromDLQ(ctx context.Context, messageID int64) error RangeDeleteMessagesFromDLQ(ctx context.Context, firstMessageID int64, lastMessageID int64) error UpdateDLQAckLevel(ctx context.Context, messageID int64, clusterName string) error GetDLQAckLevels(ctx context.Context) (map[string]int64, error) GetDLQSize(ctx context.Context) (int64, error) }
QueueManager is used to manage queue store
func NewQueueManager ¶ added in v0.16.0
func NewQueueManager( persistence Queue, ) QueueManager
NewQueueManager returns a new QueueManager
type QueueMessage ¶ added in v0.9.3
type QueueMessage struct { ID int64 `json:"message_id"` QueueType QueueType `json:"queue_type"` Payload []byte `json:"message_payload"` }
QueueMessage is the message that stores in the queue
type QueueMessageList ¶ added in v1.2.7
type QueueMessageList []*QueueMessage
func (QueueMessageList) Len ¶ added in v1.2.7
func (r QueueMessageList) Len() int
type QueueType ¶ added in v0.12.0
type QueueType int
QueueType is an enum that represents various queue types in persistence
type RangeCompleteCrossClusterTaskRequest ¶ added in v0.22.0
type RangeCompleteCrossClusterTaskRequest struct { TargetCluster string ExclusiveBeginTaskID int64 InclusiveEndTaskID int64 PageSize int }
RangeCompleteCrossClusterTaskRequest is used to complete a range of tasks in the cross-cluster task queue
type RangeCompleteCrossClusterTaskResponse ¶ added in v0.23.1
type RangeCompleteCrossClusterTaskResponse struct {
TasksCompleted int
}
RangeCompleteCrossClusterTaskResponse is the response of RangeCompleteCrossClusterTask
type RangeCompleteReplicationTaskRequest ¶ added in v0.11.0
RangeCompleteReplicationTaskRequest is used to complete a range of task in the replication task queue
type RangeCompleteReplicationTaskResponse ¶ added in v0.23.1
type RangeCompleteReplicationTaskResponse struct {
TasksCompleted int
}
RangeCompleteReplicationTaskResponse is the response of RangeCompleteReplicationTask
type RangeCompleteTimerTaskRequest ¶ added in v0.4.0
type RangeCompleteTimerTaskRequest struct { InclusiveBeginTimestamp time.Time ExclusiveEndTimestamp time.Time PageSize int }
RangeCompleteTimerTaskRequest is used to complete a range of tasks in the timer task queue
type RangeCompleteTimerTaskResponse ¶ added in v0.23.1
type RangeCompleteTimerTaskResponse struct {
TasksCompleted int
}
RangeCompleteTimerTaskResponse is the response of RangeCompleteTimerTask
type RangeCompleteTransferTaskRequest ¶ added in v0.4.0
type RangeCompleteTransferTaskRequest struct { ExclusiveBeginTaskID int64 InclusiveEndTaskID int64 PageSize int }
RangeCompleteTransferTaskRequest is used to complete a range of tasks in the transfer task queue
type RangeCompleteTransferTaskResponse ¶ added in v0.23.1
type RangeCompleteTransferTaskResponse struct {
TasksCompleted int
}
RangeCompleteTransferTaskResponse is the response of RangeCompleteTransferTask
type RangeDeleteReplicationTaskFromDLQRequest ¶ added in v0.12.0
type RangeDeleteReplicationTaskFromDLQRequest struct { SourceClusterName string ExclusiveBeginTaskID int64 InclusiveEndTaskID int64 PageSize int }
RangeDeleteReplicationTaskFromDLQRequest is used to delete replication tasks from DLQ
type RangeDeleteReplicationTaskFromDLQResponse ¶ added in v0.23.1
type RangeDeleteReplicationTaskFromDLQResponse struct {
TasksCompleted int
}
RangeDeleteReplicationTaskFromDLQResponse is the response of RangeDeleteReplicationTaskFromDLQ
type ReadHistoryBranchByBatchResponse ¶ added in v0.5.0
type ReadHistoryBranchByBatchResponse struct { // History events by batch History []*types.History // Token to read next page if there are more events beyond page size. // Use this to set NextPageToken on ReadHistoryBranchRequest to read the next page. // Empty means we have reached the last page, not need to continue NextPageToken []byte // Size of history read from store Size int // the first_event_id of last loaded batch LastFirstEventID int64 }
ReadHistoryBranchByBatchResponse is the response to ReadHistoryBranchRequest
type ReadHistoryBranchRequest ¶ added in v0.5.0
type ReadHistoryBranchRequest struct { // The branch to be read BranchToken []byte // Get the history nodes from MinEventID. Inclusive. MinEventID int64 // Get the history nodes upto MaxEventID. Exclusive. MaxEventID int64 // Maximum number of batches of events per page. Not that number of events in a batch >=1, it is not number of events per page. // However for a single page, it is also possible that the returned events is less than PageSize (event zero events) due to stale events. PageSize int // Token to continue reading next page of history append transactions. Pass in empty slice for first page NextPageToken []byte // The shard to get history branch data ShardID *int DomainName string }
ReadHistoryBranchRequest is used to read a history branch
func (ReadHistoryBranchRequest) MetricTags ¶ added in v1.2.7
func (r ReadHistoryBranchRequest) MetricTags() []metrics.Tag
type ReadHistoryBranchResponse ¶ added in v0.5.0
type ReadHistoryBranchResponse struct { // History events HistoryEvents []*types.HistoryEvent // Token to read next page if there are more events beyond page size. // Use this to set NextPageToken on ReadHistoryBranchRequest to read the next page. // Empty means we have reached the last page, not need to continue NextPageToken []byte // Size of history read from store Size int // the first_event_id of last loaded batch LastFirstEventID int64 }
ReadHistoryBranchResponse is the response to ReadHistoryBranchRequest
func (*ReadHistoryBranchResponse) Len ¶ added in v1.2.7
func (r *ReadHistoryBranchResponse) Len() int
type ReadRawHistoryBranchResponse ¶ added in v0.9.0
type ReadRawHistoryBranchResponse struct { // HistoryEventBlobs history event blobs HistoryEventBlobs []*DataBlob // Token to read next page if there are more events beyond page size. // Use this to set NextPageToken on ReadHistoryBranchRequest to read the next page. // Empty means we have reached the last page, not need to continue NextPageToken []byte // Size of history read from store Size int }
ReadRawHistoryBranchResponse is the response to ReadHistoryBranchRequest
type RecordChildExecutionCompletedTask ¶ added in v0.24.0
type RecordChildExecutionCompletedTask struct { TaskData TargetDomainID string TargetWorkflowID string TargetRunID string }
RecordChildExecutionCompletedTask identifies a task for recording the competion of a child workflow
func (*RecordChildExecutionCompletedTask) GetType ¶ added in v0.24.0
func (u *RecordChildExecutionCompletedTask) GetType() int
GetType returns the type of the record child execution completed task
type RecordWorkflowClosedTask ¶ added in v0.24.0
type RecordWorkflowClosedTask struct {
TaskData
}
RecordWorkflowClosedTask identifies a transfer task for writing visibility close execution record
func (*RecordWorkflowClosedTask) GetType ¶ added in v0.24.0
func (u *RecordWorkflowClosedTask) GetType() int
GetType returns the type of the record workflow closed task
type RecordWorkflowExecutionClosedRequest ¶
type RecordWorkflowExecutionClosedRequest struct { DomainUUID string Domain string // not persisted, used as config filter key Execution types.WorkflowExecution WorkflowTypeName string StartTimestamp int64 ExecutionTimestamp int64 CloseTimestamp int64 Status types.WorkflowExecutionCloseStatus HistoryLength int64 RetentionSeconds int64 TaskID int64 // not persisted, used as condition update version for ES Memo *types.Memo TaskList string IsCron bool NumClusters int16 UpdateTimestamp int64 SearchAttributes map[string][]byte ShardID int16 }
RecordWorkflowExecutionClosedRequest is used to add a record of a newly closed execution
type RecordWorkflowExecutionStartedRequest ¶
type RecordWorkflowExecutionStartedRequest struct { DomainUUID string Domain string // not persisted, used as config filter key Execution types.WorkflowExecution WorkflowTypeName string StartTimestamp int64 ExecutionTimestamp int64 WorkflowTimeout int64 // not persisted, used for cassandra ttl TaskID int64 // not persisted, used as condition update version for ES Memo *types.Memo TaskList string IsCron bool NumClusters int16 UpdateTimestamp int64 // unit is unix nano, consistent with start/execution timestamp, same in other requests SearchAttributes map[string][]byte ShardID int16 }
RecordWorkflowExecutionStartedRequest is used to add a record of a newly started execution
type RecordWorkflowExecutionUninitializedRequest ¶ added in v0.25.0
type RecordWorkflowExecutionUninitializedRequest struct { DomainUUID string Domain string Execution types.WorkflowExecution WorkflowTypeName string UpdateTimestamp int64 ShardID int64 }
RecordWorkflowExecutionUninitializedRequest is used to add a record of a newly uninitialized execution
type RecordWorkflowStartedTask ¶ added in v0.5.7
type RecordWorkflowStartedTask struct {
TaskData
}
RecordWorkflowStartedTask identifites a transfer task for writing visibility open execution record
func (*RecordWorkflowStartedTask) GetType ¶ added in v0.5.7
func (a *RecordWorkflowStartedTask) GetType() int
GetType returns the type of the record workflow started task
type ReplicationInfo ¶ added in v0.3.11
ReplicationInfo represents the information stored for last replication event details per cluster
type ReplicationState ¶ added in v0.3.11
type ReplicationState struct { CurrentVersion int64 StartVersion int64 LastWriteVersion int64 LastWriteEventID int64 LastReplicationInfo map[string]*ReplicationInfo }
ReplicationState represents mutable state information for global domains. This information is used by replication protocol when applying events from remote clusters TODO: remove this struct after all 2DC workflows complete
type ReplicationTaskInfo ¶ added in v0.3.11
type ReplicationTaskInfo struct { DomainID string WorkflowID string RunID string TaskID int64 TaskType int FirstEventID int64 NextEventID int64 Version int64 ScheduledID int64 BranchToken []byte NewRunBranchToken []byte CreationTime int64 }
ReplicationTaskInfo describes the replication task created for replication of history events
func (*ReplicationTaskInfo) GetDomainID ¶ added in v0.9.0
func (t *ReplicationTaskInfo) GetDomainID() string
GetDomainID returns the domain ID for replication task
func (*ReplicationTaskInfo) GetRunID ¶ added in v0.9.0
func (t *ReplicationTaskInfo) GetRunID() string
GetRunID returns the run ID for replication task
func (*ReplicationTaskInfo) GetTaskID ¶ added in v0.3.11
func (t *ReplicationTaskInfo) GetTaskID() int64
GetTaskID returns the task ID for replication task
func (*ReplicationTaskInfo) GetTaskType ¶ added in v0.3.11
func (t *ReplicationTaskInfo) GetTaskType() int
GetTaskType returns the task type for replication task
func (*ReplicationTaskInfo) GetVersion ¶ added in v0.3.12
func (t *ReplicationTaskInfo) GetVersion() int64
GetVersion returns the task version for replication task
func (*ReplicationTaskInfo) GetVisibilityTimestamp ¶ added in v0.3.14
func (t *ReplicationTaskInfo) GetVisibilityTimestamp() time.Time
GetVisibilityTimestamp returns the task type for replication task
func (*ReplicationTaskInfo) GetWorkflowID ¶ added in v0.9.0
func (t *ReplicationTaskInfo) GetWorkflowID() string
GetWorkflowID returns the workflow ID for replication task
type RequestCancelInfo ¶
type RequestCancelInfo struct { Version int64 InitiatedEventBatchID int64 InitiatedID int64 CancelRequestID string }
RequestCancelInfo has details for pending external workflow cancellations
type ResetWorkflowTask ¶ added in v0.5.8
type ResetWorkflowTask struct {
TaskData
}
ResetWorkflowTask identifites a transfer task to reset workflow
func (*ResetWorkflowTask) GetType ¶ added in v0.5.8
func (a *ResetWorkflowTask) GetType() int
GetType returns the type of the ResetWorkflowTask
type ResponseComparatorContextKey ¶ added in v1.2.7
type ResponseComparatorContextKey string
ResponseComparatorContextKey is for Pinot/ES response comparator. This struct will be passed into ctx as a key.
type Retryer ¶ added in v0.15.0
type Retryer interface { ListConcreteExecutions(context.Context, *ListConcreteExecutionsRequest) (*ListConcreteExecutionsResponse, error) ListCurrentExecutions(context.Context, *ListCurrentExecutionsRequest) (*ListCurrentExecutionsResponse, error) GetWorkflowExecution(context.Context, *GetWorkflowExecutionRequest) (*GetWorkflowExecutionResponse, error) GetCurrentExecution(context.Context, *GetCurrentExecutionRequest) (*GetCurrentExecutionResponse, error) IsWorkflowExecutionExists(context.Context, *IsWorkflowExecutionExistsRequest) (*IsWorkflowExecutionExistsResponse, error) ReadHistoryBranch(context.Context, *ReadHistoryBranchRequest) (*ReadHistoryBranchResponse, error) DeleteWorkflowExecution(context.Context, *DeleteWorkflowExecutionRequest) error DeleteCurrentWorkflowExecution(context.Context, *DeleteCurrentWorkflowExecutionRequest) error GetShardID() int GetTimerIndexTasks(context.Context, *GetTimerIndexTasksRequest) (*GetTimerIndexTasksResponse, error) CompleteTimerTask(ctx context.Context, request *CompleteTimerTaskRequest) error }
Retryer is used to retry requests to persistence with provided retry policy
func NewPersistenceRetryer ¶ added in v0.15.0
func NewPersistenceRetryer( execManager ExecutionManager, historyManager HistoryManager, policy backoff.RetryPolicy, ) Retryer
NewPersistenceRetryer constructs a new Retryer
type ShardAlreadyExistError ¶
type ShardAlreadyExistError struct {
Msg string
}
ShardAlreadyExistError is returned when conditionally creating a shard fails
func (*ShardAlreadyExistError) Error ¶
func (e *ShardAlreadyExistError) Error() string
type ShardInfo ¶
type ShardInfo struct { ShardID int `json:"shard_id"` Owner string `json:"owner"` RangeID int64 `json:"range_id"` StolenSinceRenew int `json:"stolen_since_renew"` UpdatedAt time.Time `json:"updated_at"` ReplicationAckLevel int64 `json:"replication_ack_level"` ReplicationDLQAckLevel map[string]int64 `json:"replication_dlq_ack_level"` TransferAckLevel int64 `json:"transfer_ack_level"` TimerAckLevel time.Time `json:"timer_ack_level"` ClusterTransferAckLevel map[string]int64 `json:"cluster_transfer_ack_level"` ClusterTimerAckLevel map[string]time.Time `json:"cluster_timer_ack_level"` TransferProcessingQueueStates *types.ProcessingQueueStates `json:"transfer_processing_queue_states"` CrossClusterProcessingQueueStates *types.ProcessingQueueStates `json:"cross_cluster_queue_states"` TimerProcessingQueueStates *types.ProcessingQueueStates `json:"timer_processing_queue_states"` ClusterReplicationLevel map[string]int64 `json:"cluster_replication_level"` DomainNotificationVersion int64 `json:"domain_notification_version"` PendingFailoverMarkers []*types.FailoverMarkerAttributes `json:"pending_failover_markers"` }
ShardInfo describes a shard
type ShardManager ¶
type ShardManager interface { Closeable GetName() string CreateShard(ctx context.Context, request *CreateShardRequest) error GetShard(ctx context.Context, request *GetShardRequest) (*GetShardResponse, error) UpdateShard(ctx context.Context, request *UpdateShardRequest) error }
ShardManager is used to manage all shards
func NewShardManager ¶ added in v0.16.0
func NewShardManager( persistence ShardStore, options ...ShardManagerOption, ) ShardManager
NewShardManager returns a new ShardManager
type ShardManagerOption ¶ added in v1.2.10
type ShardManagerOption func(manager *shardManager)
func WithSerializer ¶ added in v1.2.10
func WithSerializer(serializer PayloadSerializer) ShardManagerOption
type ShardOwnershipLostError ¶
ShardOwnershipLostError is returned when conditional update fails due to RangeID for the shard
func (*ShardOwnershipLostError) Error ¶
func (e *ShardOwnershipLostError) Error() string
type ShardStore ¶ added in v0.4.0
type ShardStore interface { Closeable GetName() string CreateShard(ctx context.Context, request *InternalCreateShardRequest) error GetShard(ctx context.Context, request *InternalGetShardRequest) (*InternalGetShardResponse, error) UpdateShard(ctx context.Context, request *InternalUpdateShardRequest) error }
ShardStore is the lower level of ShardManager
type SignalExecutionTask ¶ added in v0.3.6
type SignalExecutionTask struct { TaskData TargetDomainID string TargetWorkflowID string TargetRunID string TargetChildWorkflowOnly bool InitiatedID int64 }
SignalExecutionTask identifies a transfer task for signal execution
func (*SignalExecutionTask) GetType ¶ added in v0.3.6
func (u *SignalExecutionTask) GetType() int
GetType returns the type of the signal transfer task
type SignalInfo ¶ added in v0.3.6
type SignalInfo struct { Version int64 InitiatedEventBatchID int64 InitiatedID int64 SignalRequestID string SignalName string Input []byte Control []byte }
SignalInfo has details for pending external workflow signal
type StartChildExecutionTask ¶
type StartChildExecutionTask struct { TaskData TargetDomainID string TargetWorkflowID string InitiatedID int64 }
StartChildExecutionTask identifies a transfer task for starting child execution
func (*StartChildExecutionTask) GetType ¶
func (u *StartChildExecutionTask) GetType() int
GetType returns the type of the start child transfer task
type SyncActivityTask ¶ added in v0.4.0
SyncActivityTask is the replication task created for shipping activity info to other clusters
func (*SyncActivityTask) GetType ¶ added in v0.4.0
func (a *SyncActivityTask) GetType() int
GetType returns the type of the history replication task
type Task ¶
type Task interface { GetType() int GetVersion() int64 SetVersion(version int64) GetTaskID() int64 SetTaskID(id int64) GetVisibilityTimestamp() time.Time SetVisibilityTimestamp(timestamp time.Time) }
Task is the generic interface for workflow tasks
type TaskData ¶ added in v1.2.9
TaskData is common attributes for all tasks.
func (*TaskData) GetVersion ¶ added in v1.2.9
GetVersion returns the version of the task
func (*TaskData) GetVisibilityTimestamp ¶ added in v1.2.9
GetVisibilityTimestamp get the visibility timestamp
func (*TaskData) SetVersion ¶ added in v1.2.9
SetVersion sets the version of the task
func (*TaskData) SetVisibilityTimestamp ¶ added in v1.2.9
SetVisibilityTimestamp set the visibility timestamp
type TaskInfo ¶
type TaskInfo struct { DomainID string WorkflowID string RunID string TaskID int64 ScheduleID int64 ScheduleToStartTimeout int32 Expiry time.Time CreatedTime time.Time PartitionConfig map[string]string }
TaskInfo describes either activity or decision task
type TaskListInfo ¶
type TaskListInfo struct { DomainID string Name string TaskType int RangeID int64 AckLevel int64 Kind int Expiry time.Time LastUpdated time.Time }
TaskListInfo describes a state of a task list implementation.
type TaskManager ¶
type TaskManager interface { Closeable GetName() string LeaseTaskList(ctx context.Context, request *LeaseTaskListRequest) (*LeaseTaskListResponse, error) UpdateTaskList(ctx context.Context, request *UpdateTaskListRequest) (*UpdateTaskListResponse, error) ListTaskList(ctx context.Context, request *ListTaskListRequest) (*ListTaskListResponse, error) DeleteTaskList(ctx context.Context, request *DeleteTaskListRequest) error GetTaskListSize(ctx context.Context, request *GetTaskListSizeRequest) (*GetTaskListSizeResponse, error) CreateTasks(ctx context.Context, request *CreateTasksRequest) (*CreateTasksResponse, error) GetTasks(ctx context.Context, request *GetTasksRequest) (*GetTasksResponse, error) CompleteTask(ctx context.Context, request *CompleteTaskRequest) error CompleteTasksLessThan(ctx context.Context, request *CompleteTasksLessThanRequest) (*CompleteTasksLessThanResponse, error) GetOrphanTasks(ctx context.Context, request *GetOrphanTasksRequest) (*GetOrphanTasksResponse, error) }
TaskManager is used to manage tasks
func NewTaskManager ¶ added in v0.16.0
func NewTaskManager( persistence TaskStore, ) TaskManager
NewTaskManager returns a new TaskManager
type TaskStore ¶ added in v0.4.0
type TaskStore interface { Closeable GetName() string LeaseTaskList(ctx context.Context, request *LeaseTaskListRequest) (*LeaseTaskListResponse, error) UpdateTaskList(ctx context.Context, request *UpdateTaskListRequest) (*UpdateTaskListResponse, error) ListTaskList(ctx context.Context, request *ListTaskListRequest) (*ListTaskListResponse, error) DeleteTaskList(ctx context.Context, request *DeleteTaskListRequest) error GetTaskListSize(ctx context.Context, request *GetTaskListSizeRequest) (*GetTaskListSizeResponse, error) CreateTasks(ctx context.Context, request *InternalCreateTasksRequest) (*CreateTasksResponse, error) GetTasks(ctx context.Context, request *GetTasksRequest) (*InternalGetTasksResponse, error) CompleteTask(ctx context.Context, request *CompleteTaskRequest) error // CompleteTasksLessThan completes tasks less than or equal to the given task id // This API takes a limit parameter which specifies the count of maxRows that // can be deleted. This parameter may be ignored by the underlying storage, but // its mandatory to specify it. On success this method returns the number of rows // actually deleted. If the underlying storage doesn't support "limit", all rows // less than or equal to taskID will be deleted. // On success, this method returns: // - number of rows actually deleted, if limit is honored // - UnknownNumRowsDeleted, when all rows below value are deleted CompleteTasksLessThan(ctx context.Context, request *CompleteTasksLessThanRequest) (*CompleteTasksLessThanResponse, error) // GetOrphanTasks returns tasks that exist as records in the database but are part of task lists which // _do not_ exist in the database. They are therefore unreachable and no longer represent valid items // that can be legitimately acted upon. GetOrphanTasks(ctx context.Context, request *GetOrphanTasksRequest) (*GetOrphanTasksResponse, error) }
TaskStore is a lower level of TaskManager
type TimeoutError ¶
type TimeoutError struct {
Msg string
}
TimeoutError is returned when a write operation fails due to a timeout
func (*TimeoutError) Error ¶
func (e *TimeoutError) Error() string
type TimerInfo ¶
type TimerInfo struct { Version int64 TimerID string StartedID int64 ExpiryTime time.Time TaskStatus int64 }
TimerInfo details - metadata about user timer info.
type TimerTaskInfo ¶
type TimerTaskInfo struct { DomainID string WorkflowID string RunID string VisibilityTimestamp time.Time TaskID int64 TaskType int TimeoutType int EventID int64 ScheduleAttempt int64 Version int64 }
TimerTaskInfo describes a timer task.
func (*TimerTaskInfo) GetDomainID ¶ added in v0.9.0
func (t *TimerTaskInfo) GetDomainID() string
GetDomainID returns the domain ID for timer task
func (*TimerTaskInfo) GetRunID ¶ added in v0.9.0
func (t *TimerTaskInfo) GetRunID() string
GetRunID returns the run ID for timer task
func (*TimerTaskInfo) GetTaskID ¶ added in v0.3.12
func (t *TimerTaskInfo) GetTaskID() int64
GetTaskID returns the task ID for timer task
func (*TimerTaskInfo) GetTaskType ¶ added in v0.3.12
func (t *TimerTaskInfo) GetTaskType() int
GetTaskType returns the task type for timer task
func (*TimerTaskInfo) GetVersion ¶ added in v0.3.12
func (t *TimerTaskInfo) GetVersion() int64
GetVersion returns the task version for timer task
func (*TimerTaskInfo) GetVisibilityTimestamp ¶ added in v0.3.14
func (t *TimerTaskInfo) GetVisibilityTimestamp() time.Time
GetVisibilityTimestamp returns the task type for timer task
func (*TimerTaskInfo) GetWorkflowID ¶ added in v0.9.0
func (t *TimerTaskInfo) GetWorkflowID() string
GetWorkflowID returns the workflow ID for timer task
func (*TimerTaskInfo) String ¶ added in v0.3.14
func (t *TimerTaskInfo) String() string
String returns a string representation for timer task
type TransactionSizeLimitError ¶ added in v0.5.9
type TransactionSizeLimitError struct {
Msg string
}
TransactionSizeLimitError is returned when the transaction size is too large
func (*TransactionSizeLimitError) Error ¶ added in v0.5.9
func (e *TransactionSizeLimitError) Error() string
type TransferTaskInfo ¶
type TransferTaskInfo struct { DomainID string WorkflowID string RunID string VisibilityTimestamp time.Time TaskID int64 TargetDomainID string TargetDomainIDs map[string]struct{} // used for ApplyParentPolicy request TargetWorkflowID string TargetRunID string TargetChildWorkflowOnly bool TaskList string TaskType int ScheduleID int64 Version int64 RecordVisibility bool }
TransferTaskInfo describes a transfer task
func (*TransferTaskInfo) GetDomainID ¶ added in v0.9.0
func (t *TransferTaskInfo) GetDomainID() string
GetDomainID returns the domain ID for transfer task
func (*TransferTaskInfo) GetRunID ¶ added in v0.9.0
func (t *TransferTaskInfo) GetRunID() string
GetRunID returns the run ID for transfer task
func (*TransferTaskInfo) GetTargetDomainIDs ¶ added in v0.24.0
func (t *TransferTaskInfo) GetTargetDomainIDs() map[string]struct{}
GetTargetDomainIDs returns the targetDomainIDs for applyParentPolicy
func (*TransferTaskInfo) GetTaskID ¶ added in v0.3.11
func (t *TransferTaskInfo) GetTaskID() int64
GetTaskID returns the task ID for transfer task
func (*TransferTaskInfo) GetTaskType ¶ added in v0.3.11
func (t *TransferTaskInfo) GetTaskType() int
GetTaskType returns the task type for transfer task
func (*TransferTaskInfo) GetVersion ¶ added in v0.3.12
func (t *TransferTaskInfo) GetVersion() int64
GetVersion returns the task version for transfer task
func (*TransferTaskInfo) GetVisibilityTimestamp ¶ added in v0.3.14
func (t *TransferTaskInfo) GetVisibilityTimestamp() time.Time
GetVisibilityTimestamp returns the task type for transfer task
func (*TransferTaskInfo) GetWorkflowID ¶ added in v0.9.0
func (t *TransferTaskInfo) GetWorkflowID() string
GetWorkflowID returns the workflow ID for transfer task
func (*TransferTaskInfo) String ¶ added in v0.3.14
func (t *TransferTaskInfo) String() string
String returns a string representation for transfer task
type UnknownEncodingTypeError ¶
type UnknownEncodingTypeError struct {
// contains filtered or unexported fields
}
UnknownEncodingTypeError is an error type for unknown or unsupported encoding type
func (*UnknownEncodingTypeError) Error ¶
func (e *UnknownEncodingTypeError) Error() string
type UpdateDomainRequest ¶
type UpdateDomainRequest struct { Info *DomainInfo Config *DomainConfig ReplicationConfig *DomainReplicationConfig ConfigVersion int64 FailoverVersion int64 FailoverNotificationVersion int64 PreviousFailoverVersion int64 FailoverEndTime *int64 LastUpdatedTime int64 NotificationVersion int64 }
UpdateDomainRequest is used to update domain
type UpdateDynamicConfigRequest ¶ added in v0.23.1
type UpdateDynamicConfigRequest struct {
Snapshot *DynamicConfigSnapshot
}
UpdateDynamicConfigRequest is a request to update dynamic config with snapshot
type UpdateShardRequest ¶
UpdateShardRequest is used to update shard information
type UpdateTaskListRequest ¶
type UpdateTaskListRequest struct { TaskListInfo *TaskListInfo DomainName string }
UpdateTaskListRequest is used to update task list implementation information
func (UpdateTaskListRequest) MetricTags ¶ added in v1.2.7
func (r UpdateTaskListRequest) MetricTags() []metrics.Tag
type UpdateTaskListResponse ¶
type UpdateTaskListResponse struct { }
UpdateTaskListResponse is the response to UpdateTaskList
type UpdateWorkflowExecutionRequest ¶
type UpdateWorkflowExecutionRequest struct { RangeID int64 Mode UpdateWorkflowMode UpdateWorkflowMutation WorkflowMutation NewWorkflowSnapshot *WorkflowSnapshot WorkflowRequestMode CreateWorkflowRequestMode Encoding common.EncodingType // optional binary encoding type DomainName string }
UpdateWorkflowExecutionRequest is used to update a workflow execution
func (*UpdateWorkflowExecutionRequest) GetDomainName ¶ added in v1.2.7
func (r *UpdateWorkflowExecutionRequest) GetDomainName() string
func (*UpdateWorkflowExecutionRequest) GetExtraLogTags ¶ added in v1.2.7
func (r *UpdateWorkflowExecutionRequest) GetExtraLogTags() []tag.Tag
type UpdateWorkflowExecutionResponse ¶ added in v0.4.0
type UpdateWorkflowExecutionResponse struct {
MutableStateUpdateSessionStats *MutableStateUpdateSessionStats
}
UpdateWorkflowExecutionResponse is response for UpdateWorkflowExecutionRequest
type UpdateWorkflowMode ¶ added in v0.9.3
type UpdateWorkflowMode int
UpdateWorkflowMode update mode
const ( // Update workflow, including current record // NOTE: update on current record is a condition update UpdateWorkflowModeUpdateCurrent UpdateWorkflowMode = iota // Update workflow, without current record // NOTE: current record CANNOT point to the workflow to be updated UpdateWorkflowModeBypassCurrent // 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 UpdateWorkflowModeIgnoreCurrent )
Update Workflow Execution Mode
type UpsertWorkflowExecutionRequest ¶ added in v0.6.0
type UpsertWorkflowExecutionRequest struct { DomainUUID string Domain string // not persisted, used as config filter key Execution types.WorkflowExecution WorkflowTypeName string StartTimestamp int64 ExecutionTimestamp int64 WorkflowTimeout int64 // not persisted, used for cassandra ttl TaskID int64 // not persisted, used as condition update version for ES Memo *types.Memo TaskList string IsCron bool NumClusters int16 UpdateTimestamp int64 SearchAttributes map[string][]byte ShardID int64 }
UpsertWorkflowExecutionRequest is used to upsert workflow execution
type UpsertWorkflowSearchAttributesTask ¶ added in v0.6.0
type UpsertWorkflowSearchAttributesTask struct {
TaskData
}
UpsertWorkflowSearchAttributesTask identifies a transfer task for upsert search attributes
func (*UpsertWorkflowSearchAttributesTask) GetType ¶ added in v0.6.0
func (u *UpsertWorkflowSearchAttributesTask) GetType() int
GetType returns the type of the upsert search attributes transfer task
type UserTimerTask ¶
UserTimerTask identifies a timeout task.
func (*UserTimerTask) GetType ¶
func (u *UserTimerTask) GetType() int
GetType returns the type of the timer task
type VersionHistories ¶ added in v0.5.8
type VersionHistories struct { CurrentVersionHistoryIndex int Histories []*VersionHistory }
VersionHistories contains a set of VersionHistory
func NewVersionHistories ¶ added in v0.5.8
func NewVersionHistories( versionHistory *VersionHistory, ) *VersionHistories
NewVersionHistories create a new version histories
func NewVersionHistoriesFromInternalType ¶ added in v0.18.0
func NewVersionHistoriesFromInternalType( input *types.VersionHistories, ) *VersionHistories
NewVersionHistoriesFromInternalType create a new version histories from internal type object
func (*VersionHistories) AddVersionHistory ¶ added in v0.9.3
func (h *VersionHistories) AddVersionHistory( v *VersionHistory, ) (bool, int, error)
AddVersionHistory add a version history and return the whether current branch is changed
func (*VersionHistories) Duplicate ¶ added in v0.9.3
func (h *VersionHistories) Duplicate() *VersionHistories
Duplicate duplicate VersionHistories
func (*VersionHistories) FindFirstVersionHistoryByItem ¶ added in v0.25.0
func (h *VersionHistories) FindFirstVersionHistoryByItem( item *VersionHistoryItem, ) (index int, history *VersionHistory, err error)
FindFirstVersionHistoryByItem find the first version history index and history which contains the given version history item
func (*VersionHistories) FindLCAVersionHistoryIndexAndItem ¶ added in v0.9.3
func (h *VersionHistories) FindLCAVersionHistoryIndexAndItem( incomingHistory *VersionHistory, ) (int, *VersionHistoryItem, error)
FindLCAVersionHistoryIndexAndItem finds the lowest common ancestor version history index along with corresponding item
func (*VersionHistories) GetCurrentVersionHistory ¶ added in v0.9.3
func (h *VersionHistories) GetCurrentVersionHistory() (*VersionHistory, error)
GetCurrentVersionHistory get the current version history
func (*VersionHistories) GetCurrentVersionHistoryIndex ¶ added in v0.9.3
func (h *VersionHistories) GetCurrentVersionHistoryIndex() int
GetCurrentVersionHistoryIndex get the current branch index
func (*VersionHistories) GetVersionHistory ¶ added in v0.9.3
func (h *VersionHistories) GetVersionHistory( branchIndex int, ) (*VersionHistory, error)
GetVersionHistory get the version history according to index provided
func (*VersionHistories) IsRebuilt ¶ added in v0.9.3
func (h *VersionHistories) IsRebuilt() (bool, error)
IsRebuilt returns true if the current branch index's last write version is not the largest among all branches' last write version
func (*VersionHistories) SetCurrentVersionHistoryIndex ¶ added in v0.9.3
func (h *VersionHistories) SetCurrentVersionHistoryIndex( index int, ) error
SetCurrentVersionHistoryIndex set the current branch index
func (*VersionHistories) ToInternalType ¶ added in v0.18.0
func (h *VersionHistories) ToInternalType() *types.VersionHistories
ToInternalType return internal format of version histories
type VersionHistory ¶ added in v0.5.8
type VersionHistory struct { BranchToken []byte Items []*VersionHistoryItem }
VersionHistory provides operations on version history
func NewVersionHistory ¶ added in v0.5.8
func NewVersionHistory( inputToken []byte, inputItems []*VersionHistoryItem, ) *VersionHistory
NewVersionHistory create a new version history
func NewVersionHistoryFromInternalType ¶ added in v0.18.0
func NewVersionHistoryFromInternalType( input *types.VersionHistory, ) *VersionHistory
NewVersionHistoryFromInternalType create a new version history from internal type object
func (*VersionHistory) AddOrUpdateItem ¶ added in v0.9.3
func (v *VersionHistory) AddOrUpdateItem( item *VersionHistoryItem, ) error
AddOrUpdateItem updates the versionHistory slice
func (*VersionHistory) ContainsItem ¶ added in v0.9.3
func (v *VersionHistory) ContainsItem( item *VersionHistoryItem, ) bool
ContainsItem check whether given version history item is included
func (*VersionHistory) Duplicate ¶ added in v0.9.3
func (v *VersionHistory) Duplicate() *VersionHistory
Duplicate duplicate VersionHistory
func (*VersionHistory) DuplicateUntilLCAItem ¶ added in v0.9.3
func (v *VersionHistory) DuplicateUntilLCAItem( lcaItem *VersionHistoryItem, ) (*VersionHistory, error)
DuplicateUntilLCAItem duplicate the version history up until LCA item
func (*VersionHistory) Equals ¶ added in v0.9.3
func (v *VersionHistory) Equals( input *VersionHistory, ) bool
Equals test if this version history and input version history are the same
func (*VersionHistory) FindLCAItem ¶ added in v0.9.3
func (v *VersionHistory) FindLCAItem( remote *VersionHistory, ) (*VersionHistoryItem, error)
FindLCAItem returns the lowest common ancestor version history item
func (*VersionHistory) GetBranchToken ¶ added in v0.9.3
func (v *VersionHistory) GetBranchToken() []byte
GetBranchToken return the branch token
func (*VersionHistory) GetEventVersion ¶ added in v0.10.0
func (v *VersionHistory) GetEventVersion( eventID int64, ) (int64, error)
GetEventVersion return the corresponding event version of an event ID
func (*VersionHistory) GetFirstItem ¶ added in v0.9.3
func (v *VersionHistory) GetFirstItem() (*VersionHistoryItem, error)
GetFirstItem return the first version history item
func (*VersionHistory) GetLastItem ¶ added in v0.9.3
func (v *VersionHistory) GetLastItem() (*VersionHistoryItem, error)
GetLastItem return the last version history item
func (*VersionHistory) IsEmpty ¶ added in v0.9.3
func (v *VersionHistory) IsEmpty() bool
IsEmpty indicate whether version history is empty
func (*VersionHistory) IsLCAAppendable ¶ added in v0.9.3
func (v *VersionHistory) IsLCAAppendable( item *VersionHistoryItem, ) bool
IsLCAAppendable checks if a LCA version history item is appendable
func (*VersionHistory) SetBranchToken ¶ added in v0.9.3
func (v *VersionHistory) SetBranchToken( inputToken []byte, ) error
SetBranchToken the overwrite the branch token
func (*VersionHistory) ToInternalType ¶ added in v0.18.0
func (v *VersionHistory) ToInternalType() *types.VersionHistory
ToInternalType return internal format of version history
type VersionHistoryItem ¶ added in v0.5.8
VersionHistoryItem contains the event id and the associated version
func NewVersionHistoryItem ¶ added in v0.9.3
func NewVersionHistoryItem( inputEventID int64, inputVersion int64, ) *VersionHistoryItem
NewVersionHistoryItem create a new version history item
func NewVersionHistoryItemFromInternalType ¶ added in v0.18.0
func NewVersionHistoryItemFromInternalType( input *types.VersionHistoryItem, ) *VersionHistoryItem
NewVersionHistoryItemFromInternalType create a new version history item from internal type object
func (*VersionHistoryItem) Duplicate ¶ added in v0.9.3
func (item *VersionHistoryItem) Duplicate() *VersionHistoryItem
Duplicate duplicate VersionHistoryItem
func (*VersionHistoryItem) Equals ¶ added in v0.9.3
func (item *VersionHistoryItem) Equals(input *VersionHistoryItem) bool
Equals test if this version history itme and input version history item are the same
func (*VersionHistoryItem) ToInternalType ¶ added in v0.18.0
func (item *VersionHistoryItem) ToInternalType() *types.VersionHistoryItem
ToInternalType return internal format of version history item
type VisibilityAdminDeletionKey ¶ added in v0.24.0
type VisibilityAdminDeletionKey string
type VisibilityDeleteWorkflowExecutionRequest ¶ added in v0.5.7
type VisibilityDeleteWorkflowExecutionRequest struct { DomainID string Domain string RunID string WorkflowID string TaskID int64 }
VisibilityDeleteWorkflowExecutionRequest contains the request params for DeleteWorkflowExecution call
type VisibilityManager ¶
type VisibilityManager interface { Closeable GetName() string RecordWorkflowExecutionStarted(ctx context.Context, request *RecordWorkflowExecutionStartedRequest) error RecordWorkflowExecutionClosed(ctx context.Context, request *RecordWorkflowExecutionClosedRequest) error RecordWorkflowExecutionUninitialized(ctx context.Context, request *RecordWorkflowExecutionUninitializedRequest) error UpsertWorkflowExecution(ctx context.Context, request *UpsertWorkflowExecutionRequest) error ListOpenWorkflowExecutions(ctx context.Context, request *ListWorkflowExecutionsRequest) (*ListWorkflowExecutionsResponse, error) ListClosedWorkflowExecutions(ctx context.Context, request *ListWorkflowExecutionsRequest) (*ListWorkflowExecutionsResponse, error) ListOpenWorkflowExecutionsByType(ctx context.Context, request *ListWorkflowExecutionsByTypeRequest) (*ListWorkflowExecutionsResponse, error) ListClosedWorkflowExecutionsByType(ctx context.Context, request *ListWorkflowExecutionsByTypeRequest) (*ListWorkflowExecutionsResponse, error) ListOpenWorkflowExecutionsByWorkflowID(ctx context.Context, request *ListWorkflowExecutionsByWorkflowIDRequest) (*ListWorkflowExecutionsResponse, error) ListClosedWorkflowExecutionsByWorkflowID(ctx context.Context, request *ListWorkflowExecutionsByWorkflowIDRequest) (*ListWorkflowExecutionsResponse, error) ListClosedWorkflowExecutionsByStatus(ctx context.Context, request *ListClosedWorkflowExecutionsByStatusRequest) (*ListWorkflowExecutionsResponse, error) DeleteWorkflowExecution(ctx context.Context, request *VisibilityDeleteWorkflowExecutionRequest) error ListWorkflowExecutions(ctx context.Context, request *ListWorkflowExecutionsByQueryRequest) (*ListWorkflowExecutionsResponse, error) ListAllWorkflowExecutions(ctx context.Context, request *ListAllWorkflowExecutionsRequest) (*ListWorkflowExecutionsResponse, error) ScanWorkflowExecutions(ctx context.Context, request *ListWorkflowExecutionsByQueryRequest) (*ListWorkflowExecutionsResponse, error) CountWorkflowExecutions(ctx context.Context, request *CountWorkflowExecutionsRequest) (*CountWorkflowExecutionsResponse, error) // NOTE: GetClosedWorkflowExecution is only for persistence testing, currently no index is supported for filtering by RunID GetClosedWorkflowExecution(ctx context.Context, request *GetClosedWorkflowExecutionRequest) (*GetClosedWorkflowExecutionResponse, error) DeleteUninitializedWorkflowExecution(ctx context.Context, request *VisibilityDeleteWorkflowExecutionRequest) error }
VisibilityManager is used to manage the visibility store
func NewPinotVisibilityDualManager ¶ added in v1.2.5
func NewPinotVisibilityDualManager( dbVisibilityManager VisibilityManager, pinotVisibilityManager VisibilityManager, readModeIsFromPinot dynamicconfig.BoolPropertyFnWithDomainFilter, visWritingMode dynamicconfig.StringPropertyFn, logger log.Logger, ) VisibilityManager
NewPinotVisibilityDualManager create a visibility manager that operate on DB or Pinot based on dynamic config.
func NewVisibilityDualManager ¶ added in v0.22.0
func NewVisibilityDualManager( dbVisibilityManager VisibilityManager, advancedVisibilityManager VisibilityManager, readModeIsFromAdvanced dynamicconfig.BoolPropertyFnWithDomainFilter, visWritingMode dynamicconfig.StringPropertyFn, logger log.Logger, ) VisibilityManager
NewVisibilityDualManager create a visibility manager that operate on DB or ElasticSearch based on dynamic config.
func NewVisibilityManagerImpl ¶ added in v0.5.7
func NewVisibilityManagerImpl(persistence VisibilityStore, logger log.Logger) VisibilityManager
NewVisibilityManagerImpl returns new VisibilityManager via a VisibilityStore
func NewVisibilityTripleManager ¶ added in v1.2.11
func NewVisibilityTripleManager( dbVisibilityManager VisibilityManager, pinotVisibilityManager VisibilityManager, esVisibilityManager VisibilityManager, readModeIsFromPinot dynamicconfig.BoolPropertyFnWithDomainFilter, readModeIsFromES dynamicconfig.BoolPropertyFnWithDomainFilter, visWritingMode dynamicconfig.StringPropertyFn, logCustomerQueryParameter dynamicconfig.BoolPropertyFnWithDomainFilter, readModeIsDouble dynamicconfig.BoolPropertyFnWithDomainFilter, logger log.Logger, ) VisibilityManager
NewPinotVisibilityTripleManager create a visibility manager that operate on DB or Pinot based on dynamic config.
type VisibilityStore ¶ added in v0.4.0
type VisibilityStore interface { Closeable GetName() string RecordWorkflowExecutionStarted(ctx context.Context, request *InternalRecordWorkflowExecutionStartedRequest) error RecordWorkflowExecutionClosed(ctx context.Context, request *InternalRecordWorkflowExecutionClosedRequest) error RecordWorkflowExecutionUninitialized(ctx context.Context, request *InternalRecordWorkflowExecutionUninitializedRequest) error UpsertWorkflowExecution(ctx context.Context, request *InternalUpsertWorkflowExecutionRequest) error ListOpenWorkflowExecutions(ctx context.Context, request *InternalListWorkflowExecutionsRequest) (*InternalListWorkflowExecutionsResponse, error) ListClosedWorkflowExecutions(ctx context.Context, request *InternalListWorkflowExecutionsRequest) (*InternalListWorkflowExecutionsResponse, error) ListOpenWorkflowExecutionsByType(ctx context.Context, request *InternalListWorkflowExecutionsByTypeRequest) (*InternalListWorkflowExecutionsResponse, error) ListClosedWorkflowExecutionsByType(ctx context.Context, request *InternalListWorkflowExecutionsByTypeRequest) (*InternalListWorkflowExecutionsResponse, error) ListOpenWorkflowExecutionsByWorkflowID(ctx context.Context, request *InternalListWorkflowExecutionsByWorkflowIDRequest) (*InternalListWorkflowExecutionsResponse, error) ListClosedWorkflowExecutionsByWorkflowID(ctx context.Context, request *InternalListWorkflowExecutionsByWorkflowIDRequest) (*InternalListWorkflowExecutionsResponse, error) ListClosedWorkflowExecutionsByStatus(ctx context.Context, request *InternalListClosedWorkflowExecutionsByStatusRequest) (*InternalListWorkflowExecutionsResponse, error) GetClosedWorkflowExecution(ctx context.Context, request *InternalGetClosedWorkflowExecutionRequest) (*InternalGetClosedWorkflowExecutionResponse, error) DeleteWorkflowExecution(ctx context.Context, request *VisibilityDeleteWorkflowExecutionRequest) error ListWorkflowExecutions(ctx context.Context, request *ListWorkflowExecutionsByQueryRequest) (*InternalListWorkflowExecutionsResponse, error) ListAllWorkflowExecutions(ctx context.Context, request *InternalListAllWorkflowExecutionsByTypeRequest) (*InternalListWorkflowExecutionsResponse, error) ScanWorkflowExecutions(ctx context.Context, request *ListWorkflowExecutionsByQueryRequest) (*InternalListWorkflowExecutionsResponse, error) CountWorkflowExecutions(ctx context.Context, request *CountWorkflowExecutionsRequest) (*CountWorkflowExecutionsResponse, error) DeleteUninitializedWorkflowExecution(ctx context.Context, request *VisibilityDeleteWorkflowExecutionRequest) error }
VisibilityStore is the store interface for visibility
type WorkflowBackoffTimerTask ¶ added in v0.5.0
type WorkflowBackoffTimerTask struct { TaskData EventID int64 // TODO this attribute is not used? TimeoutType int // 0 for retry, 1 for cron. }
WorkflowBackoffTimerTask to schedule first decision task for retried workflow
func (*WorkflowBackoffTimerTask) GetType ¶ added in v0.5.0
func (r *WorkflowBackoffTimerTask) GetType() int
GetType returns the type of the retry timer task
type WorkflowEvents ¶ added in v0.7.0
type WorkflowEvents struct { DomainID string WorkflowID string RunID string BranchToken []byte Events []*types.HistoryEvent }
WorkflowEvents is used as generic workflow history events transaction container
type WorkflowExecutionAlreadyStartedError ¶ added in v0.3.5
type WorkflowExecutionAlreadyStartedError struct { Msg string StartRequestID string RunID string State int CloseStatus int LastWriteVersion int64 }
WorkflowExecutionAlreadyStartedError is returned when creating a new workflow failed.
func (*WorkflowExecutionAlreadyStartedError) Error ¶ added in v0.3.5
func (e *WorkflowExecutionAlreadyStartedError) Error() string
type WorkflowExecutionInfo ¶
type WorkflowExecutionInfo struct { DomainID string WorkflowID string RunID string FirstExecutionRunID string ParentDomainID string ParentWorkflowID string ParentRunID string InitiatedID int64 CompletionEventBatchID int64 CompletionEvent *types.HistoryEvent TaskList string WorkflowTypeName string WorkflowTimeout int32 DecisionStartToCloseTimeout int32 ExecutionContext []byte State int CloseStatus int LastFirstEventID int64 LastEventTaskID int64 NextEventID int64 LastProcessedEvent int64 StartTimestamp time.Time LastUpdatedTimestamp time.Time CreateRequestID string SignalCount int32 DecisionVersion int64 DecisionScheduleID int64 DecisionStartedID int64 DecisionRequestID string DecisionTimeout int32 DecisionAttempt int64 DecisionStartedTimestamp int64 DecisionScheduledTimestamp int64 DecisionOriginalScheduledTimestamp int64 CancelRequested bool CancelRequestID string StickyTaskList string StickyScheduleToStartTimeout int32 ClientLibraryVersion string ClientFeatureVersion string ClientImpl string AutoResetPoints *types.ResetPoints Memo map[string][]byte SearchAttributes map[string][]byte PartitionConfig map[string]string // for retry Attempt int32 HasRetryPolicy bool InitialInterval int32 BackoffCoefficient float64 MaximumInterval int32 ExpirationTime time.Time MaximumAttempts int32 NonRetriableErrors []string BranchToken []byte // Cron CronSchedule string IsCron bool ExpirationSeconds int32 // TODO: is this field useful? }
WorkflowExecutionInfo describes a workflow execution
func (*WorkflowExecutionInfo) IncreaseNextEventID ¶ added in v0.5.0
func (e *WorkflowExecutionInfo) IncreaseNextEventID()
IncreaseNextEventID increase the nextEventID by 1
func (*WorkflowExecutionInfo) IsRunning ¶ added in v0.25.0
func (e *WorkflowExecutionInfo) IsRunning() bool
func (*WorkflowExecutionInfo) SetLastFirstEventID ¶ added in v0.5.0
func (e *WorkflowExecutionInfo) SetLastFirstEventID(id int64)
SetLastFirstEventID set the LastFirstEventID
func (*WorkflowExecutionInfo) SetNextEventID ¶ added in v0.5.0
func (e *WorkflowExecutionInfo) SetNextEventID(id int64)
SetNextEventID sets the nextEventID
func (*WorkflowExecutionInfo) UpdateWorkflowStateCloseStatus ¶ added in v0.9.3
func (e *WorkflowExecutionInfo) UpdateWorkflowStateCloseStatus( state int, closeStatus int, ) error
UpdateWorkflowStateCloseStatus update the workflow state
type WorkflowMutableState ¶
type WorkflowMutableState struct { ActivityInfos map[int64]*ActivityInfo TimerInfos map[string]*TimerInfo ChildExecutionInfos map[int64]*ChildExecutionInfo RequestCancelInfos map[int64]*RequestCancelInfo SignalInfos map[int64]*SignalInfo SignalRequestedIDs map[string]struct{} ExecutionInfo *WorkflowExecutionInfo ExecutionStats *ExecutionStats BufferedEvents []*types.HistoryEvent VersionHistories *VersionHistories ReplicationState *ReplicationState // TODO: remove this after all 2DC workflows complete Checksum checksum.Checksum }
WorkflowMutableState indicates workflow related state
type WorkflowMutation ¶ added in v0.6.0
type WorkflowMutation struct { ExecutionInfo *WorkflowExecutionInfo ExecutionStats *ExecutionStats VersionHistories *VersionHistories UpsertActivityInfos []*ActivityInfo DeleteActivityInfos []int64 UpsertTimerInfos []*TimerInfo DeleteTimerInfos []string UpsertChildExecutionInfos []*ChildExecutionInfo DeleteChildExecutionInfos []int64 UpsertRequestCancelInfos []*RequestCancelInfo DeleteRequestCancelInfos []int64 UpsertSignalInfos []*SignalInfo DeleteSignalInfos []int64 UpsertSignalRequestedIDs []string DeleteSignalRequestedIDs []string NewBufferedEvents []*types.HistoryEvent ClearBufferedEvents bool TransferTasks []Task CrossClusterTasks []Task ReplicationTasks []Task TimerTasks []Task WorkflowRequests []*WorkflowRequest Condition int64 Checksum checksum.Checksum }
WorkflowMutation is used as generic workflow execution state mutation
type WorkflowRequest ¶ added in v1.2.9
type WorkflowRequest struct { RequestID string Version int64 RequestType WorkflowRequestType }
WorkflowRequest is used as requestID and it's corresponding failover version container
type WorkflowRequestType ¶ added in v1.2.9
type WorkflowRequestType int
WorkflowRequestType is the type of workflow request
const ( WorkflowRequestTypeStart WorkflowRequestType = iota WorkflowRequestTypeSignal WorkflowRequestTypeCancel WorkflowRequestTypeReset )
Types of workflow requests
type WorkflowSnapshot ¶ added in v0.6.0
type WorkflowSnapshot struct { ExecutionInfo *WorkflowExecutionInfo ExecutionStats *ExecutionStats VersionHistories *VersionHistories ActivityInfos []*ActivityInfo TimerInfos []*TimerInfo ChildExecutionInfos []*ChildExecutionInfo RequestCancelInfos []*RequestCancelInfo SignalInfos []*SignalInfo SignalRequestedIDs []string TransferTasks []Task CrossClusterTasks []Task ReplicationTasks []Task TimerTasks []Task WorkflowRequests []*WorkflowRequest Condition int64 Checksum checksum.Checksum }
WorkflowSnapshot is used as generic workflow execution state snapshot
type WorkflowTimeoutTask ¶
type WorkflowTimeoutTask struct {
TaskData
}
WorkflowTimeoutTask identifies a timeout task.
func (*WorkflowTimeoutTask) GetType ¶
func (u *WorkflowTimeoutTask) GetType() int
GetType returns the type of the timeout task.
Source Files
¶
- config.go
- configStoreManager.go
- dataManagerInterfaces_mock.go
- dataVisibilityManagerInterfaces.go
- dataVisibilityManagerInterfaces_mock.go
- data_manager_interfaces.go
- data_store_interfaces.go
- data_store_interfaces_mock.go
- domainManager.go
- errors.go
- execution_manager.go
- historyManager.go
- jsonHistoryTokenSerializer.go
- metered.go
- operationModeValidator.go
- pinot_visibility_dual_manager.go
- queueManager.go
- retryer.go
- retryer_mock.go
- serializer.go
- serializer_mock.go
- shard_manager.go
- statsComputer.go
- taskManager.go
- tasks.go
- versionHistory.go
- visibility_dual_manager.go
- visibility_single_manager.go
- visibility_store_mock.go
- visibility_triple_manager.go
- workflowStateCloseStatusValidator.go
- workflow_execution_info.go
Directories
¶
Path | Synopsis |
---|---|
Package client is a generated GoMock package.
|
Package client is a generated GoMock package. |
Package nosql is a generated GoMock package.
|
Package nosql is a generated GoMock package. |
nosqlplugin
Package nosqlplugin is a generated GoMock package.
|
Package nosqlplugin is a generated GoMock package. |
nosqlplugin/cassandra/gocql
Package gocql is a generated GoMock package.
|
Package gocql is a generated GoMock package. |
Package serialization is a generated GoMock package.
|
Package serialization is a generated GoMock package. |
sqldriver
Package sqldriver is a generated GoMock package.
|
Package sqldriver is a generated GoMock package. |
sqlplugin
Package sqlplugin is a generated GoMock package.
|
Package sqlplugin is a generated GoMock package. |
wrappers
|
|