Apache Mesos
Public Types | Public Member Functions | Public Attributes | List of all members
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
 
Try< Executor * > addExecutor (const ExecutorInfo &executorInfo)
 
ExecutorgetExecutor (const ExecutorID &executorId) const
 
ExecutorgetExecutor (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
 
Slaveslave
 
FrameworkInfo info
 
protobuf::framework::Capabilities capabilities
 
Option< process::UPIDpid
 
hashmap< ExecutorID, hashmap< TaskID, TaskInfo > > pendingTasks
 
hashmap< ExecutorID, process::SequencetaskLaunchSequences
 
std::vector< TaskGroupInfo > pendingTaskGroups
 
hashmap< ExecutorID, Executor * > executors
 
boost::circular_buffer< process::Owned< Executor > > completedExecutors
 

Member Enumeration Documentation

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

Try<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::vector<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
hashmap<ExecutorID, process::Sequence> mesos::internal::slave::Framework::taskLaunchSequences

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