File SnapshotServer.h

namespace faabric

namespace snapshot

class SnapshotServer : public faabric::transport::MessageEndpointServer

Public Functions

SnapshotServer()

Protected Functions

virtual void doAsyncRecv(transport::Message &message) override

virtual std::unique_ptr<google::protobuf::Message> doSyncRecv(transport::Message &message) override

std::unique_ptr<google::protobuf::Message> recvPushSnapshot(std::span<const uint8_t> buffer)

std::unique_ptr<google::protobuf::Message> recvPushSnapshotUpdate(std::span<const uint8_t> buffer)

void recvDeleteSnapshot(std::span<const uint8_t> buffer)

std::unique_ptr<google::protobuf::Message> recvThreadResult(faabric::transport::Message &message)

Private Members

faabric::transport::PointToPointBroker &broker

faabric::snapshot::SnapshotRegistry &reg