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

Namespaces

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

Classes

class  HttpConnectionProcess
 HTTP connection handler. More...
 
class  LocalAuthorizer
 
struct  RequestMediaTypes
 
class  FilesError
 
class  Files
 
class  HookManager
 
class  LocalResourceProviderDaemon
 
class  EndpointDetector
 
class  ConstantEndpointDetector
 
class  LocalResourceProvider
 
class  ResourceProviderManager
 
struct  ResourceProviderMessage
 
class  StorageLocalResourceProvider
 
class  OperationStatusUpdateManager
 
class  StatusUpdateManagerProcess
 
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)
 
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 quota::QuotaInfo &quotaInfo)
 
void json (JSON::ObjectWriter *writer, const Task &task)
 
CommandInfo devolve (const v1::CommandInfo &command)
 
ContainerID devolve (const v1::ContainerID &containerId)
 
Credential devolve (const v1::Credential &credential)
 
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)
 
OperationStatus devolve (const v1::OperationStatus &status)
 
Resource devolve (const v1::Resource &resource)
 
ResourceProviderID devolve (const v1::ResourceProviderID &resourceProviderId)
 
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)
 
scheduler::Call devolve (const v1::scheduler::Call &call)
 
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::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::DomainInfo evolve (const DomainInfo &domainInfo)
 
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::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::agent::Call evolve (const mesos::agent::Call &call)
 
v1::agent::ProcessIO evolve (const mesos::agent::ProcessIO &processIO)
 
v1::agent::Response evolve (const mesos::agent::Response &response)
 
v1::maintenance::ClusterStatus evolve (const maintenance::ClusterStatus &cluster)
 
v1::maintenance::Schedule evolve (const maintenance::Schedule &schedule)
 
v1::master::Response evolve (const mesos::master::Response &response)
 
v1::resource_provider::Call evolve (const mesos::resource_provider::Call &call)
 
v1::resource_provider::Event evolve (const mesos::resource_provider::Event &event)
 
v1::scheduler::Call evolve (const scheduler::Call &call)
 
template<typename T1 , typename T2 >
google::protobuf::RepeatedPtrField
< T1 > 
evolve (google::protobuf::RepeatedPtrField< T2 > t2s)
 
v1::scheduler::Event evolve (const scheduler::Event &event)
 
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::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)
 
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"
 
hashset< std::string > AUTHORIZABLE_ENDPOINTS
 

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)
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)
OperationStatus mesos::internal::devolve ( const v1::OperationStatus &  status)
Resource mesos::internal::devolve ( const v1::Resource &  resource)
ResourceProviderID mesos::internal::devolve ( const v1::ResourceProviderID &  resourceProviderId)
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)
scheduler::Call mesos::internal::devolve ( const v1::scheduler::Call &  call)
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::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::DomainInfo mesos::internal::evolve ( const DomainInfo &  domainInfo)
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::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::agent::Call mesos::internal::evolve ( const mesos::agent::Call &  call)
v1::agent::ProcessIO mesos::internal::evolve ( const mesos::agent::ProcessIO &  processIO)
v1::agent::Response mesos::internal::evolve ( const mesos::agent::Response &  response)
v1::maintenance::ClusterStatus mesos::internal::evolve ( const maintenance::ClusterStatus &  cluster)
v1::maintenance::Schedule mesos::internal::evolve ( const maintenance::Schedule &  schedule)
v1::master::Response mesos::internal::evolve ( const mesos::master::Response &  response)
v1::resource_provider::Call mesos::internal::evolve ( const mesos::resource_provider::Call &  call)
v1::resource_provider::Event mesos::internal::evolve ( const mesos::resource_provider::Event &  event)
v1::scheduler::Call mesos::internal::evolve ( const scheduler::Call &  call)
template<typename T1 , typename T2 >
google::protobuf::RepeatedPtrField<T1> mesos::internal::evolve ( google::protobuf::RepeatedPtrField< T2 >  t2s)
v1::scheduler::Event mesos::internal::evolve ( const scheduler::Event &  event)
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::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)
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 Task &  task 
)
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 quota::QuotaInfo &  quotaInfo)
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 ResourceProviderMessage &  resourceProviderMessage 
)
inline
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 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 
)
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

hashset<std::string> mesos::internal::AUTHORIZABLE_ENDPOINTS
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"