Apache Mesos
|
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 StatusUpdateManagerProcess< id::UUID, UpdateOperationStatusRecord, UpdateOperationStatusMessage>::State mesos::internal::OperationStatusUpdateManagerState |
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 | ) |
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 | ) |
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 | ) |
v1::master::Response mesos::internal::evolve | ( | const JSON::Object & | object | ) |
v1::agent::Response mesos::internal::evolve | ( | const JSON::Object & | object | ) |
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 | ||
) |
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 | ||
) |
|
inline |
|
inline |
|
inline |
|
inline |
|
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 | ||
) |
std::string mesos::internal::serializeGetMetrics | ( | const std::map< std::string, double > & | metrics | ) |
bool mesos::internal::streamingMediaType | ( | ContentType | contentType | ) |
|
inline |
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" |