mesos::internal::protobuf Namespace Reference

Namespaces
	framework
	maintenance
	master
	slave

Classes
class	UnionValidator
class	WireFormatLite2

Functions
template<class ProtobufUnion >
Option< Error >	validateProtobufUnion (const ProtobufUnion &message)
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(), const Option< SlaveID > &slaveId=None(), const Option< ResourceProviderID > &resourceProviderId=None())
Operation	createOperation (const Offer::Operation &info, const OperationStatus &latestStatus, const Option< FrameworkID > &frameworkId, const Option< SlaveID > &slaveId, const Option< UUID > &operationUUID=None())
UpdateOperationStatusMessage	createUpdateOperationStatusMessage (const UUID &operationUUID, const OperationStatus &status, const Option< OperationStatus > &latestStatus=None(), const Option< FrameworkID > &frameworkId=None(), const Option< SlaveID > &slaveId=None())
UUID	createUUID (const Option< id::UUID > &uuid=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 >, UUID > &resourceVersions)
hashmap< Option< ResourceProviderID >, 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)
ContainerID	parseContainerId (const std::string &value)
Try< Resources >	getConsumedResources (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< 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(),
		const Option< SlaveID > &	slaveId = None(),
		const Option< ResourceProviderID > &	resourceProviderId = None()
	)

google::protobuf::RepeatedPtrField<ResourceVersionUUID> mesos::internal::protobuf::createResourceVersions

(

const hashmap< Option< ResourceProviderID >, 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 UUID &	operationUUID,
		const OperationStatus &	status,
		const Option< OperationStatus > &	latestStatus = None(),
		const Option< FrameworkID > &	frameworkId = None(),
		const Option< SlaveID > &	slaveId = None()
	)

UUID mesos::internal::protobuf::createUUID

(

const Option< id::UUID > &

uuid = 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

)

ContainerID mesos::internal::protobuf::parseContainerId

(

const std::string &

value

)

hashmap<Option<ResourceProviderID>, UUID> mesos::internal::protobuf::parseResourceVersions

(

const google::protobuf::RepeatedPtrField< ResourceVersionUUID > &

resourceVersionUUIDs

)

void mesos::internal::protobuf::stripAllocationInfo

(

Offer::Operation *

operation

)

template<class ProtobufUnion >

Option<Error> mesos::internal::protobuf::validateProtobufUnion

(

const ProtobufUnion &

message

)