7e7f1e6f91
New RPC is introduced becuase load_stats was marked "final" in the IDL. Will be needed by capacity-aware load balancing.
24 lines
529 B
C++
24 lines
529 B
C++
/*
|
|
* Copyright (C) 2025-present ScyllaDB
|
|
*/
|
|
|
|
/*
|
|
* SPDX-License-Identifier: LicenseRef-ScyllaDB-Source-Available-1.0
|
|
*/
|
|
|
|
#pragma once
|
|
|
|
#include <seastar/core/sharded.hh>
|
|
#include <seastar/core/shard_id.hh>
|
|
|
|
// When passed to sharded<>::start(), translates to "val" passed to sharded instances on shard 0 and T{} on other shards.
|
|
template <typename T>
|
|
auto only_on_shard0(T val) {
|
|
return sharded_parameter([val] {
|
|
if (seastar::this_shard_id() == 0) {
|
|
return val;
|
|
}
|
|
return T{};
|
|
});
|
|
}
|