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