tests

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)

Variables

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 NewNamespaceSuite(
	t *testing.T,
	store sqlplugin.Namespace,
) *namespaceSuite

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

func RunSQLQueueV2TestSuite

func RunSQLQueueV2TestSuite(t *testing.T, baseDB sqlplugin.DB)