823
ctx context.Context,
824
filter sqlplugin.ReplicationDLQTasksRangeFilter,
825
>
) ([]sqlplugin.ReplicationDLQTasksRow, error) {
execution.go
826
>
var rows []sqlplugin.ReplicationDLQTasksRow
827
>
err := mdb.SelectContext(ctx,
828
>
&rows, getReplicationTasksDLQQuery,
829
>
filter.SourceClusterName,
830
>
filter.ShardID,
831
>
filter.InclusiveMinTaskID,
832
>
filter.ExclusiveMaxTaskID,
833
>
filter.PageSize,
834
>
)
835
>
return rows, err
836
>
}
837
838
// DeleteFromReplicationDLQTasks deletes one row from replication_tasks_dlq table