mesos::internal::slave::Framework Class Reference

#include <slave.hpp>

Public Types
enum	State { RUNNING, TERMINATING }

Public Member Functions
	Framework (Slave *slave, const Flags &slaveFlags, const FrameworkInfo &info, const Option< process::UPID > &pid)
	~Framework ()
bool	idle () const
void	checkpointFramework () const
const FrameworkID	id () const
Executor *	addExecutor (const ExecutorInfo &executorInfo)
Executor *	getExecutor (const ExecutorID &executorId) const
Executor *	getExecutor (const TaskID &taskId) const
void	destroyExecutor (const ExecutorID &executorId)
void	recoverExecutor (const state::ExecutorState &state, bool recheckpointExecutor, const hashset< TaskID > &tasksToRecheckpoint)
void	addPendingTask (const ExecutorID &executorId, const TaskInfo &task)
void	addPendingTaskGroup (const ExecutorID &executorId, const TaskGroupInfo &taskGroup)
bool	hasTask (const TaskID &taskId) const
bool	isPending (const TaskID &taskId) const
Option< TaskGroupInfo >	getTaskGroupForPendingTask (const TaskID &taskId)
bool	removePendingTask (const TaskID &taskId)
Option< ExecutorID >	getExecutorIdForPendingTask (const TaskID &taskId) const
Resources	allocatedResources () const

Public Attributes
enum mesos::internal::slave::Framework::State	state
Slave *	slave
FrameworkInfo	info
protobuf::framework::Capabilities	capabilities
Option< process::UPID >	pid
hashmap< ExecutorID, hashmap < TaskID, TaskInfo > >	pendingTasks
std::list< TaskGroupInfo >	pendingTaskGroups
hashmap< ExecutorID, Executor * >	executors
boost::circular_buffer < process::Owned< Executor > >	completedExecutors

Member Enumeration Documentation

enum mesos::internal::slave::Framework::State

Enumerator
RUNNING
TERMINATING

Constructor & Destructor Documentation

mesos::internal::slave::Framework::Framework	(	Slave *	slave,
		const Flags &	slaveFlags,
		const FrameworkInfo &	info,
		const Option< process::UPID > &	pid
	)

mesos::internal::slave::Framework::~Framework

(

)

Member Function Documentation

Executor* mesos::internal::slave::Framework::addExecutor

(

const ExecutorInfo &

executorInfo

)

void mesos::internal::slave::Framework::addPendingTask	(	const ExecutorID &	executorId,
		const TaskInfo &	task
	)

void mesos::internal::slave::Framework::addPendingTaskGroup	(	const ExecutorID &	executorId,
		const TaskGroupInfo &	taskGroup
	)

Resources mesos::internal::slave::Framework::allocatedResources

(

)

const

void mesos::internal::slave::Framework::checkpointFramework

(

)

const

void mesos::internal::slave::Framework::destroyExecutor

(

const ExecutorID &

executorId

)

Executor* mesos::internal::slave::Framework::getExecutor

(

const ExecutorID &

executorId

)

const

Executor* mesos::internal::slave::Framework::getExecutor

(

const TaskID &

taskId

)

const

Option<ExecutorID> mesos::internal::slave::Framework::getExecutorIdForPendingTask

(

const TaskID &

taskId

)

const

Option<TaskGroupInfo> mesos::internal::slave::Framework::getTaskGroupForPendingTask

(

const TaskID &

taskId

)

bool mesos::internal::slave::Framework::hasTask

(

const TaskID &

taskId

)

const

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

inline

bool mesos::internal::slave::Framework::idle

(

)

const

bool mesos::internal::slave::Framework::isPending

(

const TaskID &

taskId

)

const

void mesos::internal::slave::Framework::recoverExecutor	(	const state::ExecutorState &	state,
		bool	recheckpointExecutor,
		const hashset< TaskID > &	tasksToRecheckpoint
	)

bool mesos::internal::slave::Framework::removePendingTask

(

const TaskID &

taskId

)

Member Data Documentation

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

boost::circular_buffer<process::Owned<Executor> > mesos::internal::slave::Framework::completedExecutors

hashmap<ExecutorID, Executor*> mesos::internal::slave::Framework::executors

FrameworkInfo mesos::internal::slave::Framework::info

std::list<TaskGroupInfo> mesos::internal::slave::Framework::pendingTaskGroups

hashmap<ExecutorID, hashmap<TaskID, TaskInfo> > mesos::internal::slave::Framework::pendingTasks

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

Slave* mesos::internal::slave::Framework::slave

enum mesos::internal::slave::Framework::State mesos::internal::slave::Framework::state

---

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

• src/slave/slave.hpp