/*
 * Copyright (C) 2023-present ScyllaDB
 */

/*
 * SPDX-License-Identifier: (LicenseRef-ScyllaDB-Source-Available-1.0)
 */

#pragma once

#include "db/timeout_clock.hh"
#include "query/query-result.hh"

namespace locator {

class effective_replication_map;

using effective_replication_map_ptr = seastar::shared_ptr<const effective_replication_map>;

}

namespace replica::mutation_dump {

schema_ptr generate_output_schema_from_underlying_schema(schema_ptr underlying_schema);

future<foreign_ptr<lw_shared_ptr<query::result>>> dump_mutations(
        sharded<database>& db,
        locator::effective_replication_map_ptr erm_keepalive,
        schema_ptr output_schema, // must have been generated from `underlying_schema`, with `generate_output_schema_from_underlying_schema()`
        schema_ptr underlying_schema,
        const dht::partition_range_vector& pr,
        const query::read_command& cmd,
        db::timeout_clock::time_point timeout);

} // namespace replica::mutation_dump