85
// RunHistoryTaskQueueManagerTestSuite runs all tests for the history task queue manager against a given queue provided by a
86
// particular database. This test suite should be re-used to test all queue implementations.
87
>
func RunHistoryTaskQueueManagerTestSuite(t *testing.T, queue persistence.QueueV2) {
history_task_queue_manager_test_suite.go
88
>
serializer := serialization.NewSerializer()
89
>
historyTaskQueueManager := persistence.NewHistoryTaskQueueManager(queue, serializer)
90
>
t.Run("ListQueues", func(t *testing.T) {
91
listqueuestest.TestInvoke(t, historyTaskQueueManager)
92
})
93
>
t.Run("TestHistoryTaskQueueManagerEnqueueTasks", func(t *testing.T) {
history_task_queue_manager_test_suite.go
94
t.Parallel()
95
testHistoryTaskQueueManagerEnqueueTasks(t, historyTaskQueueManager)
96
})
97
>
t.Run("TestHistoryTaskQueueManagerEnqueueTasksErr", func(t *testing.T) {
history_task_queue_manager_test_suite.go
98
t.Parallel()
99
testHistoryTaskQueueManagerEnqueueTasksErr(t, queue)
100
})
101
>
t.Run("TestHistoryTaskQueueManagerCreateQueueErr", func(t *testing.T) {
history_task_queue_manager_test_suite.go
102
t.Parallel()
103
testHistoryTaskQueueManagerCreateQueueErr(t, queue)
104
})
105
>
t.Run("TestHistoryTQMErrDeserializeTask", func(t *testing.T) {
history_task_queue_manager_test_suite.go
106
t.Parallel()
107
testHistoryTaskQueueManagerErrDeserializeHistoryTask(t, queue, historyTaskQueueManager)
108
})
110
t.Parallel()
111
testHistoryTaskQueueManagerDeleteTasks(t, historyTaskQueueManager)
112
})
114
t.Parallel()
115
testHistoryTaskQueueManagerDeleteTasksErr(t, queue)
116
})
118
t.Parallel()
119
getdlqtaskstest.TestInvoke(t, historyTaskQueueManager)
120
})
122
t.Parallel()
123
deletedlqtaskstest.TestInvoke(t, historyTaskQueueManager)
124
})
126
t.Parallel()
127
historytest.TestClient(t, historyTaskQueueManager)