File MessageEndpointClient.h

namespace faabric

namespace transport

class MessageEndpointClient

Subclassed by faabric::planner::PlannerClient, faabric::scheduler::FunctionCallClient, faabric::snapshot::SnapshotClient, faabric::state::StateClient, faabric::transport::PointToPointClient

Public Functions

MessageEndpointClient(std::string hostIn, int asyncPort, int syncPort, int timeoutMs = DEFAULT_SOCKET_TIMEOUT_MS)

void asyncSend(int header, google::protobuf::Message *msg, int sequenceNum = NO_SEQUENCE_NUM)

void asyncSend(int header, const uint8_t *buffer, size_t bufferSize, int sequenceNum = NO_SEQUENCE_NUM)

void syncSend(int header, google::protobuf::Message *msg, google::protobuf::Message *response)

void syncSend(int header, const uint8_t *buffer, size_t bufferSize, google::protobuf::Message *response)

Protected Attributes

const std::string host

const int asyncPort

const int syncPort

std::optional<faabric::transport::AsyncSendMessageEndpoint> asyncEndpoint

std::optional<faabric::transport::SyncSendMessageEndpoint> syncEndpoint