Class faabric::planner::Planner

class Planner

Public Functions

Planner()

PlannerConfig getConfig()

void printConfig() const

std::string getPolicy()

void setPolicy(const std::string &newPolicy)

bool reset()

bool flush(faabric::planner::FlushType flushType)

std::vector<std::shared_ptr<Host>> getAvailableHosts()

bool registerHost(const Host &hostIn, bool overwrite)

void removeHost(const Host &hostIn)

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

std::shared_ptr<faabric::Message> getMessageResult(std::shared_ptr<faabric::Message> msg)

void preloadSchedulingDecision(int appId, std::shared_ptr<batch_scheduler::SchedulingDecision> decision)

std::shared_ptr<batch_scheduler::SchedulingDecision> getPreloadedSchedulingDecision(int32_t appId, std::shared_ptr<BatchExecuteRequest> ber)

std::shared_ptr<faabric::BatchExecuteRequestStatus> getBatchResults(int32_t appId)

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

faabric::batch_scheduler::InFlightReqs getInFlightReqs()

int getNumMigrations()

std::set<std::string> getNextEvictedHostIps()

std::map<int32_t, std::shared_ptr<BatchExecuteRequest>> getEvictedReqs()

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

void setNextEvictedVm(const std::set<std::string> &vmIp)