Remove wrongly committed files
Reviewers: msantl, teon.banek Reviewed By: msantl Subscribers: pullbot Differential Revision: https://phabricator.memgraph.io/D1602
This commit is contained in:
parent
0eb0b913a8
commit
6682f174f1
2
.gitignore
vendored
2
.gitignore
vendored
@ -52,6 +52,8 @@ src/distributed/data_rpc_messages.capnp
|
||||
src/distributed/data_rpc_messages.hpp
|
||||
src/distributed/durability_rpc_messages.capnp
|
||||
src/distributed/durability_rpc_messages.hpp
|
||||
src/distributed/dynamic_worker_rpc_messages.capnp
|
||||
src/distributed/dynamic_worker_rpc_messages.hpp
|
||||
src/distributed/index_rpc_messages.capnp
|
||||
src/distributed/index_rpc_messages.hpp
|
||||
src/distributed/plan_rpc_messages.capnp
|
||||
|
@ -990,7 +990,6 @@ Worker::Worker(Config config)
|
||||
// Durability recovery. We need to check this flag for workers that are added
|
||||
// after the "main" cluster recovery.
|
||||
if (impl_->config_.db_recover_on_startup) {
|
||||
// What we should recover.
|
||||
// What we should recover (version, transaction_id) pair.
|
||||
auto snapshot_to_recover = impl_->cluster_discovery_.snapshot_to_recover();
|
||||
|
||||
|
@ -1,18 +0,0 @@
|
||||
# -*- buffer-read-only: t; -*-
|
||||
# vim: readonly
|
||||
# DO NOT EDIT! Generated using LCP from 'dynamic_worker_rpc_messages.lcp'
|
||||
|
||||
@0x8c53f6c9a0c71b05;
|
||||
|
||||
using Cxx = import "/capnp/c++.capnp";
|
||||
$Cxx.namespace("distributed::capnp");
|
||||
|
||||
using Utils = import "/utils/serialization.capnp";
|
||||
|
||||
struct DynamicWorkerRes {
|
||||
recoverIndices @0 :List(Utils.Pair(Text, Text));
|
||||
}
|
||||
|
||||
struct DynamicWorkerReq {
|
||||
}
|
||||
|
@ -1,48 +0,0 @@
|
||||
// -*- buffer-read-only: t; -*-
|
||||
// vim: readonly
|
||||
// DO NOT EDIT! Generated using LCP from 'dynamic_worker_rpc_messages.lcp'
|
||||
|
||||
#pragma once
|
||||
|
||||
#include <string>
|
||||
#include <vector>
|
||||
|
||||
#include "communication/rpc/messages.hpp"
|
||||
#include "distributed/dynamic_worker_rpc_messages.capnp.h"
|
||||
|
||||
namespace distributed {
|
||||
|
||||
struct DynamicWorkerReq {
|
||||
using Capnp = capnp::DynamicWorkerReq;
|
||||
static const communication::rpc::MessageType TypeInfo;
|
||||
DynamicWorkerReq() {}
|
||||
|
||||
void Save(capnp::DynamicWorkerReq::Builder *builder) const;
|
||||
|
||||
static std::unique_ptr<DynamicWorkerReq> Construct(
|
||||
const capnp::DynamicWorkerReq::Reader &reader);
|
||||
|
||||
void Load(const capnp::DynamicWorkerReq::Reader &reader);
|
||||
};
|
||||
|
||||
struct DynamicWorkerRes {
|
||||
using Capnp = capnp::DynamicWorkerRes;
|
||||
static const communication::rpc::MessageType TypeInfo;
|
||||
DynamicWorkerRes() {}
|
||||
explicit DynamicWorkerRes(
|
||||
std::vector<std::pair<std::string, std::string>> recover_indices)
|
||||
: recover_indices(recover_indices) {}
|
||||
|
||||
std::vector<std::pair<std::string, std::string>> recover_indices;
|
||||
|
||||
void Save(capnp::DynamicWorkerRes::Builder *builder) const;
|
||||
|
||||
static std::unique_ptr<DynamicWorkerRes> Construct(
|
||||
const capnp::DynamicWorkerRes::Reader &reader);
|
||||
|
||||
void Load(const capnp::DynamicWorkerRes::Reader &reader);
|
||||
};
|
||||
|
||||
using DynamicWorkerRpc =
|
||||
communication::rpc::RequestResponse<DynamicWorkerReq, DynamicWorkerRes>;
|
||||
}
|
Loading…
Reference in New Issue
Block a user