Apache Mesos
Namespaces | Classes | Typedefs | Functions | Variables
mesos::internal Namespace Reference

Namespaces

 build
 
 capabilities
 
 checks
 
 command
 
 common
 
 cram_md5
 
 credentials
 
 docker
 
 examples
 
 fs
 
 local
 
 log
 
 logger
 
 logging
 
 master
 
 memfd
 
 protobuf
 
 recordio
 
 registry
 
 resource_provider
 
 rlimits
 
 scheduler
 
 seccomp
 
 slave
 
 storage
 
 tests
 
 values
 
 xfs
 

Classes

struct  asV1Protobuf
 
class  ConstantEndpointDetector
 
class  EndpointDetector
 
class  Files
 
class  FilesError
 
struct  FutureMetadata
 
class  HookManager
 
class  HttpConnectionProcess
 HTTP connection handler. More...
 
class  LocalAuthorizer
 
class  LocalResourceProvider
 
class  LocalResourceProviderDaemon
 
class  OperationStatusUpdateManager
 
class  PendingFutureTracker
 
class  PendingFutureTrackerProcess
 
struct  RequestMediaTypes
 
class  ResourceProviderManager
 
struct  ResourceProviderMessage
 
class  ResponseHeartbeater
 
class  ResponseHeartbeaterProcess
 
class  StatusUpdateManagerProcess
 
class  StorageLocalResourceProvider
 
struct  StreamingHttpConnection
 
class  VersionProcess
 
class  WhitelistWatcher
 

Typedefs

typedef StatusUpdateManagerProcess< id::UUID, UpdateOperationStatusRecord, UpdateOperationStatusMessage >::State OperationStatusUpdateManagerState
 

Functions

std::string serialize (ContentType contentType, const google::protobuf::Message &message)
 
template<typename Message >
Try< Message > deserialize (ContentType contentType, const std::string &body)
 
bool streamingMediaType (ContentType contentType)
 
void json (JSON::ObjectWriter *writer, const asV1Protobuf &protobuf)
 
JSON::Object model (const Resources &resources)
 
JSON::Object model (const hashmap< std::string, Resources > &roleResources)
 
JSON::Object model (const Attributes &attributes)
 
JSON::Object model (const CommandInfo &command)
 
JSON::Object model (const ExecutorInfo &executorInfo)
 
JSON::Array model (const Labels &labels)
 
JSON::Object model (const Task &task)
 
JSON::Object model (const FileInfo &fileInfo)
 
JSON::Object model (const google::protobuf::Map< std::string, Value_Scalar > &map)
 
void json (JSON::ObjectWriter *writer, const Task &task)
 
template<typename T >
std::function< void(JSON::ObjectWriter *)> jsonifyGetMetrics (const std::map< std::string, double > &metrics)
 
template<typename T >
std::string serializeGetMetrics (const std::map< std::string, double > &metrics)
 
CommandInfo devolve (const v1::CommandInfo &command)
 
ContainerID devolve (const v1::ContainerID &containerId)
 
Credential devolve (const v1::Credential &credential)
 
DrainConfig devolve (const v1::DrainConfig &drainConfig)
 
DrainInfo devolve (const v1::DrainInfo &drainInfo)
 
DurationInfo devolve (const google::protobuf::Duration &duration)
 
ExecutorID devolve (const v1::ExecutorID &executorId)
 
FrameworkID devolve (const v1::FrameworkID &frameworkId)
 
FrameworkInfo devolve (const v1::FrameworkInfo &frameworkInfo)
 
HealthCheck devolve (const v1::HealthCheck &check)
 
InverseOffer devolve (const v1::InverseOffer &inverseOffer)
 
Offer devolve (const v1::Offer &offer)
 
Offer::Operation devolve (const v1::Offer::Operation &operation)
 
OperationStatus devolve (const v1::OperationStatus &status)
 
Resource devolve (const v1::Resource &resource)
 
ResourceProviderID devolve (const v1::ResourceProviderID &resourceProviderId)
 
ResourceProviderInfo devolve (const v1::ResourceProviderInfo &resourceProviderInfo)
 
Resources devolve (const v1::Resources &resources)
 
SlaveID devolve (const v1::AgentID &agentId)
 
SlaveInfo devolve (const v1::AgentInfo &agentInfo)
 
TaskID devolve (const v1::TaskID &taskId)
 
TaskStatus devolve (const v1::TaskStatus &status)
 
mesos::resource_provider::Call devolve (const v1::resource_provider::Call &call)
 
mesos::resource_provider::Event devolve (const v1::resource_provider::Event &event)
 
mesos::scheduler::Call devolve (const v1::scheduler::Call &call)
 
mesos::scheduler::Event devolve (const v1::scheduler::Event &event)
 
executor::Call devolve (const v1::executor::Call &call)
 
executor::Event devolve (const v1::executor::Event &event)
 
mesos::agent::Call devolve (const v1::agent::Call &call)
 
mesos::agent::Response devolve (const v1::agent::Response &response)
 
mesos::master::Call devolve (const v1::master::Call &call)
 
template<typename T1 , typename T2 >
google::protobuf::RepeatedPtrField< T1 > devolve (google::protobuf::RepeatedPtrField< T2 > t2s)
 
v1::AgentID evolve (const SlaveID &slaveId)
 
v1::AgentInfo evolve (const SlaveInfo &slaveInfo)
 
v1::ContainerInfo evolve (const ContainerInfo &containerInfo)
 
v1::DomainInfo evolve (const DomainInfo &domainInfo)
 
v1::DrainInfo evolve (const DrainInfo &drainInfo)
 
v1::ExecutorID evolve (const ExecutorID &executorId)
 
v1::ExecutorInfo evolve (const ExecutorInfo &executorInfo)
 
v1::FileInfo evolve (const FileInfo &fileInfo)
 
v1::FrameworkID evolve (const FrameworkID &frameworkId)
 
v1::FrameworkInfo evolve (const FrameworkInfo &frameworkInfo)
 
v1::InverseOffer evolve (const InverseOffer &inverseOffer)
 
v1::KillPolicy evolve (const KillPolicy &killPolicy)
 
v1::MachineID evolve (const MachineID &machineId)
 
v1::MasterInfo evolve (const MasterInfo &masterInfo)
 
v1::Offer evolve (const Offer &offer)
 
v1::OfferID evolve (const OfferID &offerId)
 
v1::OperationStatus evolve (const OperationStatus &status)
 
v1::Resource evolve (const Resource &resource)
 
v1::ResourceProviderID evolve (const ResourceProviderID &resourceProviderId)
 
v1::Resources evolve (const Resources &resources)
 
v1::Task evolve (const Task &task)
 
v1::TaskID evolve (const TaskID &taskId)
 
v1::TaskInfo evolve (const TaskInfo &taskInfo)
 
v1::TaskStatus evolve (const TaskStatus &status)
 
v1::UUID evolve (const UUID &uuid)
 
v1::agent::Call evolve (const agent::Call &call)
 
v1::agent::ProcessIO evolve (const agent::ProcessIO &processIO)
 
v1::agent::Response evolve (const agent::Response &response)
 
v1::maintenance::ClusterStatus evolve (const maintenance::ClusterStatus &cluster)
 
v1::maintenance::Schedule evolve (const maintenance::Schedule &schedule)
 
v1::resource_provider::Call evolve (const resource_provider::Call &call)
 
v1::resource_provider::Event evolve (const resource_provider::Event &event)
 
template<typename T1 , typename T2 >
google::protobuf::RepeatedPtrField< T1 > evolve (const google::protobuf::RepeatedPtrField< T2 > &t2s)
 
v1::scheduler::Event evolve (const mesos::scheduler::Event &event)
 
v1::scheduler::Response evolve (const mesos::scheduler::Response &response)
 
v1::scheduler::Event evolve (const ExitedExecutorMessage &message)
 
v1::scheduler::Event evolve (const ExecutorToFrameworkMessage &message)
 
v1::scheduler::Event evolve (const FrameworkErrorMessage &message)
 
v1::scheduler::Event evolve (const FrameworkRegisteredMessage &message)
 
v1::scheduler::Event evolve (const FrameworkReregisteredMessage &message)
 
v1::scheduler::Event evolve (const InverseOffersMessage &message)
 
v1::scheduler::Event evolve (const LostSlaveMessage &message)
 
v1::scheduler::Event evolve (const ResourceOffersMessage &message)
 
v1::scheduler::Event evolve (const RescindInverseOfferMessage &message)
 
v1::scheduler::Event evolve (const RescindResourceOfferMessage &message)
 
v1::scheduler::Event evolve (const StatusUpdateMessage &message)
 
v1::scheduler::Event evolve (const UpdateOperationStatusMessage &message)
 
v1::executor::Call evolve (const executor::Call &call)
 
v1::executor::Event evolve (const executor::Event &event)
 
v1::executor::Event evolve (const ExecutorRegisteredMessage &message)
 
v1::executor::Event evolve (const FrameworkToExecutorMessage &message)
 
v1::executor::Event evolve (const KillTaskMessage &message)
 
v1::executor::Event evolve (const RunTaskMessage &message)
 
v1::executor::Event evolve (const ShutdownExecutorMessage &message)
 
v1::executor::Event evolve (const StatusUpdateAcknowledgementMessage &message)
 
v1::master::Event evolve (const mesos::master::Event &event)
 
v1::master::Response evolve (const mesos::master::Response &response)
 
template<v1::master::Response::Type T>
v1::master::Response evolve (const JSON::Object &object)
 
template<v1::agent::Response::Type T>
v1::agent::Response evolve (const JSON::Object &object)
 
template<v1::agent::Response::Type T>
v1::agent::Response evolve (const JSON::Array &array)
 
std::ostream & operator<< (std::ostream &stream, const ImageGcConfig &imageGcConfig)
 
std::ostream & operator<< (std::ostream &stream, const Firewall &rules)
 
std::ostream & operator<< (std::ostream &stream, const ContainerDNSInfo &dns)
 
std::ostream & operator<< (std::ostream &stream, const SlaveCapabilities &slaveCapabilities)
 
bool operator== (const ResourceVersionUUID &left, const ResourceVersionUUID &right)
 
bool operator!= (const ResourceVersionUUID &left, const ResourceVersionUUID &right)
 
bool operator== (const UpdateOperationStatusMessage &left, const UpdateOperationStatusMessage &right)
 
bool operator!= (const UpdateOperationStatusMessage &left, const UpdateOperationStatusMessage &right)
 
std::ostream & operator<< (std::ostream &stream, const StatusUpdate &update)
 
std::ostream & operator<< (std::ostream &stream, const UpdateOperationStatusMessage &update)
 
std::ostream & operator<< (std::ostream &stream, const StatusUpdateRecord::Type &type)
 
std::ostream & operator<< (std::ostream &stream, const UpdateOperationStatusRecord::Type &type)
 
std::ostream & operator<< (std::ostream &stream, const ResourceProviderMessage &resourceProviderMessage)
 
Try< ResourceStatistics > usage (pid_t pid, bool mem=true, bool cpus=true)
 
JSON::Object version ()
 

Variables

constexpr char DEFAULT_BASIC_HTTP_AUTHENTICATOR [] = "basic"
 
constexpr char DEFAULT_BASIC_HTTP_AUTHENTICATEE [] = "basic"
 
constexpr char DEFAULT_JWT_HTTP_AUTHENTICATOR [] = "jwt"
 

Typedef Documentation

typedef StatusUpdateManagerProcess< id::UUID, UpdateOperationStatusRecord, UpdateOperationStatusMessage>::State mesos::internal::OperationStatusUpdateManagerState

Function Documentation

template<typename Message >
Try<Message> mesos::internal::deserialize ( ContentType  contentType,
const std::string &  body 
)
CommandInfo mesos::internal::devolve ( const v1::CommandInfo &  command)
ContainerID mesos::internal::devolve ( const v1::ContainerID &  containerId)
Credential mesos::internal::devolve ( const v1::Credential &  credential)
DrainConfig mesos::internal::devolve ( const v1::DrainConfig &  drainConfig)
DrainInfo mesos::internal::devolve ( const v1::DrainInfo &  drainInfo)
DurationInfo mesos::internal::devolve ( const google::protobuf::Duration &  duration)
ExecutorID mesos::internal::devolve ( const v1::ExecutorID &  executorId)
FrameworkID mesos::internal::devolve ( const v1::FrameworkID &  frameworkId)
FrameworkInfo mesos::internal::devolve ( const v1::FrameworkInfo &  frameworkInfo)
HealthCheck mesos::internal::devolve ( const v1::HealthCheck &  check)
InverseOffer mesos::internal::devolve ( const v1::InverseOffer &  inverseOffer)
Offer mesos::internal::devolve ( const v1::Offer &  offer)
Offer::Operation mesos::internal::devolve ( const v1::Offer::Operation &  operation)
OperationStatus mesos::internal::devolve ( const v1::OperationStatus &  status)
Resource mesos::internal::devolve ( const v1::Resource &  resource)
ResourceProviderID mesos::internal::devolve ( const v1::ResourceProviderID &  resourceProviderId)
ResourceProviderInfo mesos::internal::devolve ( const v1::ResourceProviderInfo &  resourceProviderInfo)
Resources mesos::internal::devolve ( const v1::Resources resources)
SlaveID mesos::internal::devolve ( const v1::AgentID &  agentId)
SlaveInfo mesos::internal::devolve ( const v1::AgentInfo &  agentInfo)
TaskID mesos::internal::devolve ( const v1::TaskID &  taskId)
TaskStatus mesos::internal::devolve ( const v1::TaskStatus &  status)
mesos::resource_provider::Call mesos::internal::devolve ( const v1::resource_provider::Call &  call)
mesos::resource_provider::Event mesos::internal::devolve ( const v1::resource_provider::Event &  event)
mesos::scheduler::Call mesos::internal::devolve ( const v1::scheduler::Call &  call)
mesos::scheduler::Event mesos::internal::devolve ( const v1::scheduler::Event &  event)
executor::Call mesos::internal::devolve ( const v1::executor::Call &  call)
executor::Event mesos::internal::devolve ( const v1::executor::Event &  event)
mesos::agent::Call mesos::internal::devolve ( const v1::agent::Call &  call)
mesos::agent::Response mesos::internal::devolve ( const v1::agent::Response &  response)
mesos::master::Call mesos::internal::devolve ( const v1::master::Call &  call)
template<typename T1 , typename T2 >
google::protobuf::RepeatedPtrField<T1> mesos::internal::devolve ( google::protobuf::RepeatedPtrField< T2 >  t2s)
v1::AgentID mesos::internal::evolve ( const SlaveID &  slaveId)
v1::AgentInfo mesos::internal::evolve ( const SlaveInfo &  slaveInfo)
v1::ContainerInfo mesos::internal::evolve ( const ContainerInfo &  containerInfo)
v1::DomainInfo mesos::internal::evolve ( const DomainInfo &  domainInfo)
v1::DrainInfo mesos::internal::evolve ( const DrainInfo &  drainInfo)
v1::ExecutorID mesos::internal::evolve ( const ExecutorID &  executorId)
v1::ExecutorInfo mesos::internal::evolve ( const ExecutorInfo &  executorInfo)
v1::FileInfo mesos::internal::evolve ( const FileInfo &  fileInfo)
v1::FrameworkID mesos::internal::evolve ( const FrameworkID &  frameworkId)
v1::FrameworkInfo mesos::internal::evolve ( const FrameworkInfo &  frameworkInfo)
v1::InverseOffer mesos::internal::evolve ( const InverseOffer &  inverseOffer)
v1::KillPolicy mesos::internal::evolve ( const KillPolicy &  killPolicy)
v1::MachineID mesos::internal::evolve ( const MachineID &  machineId)
v1::MasterInfo mesos::internal::evolve ( const MasterInfo &  masterInfo)
v1::Offer mesos::internal::evolve ( const Offer &  offer)
v1::OfferID mesos::internal::evolve ( const OfferID &  offerId)
v1::OperationStatus mesos::internal::evolve ( const OperationStatus &  status)
v1::Resource mesos::internal::evolve ( const Resource &  resource)
v1::ResourceProviderID mesos::internal::evolve ( const ResourceProviderID &  resourceProviderId)
v1::Resources mesos::internal::evolve ( const Resources resources)
v1::Task mesos::internal::evolve ( const Task &  task)
v1::TaskID mesos::internal::evolve ( const TaskID &  taskId)
v1::TaskInfo mesos::internal::evolve ( const TaskInfo &  taskInfo)
v1::TaskStatus mesos::internal::evolve ( const TaskStatus &  status)
v1::UUID mesos::internal::evolve ( const UUID &  uuid)
v1::agent::Call mesos::internal::evolve ( const agent::Call &  call)
v1::agent::ProcessIO mesos::internal::evolve ( const agent::ProcessIO &  processIO)
v1::agent::Response mesos::internal::evolve ( const agent::Response &  response)
v1::maintenance::ClusterStatus mesos::internal::evolve ( const maintenance::ClusterStatus &  cluster)
v1::maintenance::Schedule mesos::internal::evolve ( const maintenance::Schedule &  schedule)
v1::resource_provider::Call mesos::internal::evolve ( const resource_provider::Call &  call)
v1::resource_provider::Event mesos::internal::evolve ( const resource_provider::Event &  event)
template<typename T1 , typename T2 >
google::protobuf::RepeatedPtrField<T1> mesos::internal::evolve ( const google::protobuf::RepeatedPtrField< T2 > &  t2s)
v1::scheduler::Event mesos::internal::evolve ( const mesos::scheduler::Event &  event)
v1::scheduler::Response mesos::internal::evolve ( const mesos::scheduler::Response &  response)
v1::scheduler::Event mesos::internal::evolve ( const ExitedExecutorMessage &  message)
v1::scheduler::Event mesos::internal::evolve ( const ExecutorToFrameworkMessage &  message)
v1::scheduler::Event mesos::internal::evolve ( const FrameworkErrorMessage &  message)
v1::scheduler::Event mesos::internal::evolve ( const FrameworkRegisteredMessage &  message)
v1::scheduler::Event mesos::internal::evolve ( const FrameworkReregisteredMessage &  message)
v1::scheduler::Event mesos::internal::evolve ( const InverseOffersMessage &  message)
v1::scheduler::Event mesos::internal::evolve ( const LostSlaveMessage &  message)
v1::scheduler::Event mesos::internal::evolve ( const ResourceOffersMessage &  message)
v1::scheduler::Event mesos::internal::evolve ( const RescindInverseOfferMessage &  message)
v1::scheduler::Event mesos::internal::evolve ( const RescindResourceOfferMessage &  message)
v1::scheduler::Event mesos::internal::evolve ( const StatusUpdateMessage &  message)
v1::scheduler::Event mesos::internal::evolve ( const UpdateOperationStatusMessage &  message)
v1::executor::Call mesos::internal::evolve ( const executor::Call &  call)
v1::executor::Event mesos::internal::evolve ( const executor::Event &  event)
v1::executor::Event mesos::internal::evolve ( const ExecutorRegisteredMessage &  message)
v1::executor::Event mesos::internal::evolve ( const FrameworkToExecutorMessage &  message)
v1::executor::Event mesos::internal::evolve ( const KillTaskMessage &  message)
v1::executor::Event mesos::internal::evolve ( const RunTaskMessage &  message)
v1::executor::Event mesos::internal::evolve ( const ShutdownExecutorMessage &  message)
v1::executor::Event mesos::internal::evolve ( const StatusUpdateAcknowledgementMessage &  message)
v1::master::Event mesos::internal::evolve ( const mesos::master::Event &  event)
v1::master::Response mesos::internal::evolve ( const mesos::master::Response &  response)
template<v1::master::Response::Type T>
v1::master::Response mesos::internal::evolve ( const JSON::Object object)
template<v1::agent::Response::Type T>
v1::agent::Response mesos::internal::evolve ( const JSON::Object object)
template<v1::agent::Response::Type T>
v1::agent::Response mesos::internal::evolve ( const JSON::Array array)
void mesos::internal::json ( JSON::ObjectWriter writer,
const asV1Protobuf protobuf 
)
void mesos::internal::json ( JSON::ObjectWriter writer,
const Task &  task 
)
template<typename T >
std::function<void(JSON::ObjectWriter*)> mesos::internal::jsonifyGetMetrics ( const std::map< std::string, double > &  metrics)
JSON::Object mesos::internal::model ( const Resources resources)
JSON::Object mesos::internal::model ( const hashmap< std::string, Resources > &  roleResources)
JSON::Object mesos::internal::model ( const Attributes attributes)
JSON::Object mesos::internal::model ( const CommandInfo &  command)
JSON::Object mesos::internal::model ( const ExecutorInfo &  executorInfo)
JSON::Array mesos::internal::model ( const Labels &  labels)
JSON::Object mesos::internal::model ( const Task &  task)
JSON::Object mesos::internal::model ( const FileInfo &  fileInfo)
JSON::Object mesos::internal::model ( const google::protobuf::Map< std::string, Value_Scalar > &  map)
bool mesos::internal::operator!= ( const ResourceVersionUUID &  left,
const ResourceVersionUUID &  right 
)
bool mesos::internal::operator!= ( const UpdateOperationStatusMessage &  left,
const UpdateOperationStatusMessage &  right 
)
std::ostream& mesos::internal::operator<< ( std::ostream &  stream,
const StatusUpdate &  update 
)
std::ostream& mesos::internal::operator<< ( std::ostream &  stream,
const UpdateOperationStatusMessage &  update 
)
std::ostream& mesos::internal::operator<< ( std::ostream &  stream,
const StatusUpdateRecord::Type &  type 
)
std::ostream& mesos::internal::operator<< ( std::ostream &  stream,
const UpdateOperationStatusRecord::Type &  type 
)
std::ostream& mesos::internal::operator<< ( std::ostream &  stream,
const ImageGcConfig &  imageGcConfig 
)
inline
std::ostream& mesos::internal::operator<< ( std::ostream &  stream,
const Firewall &  rules 
)
inline
std::ostream& mesos::internal::operator<< ( std::ostream &  stream,
const ResourceProviderMessage resourceProviderMessage 
)
inline
std::ostream& mesos::internal::operator<< ( std::ostream &  stream,
const ContainerDNSInfo &  dns 
)
inline
std::ostream& mesos::internal::operator<< ( std::ostream &  stream,
const SlaveCapabilities &  slaveCapabilities 
)
inline
bool mesos::internal::operator== ( const ResourceVersionUUID &  left,
const ResourceVersionUUID &  right 
)
bool mesos::internal::operator== ( const UpdateOperationStatusMessage &  left,
const UpdateOperationStatusMessage &  right 
)
std::string mesos::internal::serialize ( ContentType  contentType,
const google::protobuf::Message &  message 
)
template<typename T >
std::string mesos::internal::serializeGetMetrics ( const std::map< std::string, double > &  metrics)
bool mesos::internal::streamingMediaType ( ContentType  contentType)
Try<ResourceStatistics> mesos::internal::usage ( pid_t  pid,
bool  mem = true,
bool  cpus = true 
)
JSON::Object mesos::internal::version ( )
inline

Variable Documentation

constexpr char mesos::internal::DEFAULT_BASIC_HTTP_AUTHENTICATEE[] = "basic"
constexpr char mesos::internal::DEFAULT_BASIC_HTTP_AUTHENTICATOR[] = "basic"
constexpr char mesos::internal::DEFAULT_JWT_HTTP_AUTHENTICATOR[] = "jwt"