mesos::internal::master::allocator::MesosAllocatorProcess Class Reference

#include <allocator.hpp>

Inheritance diagram for mesos::internal::master::allocator::MesosAllocatorProcess:

Public Member Functions
	MesosAllocatorProcess ()
	~MesosAllocatorProcess () override
virtual 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)=0
virtual void	recover (const int expectedAgentCount, const hashmap< std::string, Quota > &quotas)=0
virtual void	addFramework (const FrameworkID &frameworkId, const FrameworkInfo &frameworkInfo, const hashmap< SlaveID, Resources > &used, bool active,::mesos::allocator::FrameworkOptions &&options)=0
virtual void	removeFramework (const FrameworkID &frameworkId)=0
virtual void	activateFramework (const FrameworkID &frameworkId)=0
virtual void	deactivateFramework (const FrameworkID &frameworkId)=0
virtual void	updateFramework (const FrameworkID &frameworkId, const FrameworkInfo &frameworkInfo,::mesos::allocator::FrameworkOptions &&options)=0
virtual 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)=0
virtual void	removeSlave (const SlaveID &slaveId)=0
virtual void	updateSlave (const SlaveID &slave, const SlaveInfo &slaveInfo, const Option< Resources > &total=None(), const Option< std::vector< SlaveInfo::Capability >> &capabilities=None())=0
virtual void	addResourceProvider (const SlaveID &slave, const Resources &total, const hashmap< FrameworkID, Resources > &used)=0
virtual void	activateSlave (const SlaveID &slaveId)=0
virtual void	deactivateSlave (const SlaveID &slaveId)=0
virtual void	updateWhitelist (const Option< hashset< std::string >> &whitelist)=0
virtual void	requestResources (const FrameworkID &frameworkId, const std::vector< Request > &requests)=0
virtual void	updateAllocation (const FrameworkID &frameworkId, const SlaveID &slaveId, const Resources &offeredResources, const std::vector< ResourceConversion > &conversions)=0
virtual process::Future< Nothing >	updateAvailable (const SlaveID &slaveId, const std::vector< Offer::Operation > &operations)=0
virtual void	updateUnavailability (const SlaveID &slaveId, const Option< Unavailability > &unavailability)=0
virtual void	updateInverseOffer (const SlaveID &slaveId, const FrameworkID &frameworkId, const Option< UnavailableResources > &unavailableResources, const Option< mesos::allocator::InverseOfferStatus > &status, const Option< Filters > &filters=None())=0
virtual process::Future< hashmap< SlaveID, hashmap< FrameworkID, mesos::allocator::InverseOfferStatus > > >	getInverseOfferStatuses ()=0
virtual void	transitionOfferedToAllocated (const SlaveID &slaveId, const Resources &resources)=0
virtual void	recoverResources (const FrameworkID &frameworkId, const SlaveID &slaveId, const Resources &resources, const Option< Filters > &filters, bool isAllocated)=0
virtual void	suppressOffers (const FrameworkID &frameworkId, const std::set< std::string > &roles)=0
virtual void	reviveOffers (const FrameworkID &frameworkId, const std::set< std::string > &roles)=0
virtual void	updateQuota (const std::string &role, const Quota &quota)=0
virtual void	updateWeights (const std::vector< WeightInfo > &weightInfos)=0
virtual void	pause ()=0
virtual void	resume ()=0
Public Member Functions inherited from process::Process< MesosAllocatorProcess >
	~Process () override
PID< MesosAllocatorProcess >	self () const
	Returns the PID of the process. More...
Public Member Functions inherited from process::ProcessBase
	ProcessBase (const std::string &id="")
	~ProcessBase () override
const UPID &	self () const
Public Member Functions inherited from process::EventConsumer
virtual	~EventConsumer ()

Additional Inherited Members
Protected Types inherited from process::Process< MesosAllocatorProcess >
typedef MesosAllocatorProcess	Self
typedef MesosAllocatorProcess	This
Protected Types inherited from process::ProcessBase
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...
Protected Member Functions inherited from process::ProcessBase
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...

Constructor & Destructor Documentation

mesos::internal::master::allocator::MesosAllocatorProcess::MesosAllocatorProcess ( )

inline

mesos::internal::master::allocator::MesosAllocatorProcess::~MesosAllocatorProcess ( )

inlineoverride

Member Function Documentation

virtual void mesos::internal::master::allocator::MesosAllocatorProcess::activateFramework ( const FrameworkID &  frameworkId )

pure virtual

Implemented in mesos::internal::master::allocator::internal::HierarchicalAllocatorProcess.

virtual void mesos::internal::master::allocator::MesosAllocatorProcess::activateSlave ( const SlaveID &  slaveId )

pure virtual

Implemented in mesos::internal::master::allocator::internal::HierarchicalAllocatorProcess.

virtual void mesos::internal::master::allocator::MesosAllocatorProcess::addFramework ( const FrameworkID &  frameworkId, const FrameworkInfo &  frameworkInfo, const hashmap< SlaveID, Resources > &  used, bool  active, ::mesos::allocator::FrameworkOptions &&  options  )

pure virtual

Implemented in mesos::internal::master::allocator::internal::HierarchicalAllocatorProcess.

virtual void mesos::internal::master::allocator::MesosAllocatorProcess::addResourceProvider ( const SlaveID &  slave, const Resources &  total, const hashmap< FrameworkID, Resources > &  used  )

pure virtual

Implemented in mesos::internal::master::allocator::internal::HierarchicalAllocatorProcess.

virtual void mesos::internal::master::allocator::MesosAllocatorProcess::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  )

pure virtual

Implemented in mesos::internal::master::allocator::internal::HierarchicalAllocatorProcess.

virtual void mesos::internal::master::allocator::MesosAllocatorProcess::deactivateFramework ( const FrameworkID &  frameworkId )

pure virtual

Implemented in mesos::internal::master::allocator::internal::HierarchicalAllocatorProcess.

virtual void mesos::internal::master::allocator::MesosAllocatorProcess::deactivateSlave ( const SlaveID &  slaveId )

pure virtual

Implemented in mesos::internal::master::allocator::internal::HierarchicalAllocatorProcess.

virtual process::Future< hashmap<SlaveID, hashmap<FrameworkID, mesos::allocator::InverseOfferStatus> > > mesos::internal::master::allocator::MesosAllocatorProcess::getInverseOfferStatuses ( )

pure virtual

Implemented in mesos::internal::master::allocator::internal::HierarchicalAllocatorProcess.

virtual void mesos::internal::master::allocator::MesosAllocatorProcess::initialize ( const mesos::allocator::Options &  options )

pure virtual

Implemented in mesos::internal::master::allocator::internal::HierarchicalAllocatorProcess.

virtual void mesos::internal::master::allocator::MesosAllocatorProcess::pause ( )

pure virtual

Implemented in mesos::internal::master::allocator::internal::HierarchicalAllocatorProcess.

virtual void mesos::internal::master::allocator::MesosAllocatorProcess::recover ( const int  expectedAgentCount, const hashmap< std::string, Quota > &  quotas  )

pure virtual

Implemented in mesos::internal::master::allocator::internal::HierarchicalAllocatorProcess.

virtual void mesos::internal::master::allocator::MesosAllocatorProcess::recoverResources ( const FrameworkID &  frameworkId, const SlaveID &  slaveId, const Resources &  resources, const Option< Filters > &  filters, bool  isAllocated  )

pure virtual

Implemented in mesos::internal::master::allocator::internal::HierarchicalAllocatorProcess.

virtual void mesos::internal::master::allocator::MesosAllocatorProcess::removeFramework ( const FrameworkID &  frameworkId )

pure virtual

Implemented in mesos::internal::master::allocator::internal::HierarchicalAllocatorProcess.

virtual void mesos::internal::master::allocator::MesosAllocatorProcess::removeSlave ( const SlaveID &  slaveId )

pure virtual

Implemented in mesos::internal::master::allocator::internal::HierarchicalAllocatorProcess.

virtual void mesos::internal::master::allocator::MesosAllocatorProcess::requestResources ( const FrameworkID &  frameworkId, const std::vector< Request > &  requests  )

pure virtual

Implemented in mesos::internal::master::allocator::internal::HierarchicalAllocatorProcess.

virtual void mesos::internal::master::allocator::MesosAllocatorProcess::resume ( )

pure virtual

Implemented in mesos::internal::master::allocator::internal::HierarchicalAllocatorProcess.

virtual void mesos::internal::master::allocator::MesosAllocatorProcess::reviveOffers ( const FrameworkID &  frameworkId, const std::set< std::string > &  roles  )

pure virtual

Implemented in mesos::internal::master::allocator::internal::HierarchicalAllocatorProcess.

virtual void mesos::internal::master::allocator::MesosAllocatorProcess::suppressOffers ( const FrameworkID &  frameworkId, const std::set< std::string > &  roles  )

pure virtual

Implemented in mesos::internal::master::allocator::internal::HierarchicalAllocatorProcess.

virtual void mesos::internal::master::allocator::MesosAllocatorProcess::transitionOfferedToAllocated ( const SlaveID &  slaveId, const Resources &  resources  )

pure virtual

Implemented in mesos::internal::master::allocator::internal::HierarchicalAllocatorProcess.

virtual void mesos::internal::master::allocator::MesosAllocatorProcess::updateAllocation ( const FrameworkID &  frameworkId, const SlaveID &  slaveId, const Resources &  offeredResources, const std::vector< ResourceConversion > &  conversions  )

pure virtual

Implemented in mesos::internal::master::allocator::internal::HierarchicalAllocatorProcess.

virtual process::Future<Nothing> mesos::internal::master::allocator::MesosAllocatorProcess::updateAvailable ( const SlaveID &  slaveId, const std::vector< Offer::Operation > &  operations  )

pure virtual

Implemented in mesos::internal::master::allocator::internal::HierarchicalAllocatorProcess.

virtual void mesos::internal::master::allocator::MesosAllocatorProcess::updateFramework ( const FrameworkID &  frameworkId, const FrameworkInfo &  frameworkInfo, ::mesos::allocator::FrameworkOptions &&  options  )

pure virtual

Implemented in mesos::internal::master::allocator::internal::HierarchicalAllocatorProcess.

virtual void mesos::internal::master::allocator::MesosAllocatorProcess::updateInverseOffer ( const SlaveID &  slaveId, const FrameworkID &  frameworkId, const Option< UnavailableResources > &  unavailableResources, const Option< mesos::allocator::InverseOfferStatus > &  status, const Option< Filters > &  filters = None()  )

pure virtual

Implemented in mesos::internal::master::allocator::internal::HierarchicalAllocatorProcess.

virtual void mesos::internal::master::allocator::MesosAllocatorProcess::updateQuota ( const std::string &  role, const Quota &  quota  )

pure virtual

Implemented in mesos::internal::master::allocator::internal::HierarchicalAllocatorProcess.

virtual void mesos::internal::master::allocator::MesosAllocatorProcess::updateSlave ( const SlaveID &  slave, const SlaveInfo &  slaveInfo, const Option< Resources > &  total = None(), const Option< std::vector< SlaveInfo::Capability >> &  capabilities = None()  )

pure virtual

Implemented in mesos::internal::master::allocator::internal::HierarchicalAllocatorProcess.

virtual void mesos::internal::master::allocator::MesosAllocatorProcess::updateUnavailability ( const SlaveID &  slaveId, const Option< Unavailability > &  unavailability  )

pure virtual

Implemented in mesos::internal::master::allocator::internal::HierarchicalAllocatorProcess.

virtual void mesos::internal::master::allocator::MesosAllocatorProcess::updateWeights ( const std::vector< WeightInfo > &  weightInfos )

pure virtual

Implemented in mesos::internal::master::allocator::internal::HierarchicalAllocatorProcess.

virtual void mesos::internal::master::allocator::MesosAllocatorProcess::updateWhitelist ( const Option< hashset< std::string >> &  whitelist )

pure virtual

Implemented in mesos::internal::master::allocator::internal::HierarchicalAllocatorProcess.

---

The documentation for this class was generated from the following file:

• src/master/allocator/mesos/allocator.hpp