Apache Mesos
Namespaces | Functions
mesos::internal::protobuf Namespace Reference

Namespaces

 framework
 
 maintenance
 
 master
 
 slave
 

Functions

bool frameworkHasCapability (const FrameworkInfo &framework, FrameworkInfo::Capability::Type capability)
 
bool isTerminalState (const TaskState &state)
 
StatusUpdate createStatusUpdate (const FrameworkID &frameworkId, const Option< SlaveID > &slaveId, const TaskID &taskId, const TaskState &state, const TaskStatus::Source &source, const Option< id::UUID > &uuid, const std::string &message="", const Option< TaskStatus::Reason > &reason=None(), const Option< ExecutorID > &executorId=None(), const Option< bool > &healthy=None(), const Option< CheckStatusInfo > &checkStatus=None(), const Option< Labels > &labels=None(), const Option< ContainerStatus > &containerStatus=None(), const Option< TimeInfo > &unreachableTime=None(), const Option< Resources > &limitedResources=None())
 
StatusUpdate createStatusUpdate (const FrameworkID &frameworkId, const TaskStatus &status, const Option< SlaveID > &slaveId)
 
TaskStatus createTaskStatus (const TaskID &taskId, const TaskState &state, const id::UUID &uuid, double timestamp)
 
TaskStatus createTaskStatus (TaskStatus status, const id::UUID &uuid, double timestamp, const Option< TaskState > &state=None(), const Option< std::string > &message=None(), const Option< TaskStatus::Source > &source=None(), const Option< TaskStatus::Reason > &reason=None(), const Option< std::string > &data=None(), const Option< bool > &healthy=None(), const Option< CheckStatusInfo > &checkStatus=None(), const Option< Labels > &labels=None(), const Option< ContainerStatus > &containerStatus=None(), const Option< TimeInfo > &unreachableTime=None())
 
Task createTask (const TaskInfo &task, const TaskState &state, const FrameworkID &frameworkId)
 
Option< bool > getTaskHealth (const Task &task)
 
Option< CheckStatusInfo > getTaskCheckStatus (const Task &task)
 
Option< ContainerStatus > getTaskContainerStatus (const Task &task)
 
bool isTerminalState (const OperationState &state)
 
OperationStatus createOperationStatus (const OperationState &state, const Option< OperationID > &operationId=None(), const Option< std::string > &message=None(), const Option< Resources > &convertedResources=None(), const Option< id::UUID > &statusUUID=None())
 
Operation createOperation (const Offer::Operation &info, const OperationStatus &latestStatus, const Option< FrameworkID > &frameworkId, const Option< SlaveID > &slaveId, const Option< id::UUID > &operationUUID=None())
 
UpdateOperationStatusMessage createUpdateOperationStatusMessage (const id::UUID &operationUUID, const OperationStatus &status, const Option< OperationStatus > &latestStatus=None(), const Option< FrameworkID > &frameworkId=None(), const Option< SlaveID > &slaveId=None())
 
MasterInfo createMasterInfo (const process::UPID &pid)
 
Label createLabel (const std::string &key, const Option< std::string > &value=None())
 
Labels convertStringMapToLabels (const google::protobuf::Map< std::string, std::string > &map)
 
Try< google::protobuf::Map
< std::string, std::string > > 
convertLabelsToStringMap (const Labels &labels)
 
void injectAllocationInfo (Offer::Operation *operation, const Resource::AllocationInfo &allocationInfo)
 
void stripAllocationInfo (Offer::Operation *operation)
 
bool isSpeculativeOperation (const Offer::Operation &operation)
 
google::protobuf::RepeatedPtrField
< ResourceVersionUUID > 
createResourceVersions (const hashmap< Option< ResourceProviderID >, id::UUID > &resourceVersions)
 
hashmap< Option
< ResourceProviderID >
, id::UUID
parseResourceVersions (const google::protobuf::RepeatedPtrField< ResourceVersionUUID > &resourceVersionUUIDs)
 
TimeInfo getCurrentTime ()
 
FileInfo createFileInfo (const std::string &path, const struct stat &s)
 
ContainerID getRootContainerId (const ContainerID &containerId)
 
Try< ResourcesgetConsumedResources (const Offer::Operation &operation)
 

Function Documentation

Try<google::protobuf::Map<std::string, std::string> > mesos::internal::protobuf::convertLabelsToStringMap ( const Labels &  labels)
Labels mesos::internal::protobuf::convertStringMapToLabels ( const google::protobuf::Map< std::string, std::string > &  map)
FileInfo mesos::internal::protobuf::createFileInfo ( const std::string &  path,
const struct stat &  s 
)
Label mesos::internal::protobuf::createLabel ( const std::string &  key,
const Option< std::string > &  value = None() 
)
MasterInfo mesos::internal::protobuf::createMasterInfo ( const process::UPID pid)
Operation mesos::internal::protobuf::createOperation ( const Offer::Operation &  info,
const OperationStatus &  latestStatus,
const Option< FrameworkID > &  frameworkId,
const Option< SlaveID > &  slaveId,
const Option< id::UUID > &  operationUUID = None() 
)
OperationStatus mesos::internal::protobuf::createOperationStatus ( const OperationState &  state,
const Option< OperationID > &  operationId = None(),
const Option< std::string > &  message = None(),
const Option< Resources > &  convertedResources = None(),
const Option< id::UUID > &  statusUUID = None() 
)
google::protobuf::RepeatedPtrField<ResourceVersionUUID> mesos::internal::protobuf::createResourceVersions ( const hashmap< Option< ResourceProviderID >, id::UUID > &  resourceVersions)
StatusUpdate mesos::internal::protobuf::createStatusUpdate ( const FrameworkID &  frameworkId,
const Option< SlaveID > &  slaveId,
const TaskID &  taskId,
const TaskState &  state,
const TaskStatus::Source &  source,
const Option< id::UUID > &  uuid,
const std::string &  message = "",
const Option< TaskStatus::Reason > &  reason = None(),
const Option< ExecutorID > &  executorId = None(),
const Option< bool > &  healthy = None(),
const Option< CheckStatusInfo > &  checkStatus = None(),
const Option< Labels > &  labels = None(),
const Option< ContainerStatus > &  containerStatus = None(),
const Option< TimeInfo > &  unreachableTime = None(),
const Option< Resources > &  limitedResources = None() 
)
StatusUpdate mesos::internal::protobuf::createStatusUpdate ( const FrameworkID &  frameworkId,
const TaskStatus &  status,
const Option< SlaveID > &  slaveId 
)
Task mesos::internal::protobuf::createTask ( const TaskInfo &  task,
const TaskState &  state,
const FrameworkID &  frameworkId 
)
TaskStatus mesos::internal::protobuf::createTaskStatus ( const TaskID &  taskId,
const TaskState &  state,
const id::UUID uuid,
double  timestamp 
)
TaskStatus mesos::internal::protobuf::createTaskStatus ( TaskStatus  status,
const id::UUID uuid,
double  timestamp,
const Option< TaskState > &  state = None(),
const Option< std::string > &  message = None(),
const Option< TaskStatus::Source > &  source = None(),
const Option< TaskStatus::Reason > &  reason = None(),
const Option< std::string > &  data = None(),
const Option< bool > &  healthy = None(),
const Option< CheckStatusInfo > &  checkStatus = None(),
const Option< Labels > &  labels = None(),
const Option< ContainerStatus > &  containerStatus = None(),
const Option< TimeInfo > &  unreachableTime = None() 
)
UpdateOperationStatusMessage mesos::internal::protobuf::createUpdateOperationStatusMessage ( const id::UUID operationUUID,
const OperationStatus &  status,
const Option< OperationStatus > &  latestStatus = None(),
const Option< FrameworkID > &  frameworkId = None(),
const Option< SlaveID > &  slaveId = None() 
)
bool mesos::internal::protobuf::frameworkHasCapability ( const FrameworkInfo &  framework,
FrameworkInfo::Capability::Type  capability 
)
Try<Resources> mesos::internal::protobuf::getConsumedResources ( const Offer::Operation &  operation)
TimeInfo mesos::internal::protobuf::getCurrentTime ( )
ContainerID mesos::internal::protobuf::getRootContainerId ( const ContainerID &  containerId)
Option<CheckStatusInfo> mesos::internal::protobuf::getTaskCheckStatus ( const Task &  task)
Option<ContainerStatus> mesos::internal::protobuf::getTaskContainerStatus ( const Task &  task)
Option<bool> mesos::internal::protobuf::getTaskHealth ( const Task &  task)
void mesos::internal::protobuf::injectAllocationInfo ( Offer::Operation *  operation,
const Resource::AllocationInfo &  allocationInfo 
)
bool mesos::internal::protobuf::isSpeculativeOperation ( const Offer::Operation &  operation)
bool mesos::internal::protobuf::isTerminalState ( const TaskState &  state)
bool mesos::internal::protobuf::isTerminalState ( const OperationState &  state)
hashmap<Option<ResourceProviderID>, id::UUID> mesos::internal::protobuf::parseResourceVersions ( const google::protobuf::RepeatedPtrField< ResourceVersionUUID > &  resourceVersionUUIDs)
void mesos::internal::protobuf::stripAllocationInfo ( Offer::Operation *  operation)