#include <master.hpp>

Public Types
enum	State { RECOVERED, DISCONNECTED, INACTIVE, ACTIVE }

Public Member Functions
	Framework (Master *const master, const Flags &masterFlags, const FrameworkInfo &info, const process::UPID &_pid, const process::Time &time=process::Clock::now())

	Framework (Master *const master, const Flags &masterFlags, const FrameworkInfo &info, const HttpConnection &_http, const process::Time &time=process::Clock::now())

	Framework (Master *const master, const Flags &masterFlags, const FrameworkInfo &info)

	~Framework ()

Task *	getTask (const TaskID &taskId)

void	addTask (Task *task)

void	recoverResources (Task *task)

template<typename Message >
void	send (const Message &message)

void	addCompletedTask (Task &&task)

void	addUnreachableTask (const Task &task)

void	removeTask (Task *task, bool unreachable)

void	addOffer (Offer *offer)

void	removeOffer (Offer *offer)

void	addInverseOffer (InverseOffer *inverseOffer)

void	removeInverseOffer (InverseOffer *inverseOffer)

bool	hasExecutor (const SlaveID &slaveId, const ExecutorID &executorId)

void	addExecutor (const SlaveID &slaveId, const ExecutorInfo &executorInfo)

void	removeExecutor (const SlaveID &slaveId, const ExecutorID &executorId)

void	addOperation (Operation *operation)

void	recoverResources (Operation *operation)

void	removeOperation (Operation *operation)

const FrameworkID	id () const

void	update (const FrameworkInfo &newInfo)

void	updateConnection (const process::UPID &newPid)

void	updateConnection (const HttpConnection &newHttp)

void	closeHttpConnection ()

void	heartbeat ()

bool	active () const

bool	connected () const

bool	recovered () const

bool	isTrackedUnderRole (const std::string &role) const

void	trackUnderRole (const std::string &role)

void	untrackUnderRole (const std::string &role)

Public Attributes
Master *const	master

FrameworkInfo	info

std::set< std::string >	roles

protobuf::framework::Capabilities	capabilities

Option< HttpConnection >	http

Option< process::UPID >	pid

State	state

process::Time	registeredTime

process::Time	reregisteredTime

process::Time	unregisteredTime

hashmap< TaskID, TaskInfo >	pendingTasks

hashmap< TaskID, Task * >	tasks

boost::circular_buffer < process::Owned< Task > >	completedTasks

BoundedHashMap< TaskID, process::Owned< Task > >	unreachableTasks

hashset< Offer * >	offers

hashset< InverseOffer * >	inverseOffers

hashmap< SlaveID, hashmap < ExecutorID, ExecutorInfo > >	executors

hashmap< id::UUID, Operation * >	operations

hashmap< OperationID, id::UUID >	operationUUIDs

Resources	totalUsedResources

hashmap< SlaveID, Resources >	usedResources

Resources	totalOfferedResources

hashmap< SlaveID, Resources >	offeredResources

Option< process::Owned < Heartbeater < scheduler::Event, v1::scheduler::Event > > >	heartbeater

Member Enumeration Documentation

enum mesos::internal::master::Framework::State

Enumerator
RECOVERED
DISCONNECTED
INACTIVE
ACTIVE

Constructor & Destructor Documentation

mesos::internal::master::Framework::Framework	(	Master *const	master,
		const Flags &	masterFlags,
		const FrameworkInfo &	info,
		const process::UPID &	_pid,
		const process::Time &	time = `process::Clock::now()`
	)

inline

mesos::internal::master::Framework::Framework	(	Master *const	master,
		const Flags &	masterFlags,
		const FrameworkInfo &	info,
		const HttpConnection &	_http,
		const process::Time &	time = `process::Clock::now()`
	)

inline

mesos::internal::master::Framework::Framework	(	Master *const	master,
		const Flags &	masterFlags,
		const FrameworkInfo &	info
	)

inline

mesos::internal::master::Framework::~Framework ( )

inline

Member Function Documentation

bool mesos::internal::master::Framework::active ( ) const

inline

void mesos::internal::master::Framework::addCompletedTask ( Task && task )

inline

void mesos::internal::master::Framework::addExecutor	(	const SlaveID &	slaveId,
		const ExecutorInfo &	executorInfo
	)

inline

void mesos::internal::master::Framework::addInverseOffer ( InverseOffer * inverseOffer )

inline

void mesos::internal::master::Framework::addOffer ( Offer * offer )

inline

void mesos::internal::master::Framework::addOperation ( Operation * operation )

inline

void mesos::internal::master::Framework::addTask ( Task * task )

inline

void mesos::internal::master::Framework::addUnreachableTask ( const Task & task )

inline

void mesos::internal::master::Framework::closeHttpConnection ( )

inline

bool mesos::internal::master::Framework::connected ( ) const

inline

Task* mesos::internal::master::Framework::getTask ( const TaskID & taskId )

inline

bool mesos::internal::master::Framework::hasExecutor	(	const SlaveID &	slaveId,
		const ExecutorID &	executorId
	)

inline

void mesos::internal::master::Framework::heartbeat ( )

inline

const FrameworkID mesos::internal::master::Framework::id ( ) const

inline

bool mesos::internal::master::Framework::isTrackedUnderRole ( const std::string & role ) const

bool mesos::internal::master::Framework::recovered ( ) const

inline

void mesos::internal::master::Framework::recoverResources ( Task * task )

inline

void mesos::internal::master::Framework::recoverResources ( Operation * operation )

inline

void mesos::internal::master::Framework::removeExecutor	(	const SlaveID &	slaveId,
		const ExecutorID &	executorId
	)

inline

void mesos::internal::master::Framework::removeInverseOffer ( InverseOffer * inverseOffer )

inline

void mesos::internal::master::Framework::removeOffer ( Offer * offer )

inline

void mesos::internal::master::Framework::removeOperation ( Operation * operation )

inline

void mesos::internal::master::Framework::removeTask	(	Task *	task,
		bool	unreachable
	)

inline

template<typename Message >

void mesos::internal::master::Framework::send ( const Message & message )

inline

void mesos::internal::master::Framework::trackUnderRole ( const std::string & role )

void mesos::internal::master::Framework::untrackUnderRole ( const std::string & role )

void mesos::internal::master::Framework::update ( const FrameworkInfo & newInfo )

inline

void mesos::internal::master::Framework::updateConnection ( const process::UPID & newPid )

inline

void mesos::internal::master::Framework::updateConnection ( const HttpConnection & newHttp )

inline

Member Data Documentation

protobuf::framework::Capabilities mesos::internal::master::Framework::capabilities

boost::circular_buffer<process::Owned<Task> > mesos::internal::master::Framework::completedTasks

hashmap<SlaveID, hashmap<ExecutorID, ExecutorInfo> > mesos::internal::master::Framework::executors

Option<process::Owned<Heartbeater<scheduler::Event, v1::scheduler::Event> > > mesos::internal::master::Framework::heartbeater

Option<HttpConnection> mesos::internal::master::Framework::http

FrameworkInfo mesos::internal::master::Framework::info

hashset<InverseOffer*> mesos::internal::master::Framework::inverseOffers

Master* const mesos::internal::master::Framework::master

hashmap<SlaveID, Resources> mesos::internal::master::Framework::offeredResources

hashset<Offer*> mesos::internal::master::Framework::offers

hashmap<id::UUID, Operation*> mesos::internal::master::Framework::operations

hashmap<OperationID, id::UUID> mesos::internal::master::Framework::operationUUIDs

hashmap<TaskID, TaskInfo> mesos::internal::master::Framework::pendingTasks

Option<process::UPID> mesos::internal::master::Framework::pid

process::Time mesos::internal::master::Framework::registeredTime

process::Time mesos::internal::master::Framework::reregisteredTime

std::set<std::string> mesos::internal::master::Framework::roles

State mesos::internal::master::Framework::state

hashmap<TaskID, Task*> mesos::internal::master::Framework::tasks

Resources mesos::internal::master::Framework::totalOfferedResources

Resources mesos::internal::master::Framework::totalUsedResources

BoundedHashMap<TaskID, process::Owned<Task> > mesos::internal::master::Framework::unreachableTasks

process::Time mesos::internal::master::Framework::unregisteredTime

hashmap<SlaveID, Resources> mesos::internal::master::Framework::usedResources

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

src/master/master.hpp

Public Types

Public Member Functions

Public Attributes

Member Enumeration Documentation

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation