|
Apache Mesos
|
This is the complete list of members for mesos::internal::tests::MockSlave, including all inherited members.
| ___run(const process::Future< Nothing > &future, const FrameworkID &frameworkId, const ExecutorID &executorId, const ContainerID &containerId, const std::vector< TaskInfo > &tasks, const std::vector< TaskGroupInfo > &taskGroups) | mesos::internal::slave::Slave | virtual |
| ___statusUpdate(const process::Future< Nothing > &future, const StatusUpdate &update, const Option< process::UPID > &pid) | mesos::internal::slave::Slave | |
| __recover(const process::Future< Nothing > &future) | mesos::internal::slave::Slave | virtual |
| __recoverOperations(const process::Future< OperationStatusUpdateManagerState > &state) | mesos::internal::slave::Slave | |
| __run(const FrameworkInfo &frameworkInfo, const ExecutorInfo &executorInfo, const Option< TaskInfo > &task, const Option< TaskGroupInfo > &taskGroup, const std::vector< ResourceVersionUUID > &resourceVersionUuids, const Option< bool > &launchExecutor, bool executorGeneratedForCommandTask) | mesos::internal::slave::Slave | virtual |
| __statusUpdate(const Option< process::Future< Nothing >> &future, const StatusUpdate &update, const Option< process::UPID > &pid, const ExecutorID &executorId, const ContainerID &containerId, bool checkpoint) | mesos::internal::slave::Slave | |
| _checkDiskUsage(const process::Future< double > &usage) | mesos::internal::slave::Slave | |
| _checkImageDiskUsage(const process::Future< double > &usage) | mesos::internal::slave::Slave | |
| _qosCorrections(const process::Future< std::list< mesos::slave::QoSCorrection >> &correction) | mesos::internal::slave::Slave | virtual |
| _recover() | mesos::internal::slave::Slave | |
| _recoverContainerizer(const Option< state::SlaveState > &state) | mesos::internal::slave::Slave | |
| _recoverOperations(const Option< state::SlaveState > &state) | mesos::internal::slave::Slave | |
| _recoverTaskStatusUpdates(const Option< state::SlaveState > &slaveState) | mesos::internal::slave::Slave | |
| _recoverVolumeGidManager(bool rebooted) | mesos::internal::slave::Slave | |
| _reregisterExecutor(const process::Future< Nothing > &future, const FrameworkID &frameworkId, const ExecutorID &executorId, const ContainerID &containerId) | mesos::internal::slave::Slave | |
| _run(const FrameworkInfo &frameworkInfo, const ExecutorInfo &executorInfo, const Option< TaskInfo > &task, const Option< TaskGroupInfo > &taskGroup, const std::vector< ResourceVersionUUID > &resourceVersionUuids, const Option< bool > &launchExecutor) | mesos::internal::slave::Slave | virtual |
| _shutdownExecutor(Framework *framework, Executor *executor) | mesos::internal::slave::Slave | virtual |
| _statusUpdate(StatusUpdate update, const Option< process::UPID > &pid, const ExecutorID &executorId, const Option< process::Future< ContainerStatus >> &containerStatus) | mesos::internal::slave::Slave | |
| _statusUpdateAcknowledgement(const process::Future< bool > &future, const TaskID &taskId, const FrameworkID &frameworkId, const UUID &uuid) | mesos::internal::slave::Slave | |
| age(double usage) | mesos::internal::slave::Slave | |
| applyOperation(const ApplyOperationMessage &message) | mesos::internal::slave::Slave | virtual |
| attachTaskVolumeDirectory(const ExecutorInfo &executorInfo, const ContainerID &executorContainerId, const Task &task) | mesos::internal::slave::Slave | |
| authenticate(Duration minTimeout, Duration maxTimeout) | mesos::internal::slave::Slave | virtual |
| AuthenticatedHttpRequestHandler typedef | process::ProcessBase | protected |
| checkDiskUsage() | mesos::internal::slave::Slave | |
| checkImageDiskUsage() | mesos::internal::slave::Slave | |
| checkpointResourcesMessage(const std::vector< Resource > &resources) | mesos::internal::slave::Slave | |
| checkpointResourceState(const Resources &resources, bool changeTotal) | mesos::internal::slave::Slave | |
| checkpointResourceState(std::vector< Resource > resources, bool changeTotal) | mesos::internal::slave::Slave | |
| consume(process::MessageEvent &&event) override | ProtobufProcess< Slave > | inlineprotectedvirtual |
| Process< Slave >::consume(DispatchEvent &&event) override | process::ProcessBase | protectedvirtual |
| Process< Slave >::consume(HttpEvent &&event) override | process::ProcessBase | protectedvirtual |
| Process< Slave >::consume(ExitedEvent &&event) override | process::ProcessBase | protectedvirtual |
| Process< Slave >::consume(TerminateEvent &&event) override | process::ProcessBase | protectedvirtual |
| delegate(const std::string &name, const UPID &pid) | process::ProcessBase | inlineprotected |
| detachFile(const std::string &path) | mesos::internal::slave::Slave | |
| detachTaskVolumeDirectories(const ExecutorInfo &executorInfo, const ContainerID &executorContainerId, const std::vector< Task > &tasks) | mesos::internal::slave::Slave | |
| detected(const process::Future< Option< MasterInfo >> &_master) | mesos::internal::slave::Slave | |
| DISCONNECTED enum value | mesos::internal::slave::Slave | |
| doReliableRegistration(Duration maxBackoff) | mesos::internal::slave::Slave | |
| drain(const process::UPID &from, DrainSlaveMessage &&drainSlaveMessage) | mesos::internal::slave::Slave | |
| eventCount() | process::ProcessBase | protected |
| executorLaunched(const FrameworkID &frameworkId, const ExecutorID &executorId, const ContainerID &containerId, const process::Future< Containerizer::LaunchResult > &future) | mesos::internal::slave::Slave | |
| executorMessage(const SlaveID &slaveId, const FrameworkID &frameworkId, const ExecutorID &executorId, const std::string &data) | mesos::internal::slave::Slave | |
| executorTerminated(const FrameworkID &frameworkId, const ExecutorID &executorId, const process::Future< Option< mesos::slave::ContainerTermination >> &termination) | mesos::internal::slave::Slave | virtual |
| exited(const process::UPID &pid) override | mesos::internal::slave::Slave | virtual |
| fileAttached(const process::Future< Nothing > &result, const std::string &path, const std::string &virtualPath) | mesos::internal::slave::Slave | |
| finalize() override | mesos::internal::slave::Slave | virtual |
| forward(StatusUpdate update) | mesos::internal::slave::Slave | |
| garbageCollect(const std::string &path) | mesos::internal::slave::Slave | |
| generateSecret(const FrameworkID &frameworkId, const ExecutorID &executorId, const ContainerID &containerId) | mesos::internal::slave::Slave | |
| getExecutor(const FrameworkID &frameworkId, const ExecutorID &executorId) const | mesos::internal::slave::Slave | |
| getExecutor(const ContainerID &containerId) const | mesos::internal::slave::Slave | |
| getExecutorInfo(const FrameworkInfo &frameworkInfo, const TaskInfo &task) const | mesos::internal::slave::Slave | |
| getFramework(const FrameworkID &frameworkId) const | mesos::internal::slave::Slave | |
| handleRunTaskGroupMessage(const process::UPID &from, RunTaskGroupMessage &&runTaskGroupMessage) | mesos::internal::slave::Slave | |
| handleRunTaskMessage(const process::UPID &from, RunTaskMessage &&runTaskMessage) | mesos::internal::slave::Slave | |
| HttpRequestHandler typedef | process::ProcessBase | protected |
| httpSequence | process::ProcessBase | |
| initialize() override | mesos::internal::slave::Slave | virtual |
| install(void(Slave::*method)(const process::UPID &, const M &)) | ProtobufProcess< Slave > | inlineprotected |
| install(void(Slave::*method)(const process::UPID &, M &&)) | ProtobufProcess< Slave > | inlineprotected |
| install(void(Slave::*method)(const process::UPID &)) | ProtobufProcess< Slave > | inlineprotected |
| install(void(Slave::*method)(const process::UPID &, PC...), MessageProperty< M, P >...param) | ProtobufProcess< Slave > | inlineprotected |
| install(void(Slave::*method)(const M &)) | ProtobufProcess< Slave > | inlineprotected |
| install(void(Slave::*method)(M &&)) | ProtobufProcess< Slave > | inlineprotected |
| install(void(Slave::*method)()) | ProtobufProcess< Slave > | inlineprotected |
| install(void(Slave::*method)(PC...), MessageProperty< M, P >...param) | ProtobufProcess< Slave > | inlineprotected |
| Process< Slave >::install(const std::string &name, const MessageHandler &handler) | process::ProcessBase | inlineprotected |
| Process< Slave >::install(const std::string &name, void(T::*method)(const UPID &, const std::string &)) | process::ProcessBase | inlineprotected |
| kill(const FrameworkID &frameworkId, Framework *framework, Executor *executor, const TaskID &taskId, const Option< KillPolicy > &killPolicy) | mesos::internal::slave::Slave | |
| killPendingTask(const FrameworkID &frameworkId, Framework *framework, const TaskID &taskId) | mesos::internal::slave::Slave | |
| killTask(const process::UPID &from, const KillTaskMessage &killTaskMessage) | mesos::internal::slave::Slave | virtual |
| launchExecutor(const process::Future< Option< Secret >> &authorizationToken, const FrameworkID &frameworkId, const ExecutorInfo &executorInfo, const google::protobuf::Map< std::string, Value::Scalar > &executorLimits, const Option< TaskInfo > &taskInfo) | mesos::internal::slave::Slave | |
| link(const UPID &pid, const RemoteConnection remote=RemoteConnection::REUSE) | process::ProcessBase | protected |
| lost(const UPID &) | process::ProcessBase | inlineprotectedvirtual |
| message | process::ProcessBase | |
| MessageHandler typedef | process::ProcessBase | protected |
| MessageProperty typedef | ProtobufProcess< Slave > | protected |
| MOCK_METHOD0(qosCorrections, void()) | mesos::internal::tests::MockSlave | |
| MOCK_METHOD0(usage, process::Future< ResourceUsage >()) | mesos::internal::tests::MockSlave | |
| MOCK_METHOD1(removeFramework, void(slave::Framework *framework)) | mesos::internal::tests::MockSlave | |
| MOCK_METHOD1(__recover, void(const process::Future< Nothing > &future)) | mesos::internal::tests::MockSlave | |
| MOCK_METHOD1(_qosCorrections, void(const process::Future< std::list< mesos::slave::QoSCorrection >> &correction)) | mesos::internal::tests::MockSlave | |
| MOCK_METHOD1(applyOperation, void(const ApplyOperationMessage &message)) | mesos::internal::tests::MockSlave | |
| MOCK_METHOD2(killTask, void(const process::UPID &from, const KillTaskMessage &killTaskMessage)) | mesos::internal::tests::MockSlave | |
| MOCK_METHOD2(authenticate, void(Duration minTimeout, Duration maxTimeout)) | mesos::internal::tests::MockSlave | |
| MOCK_METHOD2(_shutdownExecutor, void(slave::Framework *framework, slave::Executor *executor)) | mesos::internal::tests::MockSlave | |
| MOCK_METHOD3(executorTerminated, void(const FrameworkID &frameworkId, const ExecutorID &executorId, const process::Future< Option< mesos::slave::ContainerTermination >> &termination)) | mesos::internal::tests::MockSlave | |
| MOCK_METHOD3(shutdownExecutor, void(const process::UPID &from, const FrameworkID &frameworkId, const ExecutorID &executorId)) | mesos::internal::tests::MockSlave | |
| MOCK_METHOD6(___run, void(const process::Future< Nothing > &future, const FrameworkID &frameworkId, const ExecutorID &executorId, const ContainerID &containerId, const std::vector< TaskInfo > &tasks, const std::vector< TaskGroupInfo > &taskGroups)) | mesos::internal::tests::MockSlave | |
| MOCK_METHOD6(_run, process::Future< Nothing >(const FrameworkInfo &frameworkInfo, const ExecutorInfo &executorInfo, const Option< TaskInfo > &task, const Option< TaskGroupInfo > &taskGroup, const std::vector< ResourceVersionUUID > &resourceVersionUuids, const Option< bool > &launchExecutor)) | mesos::internal::tests::MockSlave | |
| MOCK_METHOD6(runTaskGroup, void(const process::UPID &from, const FrameworkInfo &frameworkInfo, const ExecutorInfo &executorInfo, const TaskGroupInfo &taskGroup, const std::vector< ResourceVersionUUID > &resourceVersionUuids, const Option< bool > &launchExecutor)) | mesos::internal::tests::MockSlave | |
| MOCK_METHOD7(runTask, void(const process::UPID &from, const FrameworkInfo &frameworkInfo, const FrameworkID &frameworkId, const process::UPID &pid, const TaskInfo &task, const std::vector< ResourceVersionUUID > &resourceVersionUuids, const Option< bool > &launchExecutor)) | mesos::internal::tests::MockSlave | |
| MOCK_METHOD7(__run, void(const FrameworkInfo &frameworkInfo, const ExecutorInfo &executorInfo, const Option< TaskInfo > &task, const Option< TaskGroupInfo > &taskGroup, const std::vector< ResourceVersionUUID > &resourceVersionUuids, const Option< bool > &launchExecutor, bool executorGeneratedForCommandTask)) | mesos::internal::tests::MockSlave | |
| MockSlave(const std::string &id, const slave::Flags &flags, mesos::master::detector::MasterDetector *detector, slave::Containerizer *containerizer, Files *files, slave::GarbageCollector *gc, slave::TaskStatusUpdateManager *taskStatusUpdateManager, mesos::slave::ResourceEstimator *resourceEstimator, mesos::slave::QoSController *qosController, SecretGenerator *secretGenerator, slave::VolumeGidManager *volumeGidManager, PendingFutureTracker *futureTracker, process::Owned< slave::CSIServer > &&csiServer, const Option< Authorizer * > &authorizer) | mesos::internal::tests::MockSlave | |
| operationStatusAcknowledgement(const process::UPID &from, const AcknowledgeOperationStatusMessage &acknowledgement) | mesos::internal::slave::Slave | |
| ping(const process::UPID &from, bool connected) | mesos::internal::slave::Slave | |
| pingTimeout(process::Future< Option< MasterInfo >> future) | mesos::internal::slave::Slave | |
| ProcessBase(const std::string &id="") | process::ProcessBase | explicit |
| provide(const std::string &name, const std::string &path, const std::map< std::string, std::string > &types=mime::types) | process::ProcessBase | inlineprotected |
| qosCorrections() | mesos::internal::slave::Slave | virtual |
| reconcileOperations(const ReconcileOperationsMessage &message) | mesos::internal::slave::Slave | |
| recover(const Try< state::State > &state) | mesos::internal::slave::Slave | |
| recoverFramework(const state::FrameworkState &state, const hashset< ExecutorID > &executorsToRecheckpoint, const hashmap< ExecutorID, hashset< TaskID >> &tasksToRecheckpoint) | mesos::internal::slave::Slave | |
| RECOVERING enum value | mesos::internal::slave::Slave | |
| recoveryInfo | mesos::internal::slave::Slave | |
| registered(const process::UPID &from, const SlaveID &slaveId, const MasterSlaveConnection &connection) | mesos::internal::slave::Slave | |
| registerExecutor(const process::UPID &from, const FrameworkID &frameworkId, const ExecutorID &executorId) | mesos::internal::slave::Slave | |
| registerExecutorTimeout(const FrameworkID &frameworkId, const ExecutorID &executorId, const ContainerID &containerId) | mesos::internal::slave::Slave | |
| RemoteConnection enum name | process::ProcessBase | protected |
| removeExecutor(Framework *framework, Executor *executor) | mesos::internal::slave::Slave | |
| removeFramework(Framework *framework) | mesos::internal::slave::Slave | virtual |
| reply(const google::protobuf::Message &message) | ProtobufProcess< Slave > | inlineprotected |
| reregistered(const process::UPID &from, const SlaveID &slaveId, const std::vector< ReconcileTasksMessage > &reconciliations, const MasterSlaveConnection &connection) | mesos::internal::slave::Slave | |
| reregisterExecutor(const process::UPID &from, const FrameworkID &frameworkId, const ExecutorID &executorId, const std::vector< TaskInfo > &tasks, const std::vector< StatusUpdate > &updates) | mesos::internal::slave::Slave | |
| reregisterExecutorTimeout() | mesos::internal::slave::Slave | |
| route(const std::string &name, const Option< std::string > &help, const HttpRequestHandler &handler, const RouteOptions &options=RouteOptions()) | process::ProcessBase | protected |
| route(const std::string &name, const Option< std::string > &help, Future< http::Response >(T::*method)(const http::Request &), const RouteOptions &options=RouteOptions()) | process::ProcessBase | inlineprotected |
| route(const std::string &name, const std::string &realm, const Option< std::string > &help, const AuthenticatedHttpRequestHandler &handler, const RouteOptions &options=RouteOptions()) | process::ProcessBase | protected |
| route(const std::string &name, const Option< std::string > &realm, const Option< std::string > &help, Future< http::Response >(T::*method)(const http::Request &, const Option< http::authentication::Principal > &), const RouteOptions &options=RouteOptions()) | process::ProcessBase | inlineprotected |
| run(const FrameworkInfo &frameworkInfo, ExecutorInfo executorInfo, Option< TaskInfo > task, Option< TaskGroupInfo > taskGroup, const std::vector< ResourceVersionUUID > &resourceVersionUuids, const process::UPID &pid, const Option< bool > &launchExecutor, bool executorGeneratedForCommandTask) | mesos::internal::slave::Slave | |
| RUNNING enum value | mesos::internal::slave::Slave | |
| runTask(const process::UPID &from, const FrameworkInfo &frameworkInfo, const FrameworkID &frameworkId, const process::UPID &pid, const TaskInfo &task, const std::vector< ResourceVersionUUID > &resourceVersionUuids, const Option< bool > &launchExecutor) | mesos::internal::slave::Slave | virtual |
| runTaskGroup(const process::UPID &from, const FrameworkInfo &frameworkInfo, const ExecutorInfo &executorInfo, const TaskGroupInfo &taskGroupInfo, const std::vector< ResourceVersionUUID > &resourceVersionUuids, const Option< bool > &launchExecutor) | mesos::internal::slave::Slave | virtual |
| schedulerMessage(const SlaveID &slaveId, const FrameworkID &frameworkId, const ExecutorID &executorId, const std::string &data) | mesos::internal::slave::Slave | |
| self() const | process::Process< Slave > | inline |
| Self typedef | process::Process< Slave > | protected |
| send(const process::UPID &to, const google::protobuf::Message &message) | ProtobufProcess< Slave > | inlineprotected |
| Process< Slave >::send(const UPID &to, const std::string &name, const char *data=nullptr, size_t length=0) | process::ProcessBase | protected |
| Process< Slave >::send(const UPID &to, std::string &&name) | process::ProcessBase | protected |
| Process< Slave >::send(const UPID &to, std::string &&name, std::string &&data) | process::ProcessBase | protected |
| sendOperationStatusUpdate(const UpdateOperationStatusMessage &update) | mesos::internal::slave::Slave | |
| serve(Event &&event) | process::ProcessBase | inlineprotectedvirtual |
| shutdown(const process::UPID &from, const std::string &message) | mesos::internal::slave::Slave | |
| shutdownExecutor(const process::UPID &from, const FrameworkID &frameworkId, const ExecutorID &executorId) | mesos::internal::slave::Slave | virtual |
| shutdownExecutorTimeout(const FrameworkID &frameworkId, const ExecutorID &executorId, const ContainerID &containerId) | mesos::internal::slave::Slave | |
| shutdownFramework(const process::UPID &from, const FrameworkID &frameworkId) | mesos::internal::slave::Slave | |
| signaled(int signal, int uid) | mesos::internal::slave::Slave | |
| Slave(const std::string &id, const Flags &flags, mesos::master::detector::MasterDetector *detector, Containerizer *containerizer, Files *files, GarbageCollector *gc, TaskStatusUpdateManager *taskStatusUpdateManager, mesos::slave::ResourceEstimator *resourceEstimator, mesos::slave::QoSController *qosController, mesos::SecretGenerator *secretGenerator, VolumeGidManager *volumeGidManager, PendingFutureTracker *futureTracker, process::Owned< CSIServer > &&csiServer, const Option< process::network::unix::Socket > &executorSocket, const Option< Authorizer * > &authorizer) | mesos::internal::slave::Slave | |
| state | mesos::internal::slave::Slave | |
| State enum name | mesos::internal::slave::Slave | |
| statusUpdate(StatusUpdate update, const Option< process::UPID > &pid) | mesos::internal::slave::Slave | |
| statusUpdateAcknowledgement(const process::UPID &from, const SlaveID &slaveId, const FrameworkID &frameworkId, const TaskID &taskId, const std::string &uuid) | mesos::internal::slave::Slave | |
| subscribe(StreamingHttpConnection< v1::executor::Event > http, const executor::Call::Subscribe &subscribe, Framework *framework, Executor *executor) | mesos::internal::slave::Slave | |
| TERMINATING enum value | mesos::internal::slave::Slave | |
| This typedef | process::Process< Slave > | protected |
| unmocked____run(const process::Future< Nothing > &future, const FrameworkID &frameworkId, const ExecutorID &executorId, const ContainerID &containerId, const std::vector< TaskInfo > &tasks, const std::vector< TaskGroupInfo > &taskGroups) | mesos::internal::tests::MockSlave | |
| unmocked___recover(const process::Future< Nothing > &future) | mesos::internal::tests::MockSlave | |
| unmocked___run(const FrameworkInfo &frameworkInfo, const ExecutorInfo &executorInfo, const Option< TaskInfo > &task, const Option< TaskGroupInfo > &taskGroup, const std::vector< ResourceVersionUUID > &resourceVersionUuids, const Option< bool > &launchExecutor, bool executorGeneratedForCommandTask) | mesos::internal::tests::MockSlave | |
| unmocked__run(const FrameworkInfo &frameworkInfo, const ExecutorInfo &executorInfo, const Option< TaskInfo > &task, const Option< TaskGroupInfo > &taskGroup, const std::vector< ResourceVersionUUID > &resourceVersionUuids, const Option< bool > &launchExecutor) | mesos::internal::tests::MockSlave | |
| unmocked__shutdownExecutor(slave::Framework *framework, slave::Executor *executor) | mesos::internal::tests::MockSlave | |
| unmocked_applyOperation(const ApplyOperationMessage &message) | mesos::internal::tests::MockSlave | |
| unmocked_authenticate(Duration minTimeout, Duration maxTimeout) | mesos::internal::tests::MockSlave | |
| unmocked_executorTerminated(const FrameworkID &frameworkId, const ExecutorID &executorId, const process::Future< Option< mesos::slave::ContainerTermination >> &termination) | mesos::internal::tests::MockSlave | |
| unmocked_killTask(const process::UPID &from, const KillTaskMessage &killTaskMessage) | mesos::internal::tests::MockSlave | |
| unmocked_qosCorrections() | mesos::internal::tests::MockSlave | |
| unmocked_removeFramework(slave::Framework *framework) | mesos::internal::tests::MockSlave | |
| unmocked_runTask(const process::UPID &from, const FrameworkInfo &frameworkInfo, const FrameworkID &frameworkId, const process::UPID &pid, const TaskInfo &task, const std::vector< ResourceVersionUUID > &resourceVersionUuids, const Option< bool > &launchExecutor) | mesos::internal::tests::MockSlave | |
| unmocked_runTaskGroup(const process::UPID &from, const FrameworkInfo &frameworkInfo, const ExecutorInfo &executorInfo, const TaskGroupInfo &taskGroup, const std::vector< ResourceVersionUUID > &resourceVersionUuids, const Option< bool > &launchExecutor) | mesos::internal::tests::MockSlave | |
| unmocked_shutdownExecutor(const process::UPID &from, const FrameworkID &frameworkId, const ExecutorID &executorId) | mesos::internal::tests::MockSlave | |
| unmocked_usage() | mesos::internal::tests::MockSlave | |
| updateFramework(const UpdateFrameworkMessage &message) | mesos::internal::slave::Slave | |
| usage() | mesos::internal::slave::Slave | virtual |
| validateResourceLimitsAndIsolators(const std::vector< TaskInfo > &tasks) | mesos::internal::slave::Slave | |
| ~EventConsumer() | process::EventConsumer | inlinevirtual |
| ~Process() override | process::Process< Slave > | inline |
| ~ProcessBase() override | process::ProcessBase | |
| ~ProtobufProcess() override | ProtobufProcess< Slave > | inline |
| ~Slave() override | mesos::internal::slave::Slave |
1.8.11