Apache Mesos
|
#include <initializer_list>
#include <ostream>
#include <set>
#include <string>
#include <sys/stat.h>
#include <google/protobuf/map.h>
#include <mesos/mesos.hpp>
#include <mesos/maintenance/maintenance.hpp>
#include <mesos/master/master.hpp>
#include <mesos/slave/isolator.hpp>
#include <process/time.hpp>
#include <stout/duration.hpp>
#include <stout/ip.hpp>
#include <stout/none.hpp>
#include <stout/option.hpp>
#include <stout/try.hpp>
#include <stout/uuid.hpp>
#include "master/registry.hpp"
#include "messages/messages.hpp"
Go to the source code of this file.
Functions | |
template<class ProtobufUnion > | |
Option< Error > | mesos::internal::protobuf::validateProtobufUnion (const ProtobufUnion &message) |
bool | mesos::internal::protobuf::frameworkHasCapability (const FrameworkInfo &framework, FrameworkInfo::Capability::Type capability) |
bool | mesos::internal::protobuf::isTerminalState (const TaskState &state) |
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) |
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()) |
Task | mesos::internal::protobuf::createTask (const TaskInfo &task, const TaskState &state, const FrameworkID &frameworkId) |
Option< bool > | mesos::internal::protobuf::getTaskHealth (const Task &task) |
Option< CheckStatusInfo > | mesos::internal::protobuf::getTaskCheckStatus (const Task &task) |
Option< ContainerStatus > | mesos::internal::protobuf::getTaskContainerStatus (const Task &task) |
bool | mesos::internal::protobuf::isTerminalState (const OperationState &state) |
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()) |
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()) |
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()) |
MasterInfo | mesos::internal::protobuf::createMasterInfo (const process::UPID &pid) |
Label | mesos::internal::protobuf::createLabel (const std::string &key, const Option< std::string > &value=None()) |
Labels | mesos::internal::protobuf::convertStringMapToLabels (const google::protobuf::Map< std::string, std::string > &map) |
Try< google::protobuf::Map< std::string, std::string > > | mesos::internal::protobuf::convertLabelsToStringMap (const Labels &labels) |
void | mesos::internal::protobuf::injectAllocationInfo (Offer::Operation *operation, const Resource::AllocationInfo &allocationInfo) |
void | mesos::internal::protobuf::stripAllocationInfo (Offer::Operation *operation) |
bool | mesos::internal::protobuf::isSpeculativeOperation (const Offer::Operation &operation) |
google::protobuf::RepeatedPtrField< ResourceVersionUUID > | mesos::internal::protobuf::createResourceVersions (const hashmap< Option< ResourceProviderID >, UUID > &resourceVersions) |
hashmap< Option< ResourceProviderID >, UUID > | mesos::internal::protobuf::parseResourceVersions (const google::protobuf::RepeatedPtrField< ResourceVersionUUID > &resourceVersionUUIDs) |
TimeInfo | mesos::internal::protobuf::getCurrentTime () |
FileInfo | mesos::internal::protobuf::createFileInfo (const std::string &path, const struct stat &s) |
ContainerID | mesos::internal::protobuf::getRootContainerId (const ContainerID &containerId) |
ContainerID | mesos::internal::protobuf::parseContainerId (const std::string &value) |
Try< Resources > | mesos::internal::protobuf::getConsumedResources (const Offer::Operation &operation) |
bool | mesos::internal::protobuf::slave::operator== (const Capabilities &left, const Capabilities &right) |
bool | mesos::internal::protobuf::slave::operator!= (const Capabilities &left, const Capabilities &right) |
std::ostream & | mesos::internal::protobuf::slave::operator<< (std::ostream &stream, const Capabilities &c) |
mesos::slave::ContainerLimitation | mesos::internal::protobuf::slave::createContainerLimitation (const Resources &resources, const std::string &message, const TaskStatus::Reason &reason) |
mesos::slave::ContainerState | mesos::internal::protobuf::slave::createContainerState (const Option< ExecutorInfo > &executorInfo, const Option< ContainerInfo > &containerInfo, const ContainerID &id, pid_t pid, const std::string &directory) |
mesos::slave::ContainerMountInfo | mesos::internal::protobuf::slave::createContainerMount (const std::string &source, const std::string &target, unsigned long flags) |
mesos::slave::ContainerMountInfo | mesos::internal::protobuf::slave::createContainerMount (const std::string &source, const std::string &target, const std::string &type, unsigned long flags) |
mesos::slave::ContainerMountInfo | mesos::internal::protobuf::slave::createContainerMount (const std::string &source, const std::string &target, const std::string &type, const std::string &options, unsigned long flags) |
mesos::slave::ContainerFileOperation | mesos::internal::protobuf::slave::containerSymlinkOperation (const std::string &source, const std::string &target) |
mesos::slave::ContainerFileOperation | mesos::internal::protobuf::slave::containerRenameOperation (const std::string &source, const std::string &target) |
mesos::slave::ContainerFileOperation | mesos::internal::protobuf::slave::containerMkdirOperation (const std::string &target, const bool recursive) |
mesos::slave::ContainerFileOperation | mesos::internal::protobuf::slave::containerMountOperation (const mesos::slave::ContainerMountInfo &mnt) |
Unavailability | mesos::internal::protobuf::maintenance::createUnavailability (const process::Time &start, const Option< Duration > &duration=None()) |
Helper for constructing an unavailability from a Time and Duration . More... | |
google::protobuf::RepeatedPtrField< MachineID > | mesos::internal::protobuf::maintenance::createMachineList (std::initializer_list< MachineID > ids) |
Helper for constructing a list of MachineID . More... | |
mesos::maintenance::Window | mesos::internal::protobuf::maintenance::createWindow (std::initializer_list< MachineID > ids, const Unavailability &unavailability) |
Helper for constructing a maintenance Window . More... | |
mesos::maintenance::Schedule | mesos::internal::protobuf::maintenance::createSchedule (std::initializer_list< mesos::maintenance::Window > windows) |
Helper for constructing a maintenance Schedule . More... | |
void | mesos::internal::protobuf::master::addMinimumCapability (google::protobuf::RepeatedPtrField< Registry::MinimumCapability > *capabilities, const MasterInfo::Capability::Type &capability) |
void | mesos::internal::protobuf::master::removeMinimumCapability (google::protobuf::RepeatedPtrField< Registry::MinimumCapability > *capabilities, const MasterInfo::Capability::Type &capability) |
mesos::master::Event | mesos::internal::protobuf::master::event::createTaskUpdated (const Task &task, const TaskState &state, const TaskStatus &status) |
mesos::master::Event | mesos::internal::protobuf::master::event::createTaskAdded (const Task &task) |
mesos::master::Event | mesos::internal::protobuf::master::event::createFrameworkAdded (const mesos::internal::master::Framework &framework) |
mesos::master::Event | mesos::internal::protobuf::master::event::createFrameworkUpdated (const mesos::internal::master::Framework &framework) |
mesos::master::Event | mesos::internal::protobuf::master::event::createFrameworkRemoved (const FrameworkInfo &frameworkInfo) |
mesos::master::Response::GetAgents::Agent | mesos::internal::protobuf::master::event::createAgentResponse (const mesos::internal::master::Slave &slave, const Option< DrainInfo > &drainInfo, bool deactivated, const Option< process::Owned< ObjectApprovers >> &approvers=None()) |
mesos::master::Event | mesos::internal::protobuf::master::event::createAgentAdded (const mesos::internal::master::Slave &slave, const Option< DrainInfo > &drainInfo, bool deactivated) |
mesos::master::Event | mesos::internal::protobuf::master::event::createAgentRemoved (const SlaveID &slaveId) |
std::set< std::string > | mesos::internal::protobuf::framework::getRoles (const FrameworkInfo &frameworkInfo) |