ctx context.Context,
filter sqlplugin.ReplicationTasksRangeFilter,
var rows []sqlplugin.ReplicationTasksRow
err := pdb.SelectContext(ctx,
&rows,
getReplicationTasksQuery,
filter.ShardID,
filter.InclusiveMinTaskID,
filter.ExclusiveMaxTaskID,
filter.PageSize,
)
return rows, err
}
// DeleteFromReplicationTasks deletes one rows from replication_tasks table