Class faabric::planner::PlannerClient

class PlannerClient : public faabric::transport::MessageEndpointClient 

Public Functions

PlannerClient()

PlannerClient(const std::string &plannerIp)

void ping()

void clearCache()

std::vector<Host> getAvailableHosts()

int registerHost(std::shared_ptr<RegisterHostRequest> req)

void removeHost(std::shared_ptr<RemoveHostRequest> req)

void setMessageResult(std::shared_ptr<faabric::Message> msg)

void setMessageResultLocally(std::shared_ptr<faabric::Message> msg)

faabric::Message getMessageResult(int appId, int msgId, int timeoutMs)

faabric::Message getMessageResult(const faabric::Message &msg, int timeoutMs)

std::shared_ptr<faabric::BatchExecuteRequestStatus> getBatchResults(std::shared_ptr<faabric::BatchExecuteRequest> req)

faabric::batch_scheduler::SchedulingDecision callFunctions(std::shared_ptr<faabric::BatchExecuteRequest> req)

faabric::batch_scheduler::SchedulingDecision getSchedulingDecision(std::shared_ptr<faabric::BatchExecuteRequest> req)

int getNumMigrations()

void preloadSchedulingDecision(std::shared_ptr<faabric::batch_scheduler::SchedulingDecision> preloadDec)