File PointToPointClient.h

namespace faabric

namespace transport

class PointToPointClient : public faabric::transport::MessageEndpointClient

Public Functions

PointToPointClient(const std::string &hostIn)

void sendMappings(faabric::PointToPointMappings &mappings)

void sendMessage(faabric::PointToPointMessage &msg, int sequenceNum = NO_SEQUENCE_NUM)

void groupLock(int appId, int groupId, int groupIdx, bool recursive = false)

void groupUnlock(int appId, int groupId, int groupIdx, bool recursive = false)

Private Functions

void makeCoordinationRequest(int appId, int groupId, int groupIdx, faabric::transport::PointToPointCall call)