Documentation
¶
Index ¶
- Variables
- func NewHistoryCurrentExecutionSuite(t *testing.T, store sqlplugin.HistoryExecution) *historyCurrentExecutionSuite
- func NewHistoryExecutionActivitySuite(t *testing.T, store sqlplugin.HistoryExecutionActivity) *historyExecutionActivitySuite
- func NewHistoryExecutionBufferSuite(t *testing.T, store sqlplugin.HistoryExecutionBuffer) *historyExecutionBufferSuite
- func NewHistoryExecutionChildWorkflowSuite(t *testing.T, store sqlplugin.HistoryExecutionChildWorkflow) *historyExecutionChildWorkflowSuite
- func NewHistoryExecutionRequestCancelSuite(t *testing.T, store sqlplugin.HistoryExecutionRequestCancel) *historyExecutionRequestCancelSuite
- func NewHistoryExecutionSignalRequestSuite(t *testing.T, store sqlplugin.HistoryExecutionSignalRequest) *historyExecutionSignalRequestSuite
- func NewHistoryExecutionSignalSuite(t *testing.T, store sqlplugin.HistoryExecutionSignal) *historyExecutionSignalSuite
- func NewHistoryExecutionSuite(t *testing.T, store sqlplugin.HistoryExecution) *historyExecutionSuite
- func NewHistoryExecutionTimerSuite(t *testing.T, store sqlplugin.HistoryExecutionTimer) *historyExecutionTimerSuite
- func NewHistoryNodeSuite(t *testing.T, store sqlplugin.HistoryNode) *historyNodeSuite
- func NewHistoryReplicationDLQTaskSuite(t *testing.T, store sqlplugin.HistoryReplicationDLQTask) *historyHistoryReplicationDLQTaskSuite
- func NewHistoryReplicationTaskSuite(t *testing.T, store sqlplugin.HistoryReplicationTask) *historyHistoryReplicationTaskSuite
- func NewHistoryShardSuite(t *testing.T, store sqlplugin.HistoryShard) *historyShardSuite
- func NewHistoryTimerTaskSuite(t *testing.T, store sqlplugin.HistoryTimerTask) *historyHistoryTimerTaskSuite
- func NewHistoryTransferTaskSuite(t *testing.T, store sqlplugin.HistoryTransferTask) *historyHistoryTransferTaskSuite
- func NewHistoryTreeSuite(t *testing.T, store sqlplugin.HistoryTree) *historyTreeSuite
- func NewHistoryVisibilityTaskSuite(t *testing.T, store sqlplugin.HistoryVisibilityTask) *historyHistoryVisibilityTaskSuite
- func NewMatchingTaskQueueSuite(t *testing.T, store sqlplugin.MatchingTaskQueue) *matchingTaskQueueSuite
- func NewMatchingTaskSuite(t *testing.T, store sqlplugin.MatchingTask) *matchingTaskSuite
- func NewNamespaceSuite(t *testing.T, store sqlplugin.Namespace) *namespaceSuite
- func NewQueueMessageSuite(t *testing.T, store sqlplugin.QueueMessage) *queueMessageSuite
- func NewQueueMetadataSuite(t *testing.T, store sqlplugin.QueueMetadata) *queueMetadataSuite
- func NewVisibilitySuite(t *testing.T, store sqlplugin.Visibility) *visibilitySuite
- func RunSQLQueueV2TestSuite(t *testing.T, baseDB sqlplugin.DB)
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrGetLastMessageIdFailed = errors.New("getLastMessageId error") ErrTxBeginFailed = errors.New("txBegin error") ErrInsertFailed = errors.New("insert error") ErrTxRollbackFailed = errors.New("txRollBack err") ErrTxCommitFailed = errors.New("txCommit err") ErrRangeSelectFailed = errors.New("rangeSelect err") ErrSelectMetadataFailed = errors.New("selectFromMetadata err") ErrInsertMetadataFailed = errors.New("insertMetadataFailed") ErrRangeDeleteFailed = errors.New("rangeDeleteFailed") ErrUpdateMetadataFailed = errors.New("updateMetadataFailed") ErrSelectQueueNames = errors.New("selectQueueNamesFailed") )
Functions ¶
func NewHistoryCurrentExecutionSuite ¶
func NewHistoryCurrentExecutionSuite( t *testing.T, store sqlplugin.HistoryExecution, ) *historyCurrentExecutionSuite
func NewHistoryExecutionActivitySuite ¶
func NewHistoryExecutionActivitySuite( t *testing.T, store sqlplugin.HistoryExecutionActivity, ) *historyExecutionActivitySuite
func NewHistoryExecutionBufferSuite ¶
func NewHistoryExecutionBufferSuite( t *testing.T, store sqlplugin.HistoryExecutionBuffer, ) *historyExecutionBufferSuite
func NewHistoryExecutionChildWorkflowSuite ¶
func NewHistoryExecutionChildWorkflowSuite( t *testing.T, store sqlplugin.HistoryExecutionChildWorkflow, ) *historyExecutionChildWorkflowSuite
func NewHistoryExecutionRequestCancelSuite ¶
func NewHistoryExecutionRequestCancelSuite( t *testing.T, store sqlplugin.HistoryExecutionRequestCancel, ) *historyExecutionRequestCancelSuite
func NewHistoryExecutionSignalRequestSuite ¶
func NewHistoryExecutionSignalRequestSuite( t *testing.T, store sqlplugin.HistoryExecutionSignalRequest, ) *historyExecutionSignalRequestSuite
func NewHistoryExecutionSignalSuite ¶
func NewHistoryExecutionSignalSuite( t *testing.T, store sqlplugin.HistoryExecutionSignal, ) *historyExecutionSignalSuite
func NewHistoryExecutionSuite ¶
func NewHistoryExecutionSuite( t *testing.T, store sqlplugin.HistoryExecution, ) *historyExecutionSuite
func NewHistoryExecutionTimerSuite ¶
func NewHistoryExecutionTimerSuite( t *testing.T, store sqlplugin.HistoryExecutionTimer, ) *historyExecutionTimerSuite
func NewHistoryNodeSuite ¶
func NewHistoryNodeSuite( t *testing.T, store sqlplugin.HistoryNode, ) *historyNodeSuite
func NewHistoryReplicationDLQTaskSuite ¶
func NewHistoryReplicationDLQTaskSuite( t *testing.T, store sqlplugin.HistoryReplicationDLQTask, ) *historyHistoryReplicationDLQTaskSuite
func NewHistoryReplicationTaskSuite ¶
func NewHistoryReplicationTaskSuite( t *testing.T, store sqlplugin.HistoryReplicationTask, ) *historyHistoryReplicationTaskSuite
func NewHistoryShardSuite ¶
func NewHistoryShardSuite( t *testing.T, store sqlplugin.HistoryShard, ) *historyShardSuite
func NewHistoryTimerTaskSuite ¶
func NewHistoryTimerTaskSuite( t *testing.T, store sqlplugin.HistoryTimerTask, ) *historyHistoryTimerTaskSuite
func NewHistoryTransferTaskSuite ¶
func NewHistoryTransferTaskSuite( t *testing.T, store sqlplugin.HistoryTransferTask, ) *historyHistoryTransferTaskSuite
func NewHistoryTreeSuite ¶
func NewHistoryTreeSuite( t *testing.T, store sqlplugin.HistoryTree, ) *historyTreeSuite
func NewHistoryVisibilityTaskSuite ¶
func NewHistoryVisibilityTaskSuite( t *testing.T, store sqlplugin.HistoryVisibilityTask, ) *historyHistoryVisibilityTaskSuite
func NewMatchingTaskQueueSuite ¶
func NewMatchingTaskQueueSuite( t *testing.T, store sqlplugin.MatchingTaskQueue, ) *matchingTaskQueueSuite
func NewMatchingTaskSuite ¶
func NewMatchingTaskSuite( t *testing.T, store sqlplugin.MatchingTask, ) *matchingTaskSuite
func NewNamespaceSuite ¶
func NewQueueMessageSuite ¶
func NewQueueMessageSuite( t *testing.T, store sqlplugin.QueueMessage, ) *queueMessageSuite
func NewQueueMetadataSuite ¶
func NewQueueMetadataSuite( t *testing.T, store sqlplugin.QueueMetadata, ) *queueMetadataSuite
func NewVisibilitySuite ¶
func NewVisibilitySuite( t *testing.T, store sqlplugin.Visibility, ) *visibilitySuite
Types ¶
This section is empty.
Source Files
¶
- context.go
- history_current_execution.go
- history_execution.go
- history_execution_activity.go
- history_execution_buffer.go
- history_execution_child_workflow.go
- history_execution_request_cancel.go
- history_execution_signal.go
- history_execution_signal_requested.go
- history_execution_timer.go
- history_node.go
- history_replication_task.go
- history_replication_task_dlq.go
- history_shard.go
- history_timer_task.go
- history_transfer_task.go
- history_tree.go
- history_visibility_task.go
- matching_task.go
- matching_task_queue.go
- namespace.go
- queue_message.go
- queue_metadata.go
- queue_v2.go
- visibility.go
Click to show internal directories.
Click to hide internal directories.