File FunctionCallServer.h

namespace faabric

namespace scheduler

class FunctionCallServer : public faabric::transport::MessageEndpointServer

Public Functions

FunctionCallServer()

Private 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> recvFlush(std::span<const uint8_t> buffer)

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

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

Private Members

Scheduler &scheduler