tursom/memgraph
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Update Coordinator

Browse Source
This commit is contained in:
gvolfing 2022-08-05 16:45:44 +02:00 committed by Tyler Neely
parent edf1293274
commit 5963c83a60
1 changed files with 15 additions and 4 deletions

19
src/coordinator/coordinator.hpp
View File

@ -11,6 +11,8 @@
#pragma once
#include <unordered_set>
#include "coordinator/hybrid_logical_clock.hpp"
#include "coordinator/shard_map.hpp"
#include "io/simulator/simulator.hpp"
@ -85,7 +87,11 @@ using ReadRequests = std::variant<HlcRequest, GetShardMapRequest>;
using ReadResponses = std::variant<HlcResponse, GetShardMapResponse>;
class Coordinator {
using StandbySotrageEnginePool = std::unordered_set<Address>;
ShardMap shard_map_;
StandbySotrageEnginePool storage_engine_pool_;
/// The highest reserved timestamp / highest allocated timestamp
/// is a way for minimizing communication involved in query engines
/// reserving Hlc's for their transaction processing.
@ -129,10 +135,11 @@ class Coordinator {
if (split_shard_request.previous_shard_map_version != shard_map_.shard_map_version) {
// TODO reply with failure
res.success = false;
} else {
// TODO apply split
}
// TODO apply split
return res;
}
@ -140,8 +147,10 @@ class Coordinator {
/// which can be used to rebalance storage over time.
WriteResponses Apply(RegisterStorageEngineRequest &&register_storage_engine_request) {
RegisterStorageEngineResponse res{};
// TODO
const Address &address = register_storage_engine_request.address;
storage_engine_pool_.insert(address);
res.success = true;
return res;
}
@ -150,8 +159,10 @@ class Coordinator {
/// clusters that it might be participating in.
WriteResponses Apply(DeregisterStorageEngineRequest &&register_storage_engine_request) {
DeregisterStorageEngineResponse res{};
// TODO
const Address &address = register_storage_engine_request.address;
storage_engine_pool_.erase(address);
res.success = true;
return res;
}