56
}
57
59
>
sourceCluster := shuffle.String(testHistoryReplicationTaskDLQSourceCluster)
60
>
shardID := rand.Int31()
61
>
taskID := int64(1)
62
>
63
>
task := s.newRandomReplicationTasksDLQRow(sourceCluster, shardID, taskID)
64
>
result, err := s.store.InsertIntoReplicationDLQTasks(newExecutionContext(), []sqlplugin.ReplicationDLQTasksRow{task})
65
>
s.NoError(err)
66
>
rowsAffected, err := result.RowsAffected()
67
>
s.NoError(err)
68
>
s.Equal(1, int(rowsAffected))
69
>
}
70
71
func (s *historyHistoryReplicationDLQTaskSuite) TestInsert_Multiple_Success() {