|
| | 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 () |
| |
|
| 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...
|
| |