5ba5aec1f8
As requested in #22104, moved the files and fixed other includes and build system. Moved files: - combine.hh - collection_mutation.hh - collection_mutation.cc - converting_mutation_partition_applier.hh - converting_mutation_partition_applier.cc - counters.hh - counters.cc - timestamp.hh Fixes: #22104 This is a cleanup, no need to backport Closes scylladb/scylladb#25085
53 lines
1.5 KiB
C++
53 lines
1.5 KiB
C++
/*
|
|
* Copyright (C) 2025-present ScyllaDB
|
|
*/
|
|
|
|
/*
|
|
* SPDX-License-Identifier: LicenseRef-ScyllaDB-Source-Available-1.0
|
|
*/
|
|
|
|
#pragma once
|
|
|
|
#include "mutation/mutation.hh"
|
|
#include "db/system_keyspace.hh"
|
|
#include "mutation/timestamp.hh"
|
|
|
|
namespace db {
|
|
|
|
namespace view {
|
|
|
|
// Factory for mutations to `system.view_building_tasks` table.
|
|
class view_building_task_mutation_builder {
|
|
api::timestamp_type _ts;
|
|
schema_ptr _s;
|
|
mutation _m;
|
|
|
|
public:
|
|
view_building_task_mutation_builder(api::timestamp_type ts)
|
|
: _ts(ts)
|
|
, _s(db::system_keyspace::view_building_tasks())
|
|
, _m(_s, partition_key::from_single_value(*_s, data_value("view_building").serialize_nonnull()))
|
|
{ }
|
|
|
|
static utils::UUID new_id();
|
|
|
|
view_building_task_mutation_builder& set_type(utils::UUID id, db::view::view_building_task::task_type type);
|
|
view_building_task_mutation_builder& set_state(utils::UUID id, db::view::view_building_task::task_state state);
|
|
view_building_task_mutation_builder& set_base_id(utils::UUID id, table_id base_id);
|
|
view_building_task_mutation_builder& set_view_id(utils::UUID id, table_id view_id);
|
|
view_building_task_mutation_builder& set_last_token(utils::UUID id, dht::token last_token);
|
|
view_building_task_mutation_builder& set_replica(utils::UUID id, const locator::tablet_replica& replica);
|
|
view_building_task_mutation_builder& del_task(utils::UUID id);
|
|
|
|
mutation build() {
|
|
return std::move(_m);
|
|
}
|
|
|
|
private:
|
|
clustering_key get_ck(utils::UUID id);
|
|
};
|
|
|
|
}
|
|
|
|
}
|