|
| HierarchicalAllocatorProcess () |
|
| HierarchicalAllocatorProcess (const std::function< Sorter *()> &roleSorterFactory, const std::function< Sorter *()> &_frameworkSorterFactory) |
|
| ~HierarchicalAllocatorProcess () override |
|
process::PID< HierarchicalAllocatorProcess > | self () const |
|
void | initialize (const mesos::allocator::Options &options, const lambda::function< void(const FrameworkID &, const hashmap< std::string, hashmap< SlaveID, Resources >> &)> &offerCallback, const lambda::function< void(const FrameworkID &, const hashmap< SlaveID, UnavailableResources > &)> &inverseOfferCallback) override |
|
void | recover (const int _expectedAgentCount, const hashmap< std::string, Quota > "as) override |
|
void | addFramework (const FrameworkID &frameworkId, const FrameworkInfo &frameworkInfo, const hashmap< SlaveID, Resources > &used, bool active,::mesos::allocator::FrameworkOptions &&frameworkOptions) override |
|
void | removeFramework (const FrameworkID &frameworkId) override |
|
void | activateFramework (const FrameworkID &frameworkId) override |
|
void | deactivateFramework (const FrameworkID &frameworkId) override |
|
void | updateFramework (const FrameworkID &frameworkId, const FrameworkInfo &frameworkInfo,::mesos::allocator::FrameworkOptions &&frameworkOptions) override |
|
void | addSlave (const SlaveID &slaveId, const SlaveInfo &slaveInfo, const std::vector< SlaveInfo::Capability > &capabilities, const Option< Unavailability > &unavailability, const Resources &total, const hashmap< FrameworkID, Resources > &used) override |
|
void | removeSlave (const SlaveID &slaveId) override |
|
void | updateSlave (const SlaveID &slave, const SlaveInfo &slaveInfo, const Option< Resources > &total=None(), const Option< std::vector< SlaveInfo::Capability >> &capabilities=None()) override |
|
void | addResourceProvider (const SlaveID &slave, const Resources &total, const hashmap< FrameworkID, Resources > &used) override |
|
void | deactivateSlave (const SlaveID &slaveId) override |
|
void | activateSlave (const SlaveID &slaveId) override |
|
void | updateWhitelist (const Option< hashset< std::string >> &whitelist) override |
|
void | requestResources (const FrameworkID &frameworkId, const std::vector< Request > &requests) override |
|
void | updateAllocation (const FrameworkID &frameworkId, const SlaveID &slaveId, const Resources &offeredResources, const std::vector< ResourceConversion > &conversions) override |
|
process::Future< Nothing > | updateAvailable (const SlaveID &slaveId, const std::vector< Offer::Operation > &operations) override |
|
void | updateUnavailability (const SlaveID &slaveId, const Option< Unavailability > &unavailability) override |
|
void | updateInverseOffer (const SlaveID &slaveId, const FrameworkID &frameworkId, const Option< UnavailableResources > &unavailableResources, const Option< mesos::allocator::InverseOfferStatus > &status, const Option< Filters > &filters) override |
|
process::Future< hashmap< SlaveID, hashmap< FrameworkID, mesos::allocator::InverseOfferStatus > > > | getInverseOfferStatuses () override |
|
void | transitionOfferedToAllocated (const SlaveID &slaveId, const Resources &resources) override |
|
void | recoverResources (const FrameworkID &frameworkId, const SlaveID &slaveId, const Resources &resources, const Option< Filters > &filters, bool isAllocated) override |
|
void | suppressOffers (const FrameworkID &frameworkId, const std::set< std::string > &roles) override |
|
void | reviveOffers (const FrameworkID &frameworkId, const std::set< std::string > &roles) override |
|
void | updateQuota (const std::string &role, const Quota "a) override |
|
void | updateWeights (const std::vector< WeightInfo > &weightInfos) override |
|
void | pause () override |
|
void | resume () override |
|
| MesosAllocatorProcess () |
|
| ~MesosAllocatorProcess () override |
|
| ~Process () override |
|
PID< MesosAllocatorProcess > | self () const |
| Returns the PID of the process. More...
|
|
| ProcessBase (const std::string &id="") |
|
| ~ProcessBase () override |
|
const UPID & | self () const |
|
virtual | ~EventConsumer () |
|
|
typedef HierarchicalAllocatorProcess | Self |
|
typedef HierarchicalAllocatorProcess | This |
|
typedef MesosAllocatorProcess | Self |
|
typedef MesosAllocatorProcess | This |
|
enum | RemoteConnection { RemoteConnection::REUSE,
RemoteConnection::RECONNECT
} |
| Describes the behavior of the link call when the target pid points to a remote process. More...
|
|
typedef lambda::function< void(const UPID &, const std::string &)> | MessageHandler |
| Any function which takes a "from" UPID and a message body as arguments. More...
|
|
typedef lambda::function< Future< http::Response >const http::Request &)> | HttpRequestHandler |
| Any function which takes a process::http::Request and returns a process::http::Response . More...
|
|
typedef lambda::function< Future< http::Response > const http::Request &, const Option< http::authentication::Principal > &)> | AuthenticatedHttpRequestHandler |
| Any function which takes a process::http::Request and an Option<Principal> and returns a process::http::Response . More...
|
|
process::Future< Nothing > | generateOffers () |
|
process::Future< Nothing > | generateOffers (const SlaveID &slaveId) |
|
process::Future< Nothing > | generateOffers (const hashset< SlaveID > &slaveIds) |
|
Nothing | _generateOffers () |
|
void | __generateOffers () |
|
void | generateInverseOffers () |
|
void | expire (const FrameworkID &frameworkId, const std::string &role, const SlaveID &slaveId, const std::weak_ptr< OfferFilter > &offerFilter) |
|
void | _expire (const FrameworkID &frameworkId, const std::string &role, const SlaveID &slaveId, const std::weak_ptr< OfferFilter > &offerFilter) |
|
void | expire (const FrameworkID &frameworkId, const SlaveID &slaveId, const std::weak_ptr< InverseOfferFilter > &inverseOfferFilter) |
|
bool | isWhitelisted (const SlaveID &slaveId) const |
|
bool | isFiltered (const Framework &framework, const std::string &role, const Slave &slave, const Resources &resources) const |
|
bool | isFiltered (const Framework &framework, const Slave &slave) const |
|
bool | allocatable (const Resources &resources, const std::string &role, const Framework &framework) const |
|
double | _event_queue_dispatches () |
|
double | _resources_total (const std::string &resource) |
|
double | _resources_offered_or_allocated (const std::string &resource) |
|
double | _quota_offered_or_allocated (const std::string &role, const std::string &resource) |
|
double | _offer_filters_active (const std::string &role) |
|
virtual void | serve (Event &&event) |
| Invoked when an event is serviced. More...
|
|
void | consume (MessageEvent &&event) override |
|
void | consume (DispatchEvent &&event) override |
|
void | consume (HttpEvent &&event) override |
|
void | consume (ExitedEvent &&event) override |
|
void | consume (TerminateEvent &&event) override |
|
virtual void | initialize () |
| Invoked when a process gets spawned. More...
|
|
virtual void | finalize () |
| Invoked when a process is terminated. More...
|
|
virtual void | exited (const UPID &) |
| Invoked when a linked process has exited. More...
|
|
virtual void | lost (const UPID &) |
| Invoked when a linked process can no longer be monitored. More...
|
|
void | send (const UPID &to, const std::string &name, const char *data=nullptr, size_t length=0) |
| Sends the message to the specified UPID . More...
|
|
void | send (const UPID &to, std::string &&name) |
|
void | send (const UPID &to, std::string &&name, std::string &&data) |
|
UPID | link (const UPID &pid, const RemoteConnection remote=RemoteConnection::REUSE) |
| Links with the specified UPID . More...
|
|
void | install (const std::string &name, const MessageHandler &handler) |
| Sets up a handler for messages with the specified name. More...
|
|
template<typename T > |
void | install (const std::string &name, void(T::*method)(const UPID &, const std::string &)) |
| Sets up a handler for messages with the specified name. More...
|
|
void | delegate (const std::string &name, const UPID &pid) |
| Delegates incoming messages, with the specified name, to the UPID . More...
|
|
void | route (const std::string &name, const Option< std::string > &help, const HttpRequestHandler &handler, const RouteOptions &options=RouteOptions()) |
| Sets up a handler for HTTP requests with the specified name. More...
|
|
template<typename T > |
void | route (const std::string &name, const Option< std::string > &help, Future< http::Response >(T::*method)(const http::Request &), const RouteOptions &options=RouteOptions()) |
| Sets up a handler for HTTP requests with the specified name. More...
|
|
void | route (const std::string &name, const std::string &realm, const Option< std::string > &help, const AuthenticatedHttpRequestHandler &handler, const RouteOptions &options=RouteOptions()) |
|
template<typename T > |
void | route (const std::string &name, const Option< std::string > &realm, const Option< std::string > &help, Future< http::Response >(T::*method)(const http::Request &, const Option< http::authentication::Principal > &), const RouteOptions &options=RouteOptions()) |
| Forwards to the correct overload of process::ProcessBase::route() , depending on whether the authentication realm realm is present. More...
|
|
void | provide (const std::string &name, const std::string &path, const std::map< std::string, std::string > &types=mime::types) |
| Sets up the default HTTP request handler to provide the static asset(s) at the specified absolute path for the specified name. More...
|
|
template<typename T > |
size_t | eventCount () |
| Returns the number of events of the given type currently on the event queue. More...
|
|
bool | initialized |
|
bool | paused |
|
mesos::allocator::Options | options |
|
Option< int > | expectedAgentCount |
|
lambda::function< void(const FrameworkID &, const hashmap< std::string, hashmap< SlaveID, Resources >> &)> | offerCallback |
|
lambda::function< void(const FrameworkID &, const hashmap< SlaveID, UnavailableResources > &)> | inverseOfferCallback |
|
friend | Metrics |
|
Metrics | metrics |
|
hashmap< FrameworkID, Framework > | frameworks |
|
BoundedHashMap< FrameworkID, process::Owned< FrameworkMetrics > > | completedFrameworkMetrics |
|
hashmap< SlaveID, Slave > | slaves |
|
ResourceQuantities | totalScalarQuantities |
|
RoleTree | roleTree |
|
hashset< SlaveID > | allocationCandidates |
|
Option< process::Future< Nothing > > | offerGeneration |
|
Option< hashset< std::string > > | whitelist |
|
process::Owned< Sorter > | roleSorter |
|
hashmap< std::string, process::Owned< Sorter > > | frameworkSorters |
|
const std::function< Sorter *()> | frameworkSorterFactory |
|