File PlannerServer.h

namespace faabric

namespace planner

class PlannerServer : public faabric::transport::MessageEndpointServer

Public Functions

PlannerServer()

Protected Functions

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

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

void recvSetMessageResult(std::span<const uint8_t> buffer)

std::unique_ptr<google::protobuf::Message> recvPing()

std::unique_ptr<google::protobuf::Message> recvGetAvailableHosts()

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

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

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

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

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

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

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

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

Private Members

faabric::planner::Planner &planner