File FunctionCallClient.cpp

namespace faabric

namespace scheduler

Functions

std::vector<std::pair<std::string, faabric::Message>> getFunctionCalls()

std::vector<std::pair<std::string, faabric::EmptyRequest>> getFlushCalls()

std::vector<std::pair<std::string, std::shared_ptr<faabric::BatchExecuteRequest>>> getBatchRequests()

std::vector<std::pair<std::string, std::shared_ptr<faabric::Message>>> getMessageResults()

void clearMockRequests()

std::shared_ptr<FunctionCallClient> getFunctionCallClient(const std::string &otherHost)

void clearFunctionCallClients()

Variables

static std::mutex mockMutex

static std::vector<std::pair<std::string, faabric::Message>> functionCalls

static std::vector<std::pair<std::string, faabric::EmptyRequest>> flushCalls

static std::vector<std::pair<std::string, std::shared_ptr<faabric::BatchExecuteRequest>>> batchMessages

static std::vector<std::pair<std::string, std::shared_ptr<faabric::Message>>> messageResults

static faabric::util::ConcurrentMap<std::string, std::shared_ptr<faabric::scheduler::FunctionCallClient>> functionCallClients