Apache Mesos
Public Member Functions | List of all members
mesos::internal::tests::MockSlave Class Reference

#include <mock_slave.hpp>

Inheritance diagram for mesos::internal::tests::MockSlave:
mesos::internal::slave::Slave ProtobufProcess< Slave > process::Process< Slave > process::ProcessBase process::EventConsumer

Public Member Functions

 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)
 
 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))
 
void 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)
 
 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))
 
void 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)
 
 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))
 
process::Future< Nothingunmocked__run (const FrameworkInfo &frameworkInfo, const ExecutorInfo &executorInfo, const Option< TaskInfo > &task, const Option< TaskGroupInfo > &taskGroup, const std::vector< ResourceVersionUUID > &resourceVersionUuids, const Option< bool > &launchExecutor)
 
 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))
 
void 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)
 
 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))
 
void unmocked_runTaskGroup (const process::UPID &from, const FrameworkInfo &frameworkInfo, const ExecutorInfo &executorInfo, const TaskGroupInfo &taskGroup, const std::vector< ResourceVersionUUID > &resourceVersionUuids, const Option< bool > &launchExecutor)
 
 MOCK_METHOD2 (killTask, void(const process::UPID &from, const KillTaskMessage &killTaskMessage))
 
void unmocked_killTask (const process::UPID &from, const KillTaskMessage &killTaskMessage)
 
 MOCK_METHOD2 (authenticate, void(Duration minTimeout, Duration maxTimeout))
 
void unmocked_authenticate (Duration minTimeout, Duration maxTimeout)
 
 MOCK_METHOD1 (removeFramework, void(slave::Framework *framework))
 
void unmocked_removeFramework (slave::Framework *framework)
 
 MOCK_METHOD1 (__recover, void(const process::Future< Nothing > &future))
 
void unmocked___recover (const process::Future< Nothing > &future)
 
 MOCK_METHOD0 (qosCorrections, void())
 
void unmocked_qosCorrections ()
 
 MOCK_METHOD1 (_qosCorrections, void(const process::Future< std::list< mesos::slave::QoSCorrection >> &correction))
 
 MOCK_METHOD0 (usage, process::Future< ResourceUsage >())
 
process::Future< ResourceUsage > unmocked_usage ()
 
 MOCK_METHOD3 (executorTerminated, void(const FrameworkID &frameworkId, const ExecutorID &executorId, const process::Future< Option< mesos::slave::ContainerTermination >> &termination))
 
void unmocked_executorTerminated (const FrameworkID &frameworkId, const ExecutorID &executorId, const process::Future< Option< mesos::slave::ContainerTermination >> &termination)
 
 MOCK_METHOD3 (shutdownExecutor, void(const process::UPID &from, const FrameworkID &frameworkId, const ExecutorID &executorId))
 
void unmocked_shutdownExecutor (const process::UPID &from, const FrameworkID &frameworkId, const ExecutorID &executorId)
 
 MOCK_METHOD2 (_shutdownExecutor, void(slave::Framework *framework, slave::Executor *executor))
 
void unmocked__shutdownExecutor (slave::Framework *framework, slave::Executor *executor)
 
 MOCK_METHOD1 (applyOperation, void(const ApplyOperationMessage &message))
 
void unmocked_applyOperation (const ApplyOperationMessage &message)
 
- Public Member Functions inherited from 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)
 
 ~Slave () override
 
void shutdown (const process::UPID &from, const std::string &message)
 
void registered (const process::UPID &from, const SlaveID &slaveId, const MasterSlaveConnection &connection)
 
void reregistered (const process::UPID &from, const SlaveID &slaveId, const std::vector< ReconcileTasksMessage > &reconciliations, const MasterSlaveConnection &connection)
 
void doReliableRegistration (Duration maxBackoff)
 
void handleRunTaskMessage (const process::UPID &from, RunTaskMessage &&runTaskMessage)
 
Option< ErrorvalidateResourceLimitsAndIsolators (const std::vector< TaskInfo > &tasks)
 
virtual void 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)
 
void 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)
 
virtual process::Future< Nothing_run (const FrameworkInfo &frameworkInfo, const ExecutorInfo &executorInfo, const Option< TaskInfo > &task, const Option< TaskGroupInfo > &taskGroup, const std::vector< ResourceVersionUUID > &resourceVersionUuids, const Option< bool > &launchExecutor)
 
virtual void __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)
 
virtual void ___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)
 
void handleRunTaskGroupMessage (const process::UPID &from, RunTaskGroupMessage &&runTaskGroupMessage)
 
virtual void runTaskGroup (const process::UPID &from, const FrameworkInfo &frameworkInfo, const ExecutorInfo &executorInfo, const TaskGroupInfo &taskGroupInfo, const std::vector< ResourceVersionUUID > &resourceVersionUuids, const Option< bool > &launchExecutor)
 
virtual void killTask (const process::UPID &from, const KillTaskMessage &killTaskMessage)
 
void killPendingTask (const FrameworkID &frameworkId, Framework *framework, const TaskID &taskId)
 
void kill (const FrameworkID &frameworkId, Framework *framework, Executor *executor, const TaskID &taskId, const Option< KillPolicy > &killPolicy)
 
virtual void shutdownExecutor (const process::UPID &from, const FrameworkID &frameworkId, const ExecutorID &executorId)
 
virtual void _shutdownExecutor (Framework *framework, Executor *executor)
 
void shutdownFramework (const process::UPID &from, const FrameworkID &frameworkId)
 
void schedulerMessage (const SlaveID &slaveId, const FrameworkID &frameworkId, const ExecutorID &executorId, const std::string &data)
 
void updateFramework (const UpdateFrameworkMessage &message)
 
void checkpointResourceState (const Resources &resources, bool changeTotal)
 
void checkpointResourceState (std::vector< Resource > resources, bool changeTotal)
 
void checkpointResourcesMessage (const std::vector< Resource > &resources)
 
virtual void applyOperation (const ApplyOperationMessage &message)
 
void reconcileOperations (const ReconcileOperationsMessage &message)
 
void subscribe (StreamingHttpConnection< v1::executor::Event > http, const executor::Call::Subscribe &subscribe, Framework *framework, Executor *executor)
 
void registerExecutor (const process::UPID &from, const FrameworkID &frameworkId, const ExecutorID &executorId)
 
void reregisterExecutor (const process::UPID &from, const FrameworkID &frameworkId, const ExecutorID &executorId, const std::vector< TaskInfo > &tasks, const std::vector< StatusUpdate > &updates)
 
void _reregisterExecutor (const process::Future< Nothing > &future, const FrameworkID &frameworkId, const ExecutorID &executorId, const ContainerID &containerId)
 
void executorMessage (const SlaveID &slaveId, const FrameworkID &frameworkId, const ExecutorID &executorId, const std::string &data)
 
void ping (const process::UPID &from, bool connected)
 
void statusUpdate (StatusUpdate update, const Option< process::UPID > &pid)
 
void _statusUpdate (StatusUpdate update, const Option< process::UPID > &pid, const ExecutorID &executorId, const Option< process::Future< ContainerStatus >> &containerStatus)
 
void __statusUpdate (const Option< process::Future< Nothing >> &future, const StatusUpdate &update, const Option< process::UPID > &pid, const ExecutorID &executorId, const ContainerID &containerId, bool checkpoint)
 
void ___statusUpdate (const process::Future< Nothing > &future, const StatusUpdate &update, const Option< process::UPID > &pid)
 
void forward (StatusUpdate update)
 
void sendOperationStatusUpdate (const UpdateOperationStatusMessage &update)
 
void statusUpdateAcknowledgement (const process::UPID &from, const SlaveID &slaveId, const FrameworkID &frameworkId, const TaskID &taskId, const std::string &uuid)
 
void _statusUpdateAcknowledgement (const process::Future< bool > &future, const TaskID &taskId, const FrameworkID &frameworkId, const UUID &uuid)
 
void operationStatusAcknowledgement (const process::UPID &from, const AcknowledgeOperationStatusMessage &acknowledgement)
 
void drain (const process::UPID &from, DrainSlaveMessage &&drainSlaveMessage)
 
void executorLaunched (const FrameworkID &frameworkId, const ExecutorID &executorId, const ContainerID &containerId, const process::Future< Containerizer::LaunchResult > &future)
 
virtual void executorTerminated (const FrameworkID &frameworkId, const ExecutorID &executorId, const process::Future< Option< mesos::slave::ContainerTermination >> &termination)
 
void _checkDiskUsage (const process::Future< double > &usage)
 
void _checkImageDiskUsage (const process::Future< double > &usage)
 
void detected (const process::Future< Option< MasterInfo >> &_master)
 
void initialize () override
 Invoked when a process gets spawned. More...
 
void finalize () override
 Invoked when a process is terminated. More...
 
void exited (const process::UPID &pid) override
 Invoked when a linked process has exited. More...
 
process::Future< Option< Secret > > generateSecret (const FrameworkID &frameworkId, const ExecutorID &executorId, const ContainerID &containerId)
 
void 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)
 
void fileAttached (const process::Future< Nothing > &result, const std::string &path, const std::string &virtualPath)
 
Nothing detachFile (const std::string &path)
 
void attachTaskVolumeDirectory (const ExecutorInfo &executorInfo, const ContainerID &executorContainerId, const Task &task)
 
void detachTaskVolumeDirectories (const ExecutorInfo &executorInfo, const ContainerID &executorContainerId, const std::vector< Task > &tasks)
 
void pingTimeout (process::Future< Option< MasterInfo >> future)
 
virtual void authenticate (Duration minTimeout, Duration maxTimeout)
 
FrameworkgetFramework (const FrameworkID &frameworkId) const
 
ExecutorgetExecutor (const FrameworkID &frameworkId, const ExecutorID &executorId) const
 
ExecutorgetExecutor (const ContainerID &containerId) const
 
ExecutorInfo getExecutorInfo (const FrameworkInfo &frameworkInfo, const TaskInfo &task) const
 
void registerExecutorTimeout (const FrameworkID &frameworkId, const ExecutorID &executorId, const ContainerID &containerId)
 
void reregisterExecutorTimeout ()
 
Duration age (double usage)
 
void checkDiskUsage ()
 
void checkImageDiskUsage ()
 
process::Future< Nothingrecover (const Try< state::State > &state)
 
process::Future< Nothing_recover ()
 
process::Future< Nothing_recoverVolumeGidManager (bool rebooted)
 
process::Future< Option< state::SlaveState > > _recoverTaskStatusUpdates (const Option< state::SlaveState > &slaveState)
 
process::Future< Nothing_recoverContainerizer (const Option< state::SlaveState > &state)
 
process::Future< Nothing_recoverOperations (const Option< state::SlaveState > &state)
 
process::Future< Nothing__recoverOperations (const process::Future< OperationStatusUpdateManagerState > &state)
 
virtual void __recover (const process::Future< Nothing > &future)
 
void recoverFramework (const state::FrameworkState &state, const hashset< ExecutorID > &executorsToRecheckpoint, const hashmap< ExecutorID, hashset< TaskID >> &tasksToRecheckpoint)
 
void removeExecutor (Framework *framework, Executor *executor)
 
virtual void removeFramework (Framework *framework)
 
process::Future< NothinggarbageCollect (const std::string &path)
 
void signaled (int signal, int uid)
 
virtual void qosCorrections ()
 
virtual void _qosCorrections (const process::Future< std::list< mesos::slave::QoSCorrection >> &correction)
 
virtual process::Future< ResourceUsage > usage ()
 
void shutdownExecutorTimeout (const FrameworkID &frameworkId, const ExecutorID &executorId, const ContainerID &containerId)
 
- Public Member Functions inherited from ProtobufProcess< Slave >
 ~ProtobufProcess () override
 
- Public Member Functions inherited from process::Process< Slave >
 ~Process () override
 
PID< Slave > self () const
 Returns the PID of the process. More...
 
- Public Member Functions inherited from process::ProcessBase
 ProcessBase (const std::string &id="")
 
 ~ProcessBase () override
 
const UPIDself () const
 
- Public Member Functions inherited from process::EventConsumer
virtual ~EventConsumer ()
 

Additional Inherited Members

- Public Types inherited from mesos::internal::slave::Slave
enum  State { RECOVERING, DISCONNECTED, RUNNING, TERMINATING }
 
- Public Attributes inherited from mesos::internal::slave::Slave
enum mesos::internal::slave::Slave::State state
 
struct mesos::internal::slave::Slave::RecoveryInfo recoveryInfo
 
- Protected Types inherited from ProtobufProcess< Slave >
using MessageProperty = P(M::*)() const
 
- Protected Types inherited from process::Process< Slave >
typedef Slave Self
 
typedef Slave This
 
- Protected Types inherited from process::ProcessBase
enum  RemoteConnection { RemoteConnection::REUSE, RemoteConnection::RECONNECT }
 Describes the behavior of the link call when the target pid points to a remote process. More...
 
typedef lambda::function< void(const UPID &, const std::string &)> MessageHandler
 Any function which takes a "from" UPID and a message body as arguments. More...
 
typedef lambda::function< Future< http::Response >const http::Request &)> HttpRequestHandler
 Any function which takes a process::http::Request and returns a process::http::Response. More...
 
typedef lambda::function< Future< http::Response > const http::Request &, const Option< http::authentication::Principal > &)> AuthenticatedHttpRequestHandler
 Any function which takes a process::http::Request and an Option<Principal> and returns a process::http::Response. More...
 
- Protected Member Functions inherited from ProtobufProcess< Slave >
void consume (process::MessageEvent &&event) override
 
void send (const process::UPID &to, const google::protobuf::Message &message)
 
void reply (const google::protobuf::Message &message)
 
void install (void(Slave::*method)(const process::UPID &, const M &))
 
void install (void(Slave::*method)(const process::UPID &, M &&))
 
void install (void(Slave::*method)(const process::UPID &))
 
void install (void(Slave::*method)(const process::UPID &, PC...), MessageProperty< M, P >...param)
 
void install (void(Slave::*method)(const M &))
 
void install (void(Slave::*method)(M &&))
 
void install (void(Slave::*method)())
 
void install (void(Slave::*method)(PC...), MessageProperty< M, P >...param)
 
- Protected Member Functions inherited from process::ProcessBase
virtual void serve (Event &&event)
 Invoked when an event is serviced. More...
 
void consume (DispatchEvent &&event) override
 
void consume (HttpEvent &&event) override
 
void consume (ExitedEvent &&event) override
 
void consume (TerminateEvent &&event) override
 
virtual void lost (const UPID &)
 Invoked when a linked process can no longer be monitored. More...
 
void send (const UPID &to, const std::string &name, const char *data=nullptr, size_t length=0)
 Sends the message to the specified UPID. More...
 
void send (const UPID &to, std::string &&name)
 
void send (const UPID &to, std::string &&name, std::string &&data)
 
UPID link (const UPID &pid, const RemoteConnection remote=RemoteConnection::REUSE)
 Links with the specified UPID. More...
 
void install (const std::string &name, const MessageHandler &handler)
 Sets up a handler for messages with the specified name. More...
 
template<typename T >
void install (const std::string &name, void(T::*method)(const UPID &, const std::string &))
 Sets up a handler for messages with the specified name. More...
 
void delegate (const std::string &name, const UPID &pid)
 Delegates incoming messages, with the specified name, to the UPID. More...
 
void route (const std::string &name, const Option< std::string > &help, const HttpRequestHandler &handler, const RouteOptions &options=RouteOptions())
 Sets up a handler for HTTP requests with the specified name. More...
 
template<typename T >
void route (const std::string &name, const Option< std::string > &help, Future< http::Response >(T::*method)(const http::Request &), const RouteOptions &options=RouteOptions())
 Sets up a handler for HTTP requests with the specified name. More...
 
void route (const std::string &name, const std::string &realm, const Option< std::string > &help, const AuthenticatedHttpRequestHandler &handler, const RouteOptions &options=RouteOptions())
 
template<typename T >
void 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())
 Forwards to the correct overload of process::ProcessBase::route(), depending on whether the authentication realm realm is present. More...
 
void provide (const std::string &name, const std::string &path, const std::map< std::string, std::string > &types=mime::types)
 Sets up the default HTTP request handler to provide the static asset(s) at the specified absolute path for the specified name. More...
 
template<typename T >
size_t eventCount ()
 Returns the number of events of the given type currently on the event queue. More...
 

Constructor & Destructor Documentation

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 
)

Member Function Documentation

mesos::internal::tests::MockSlave::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)   
)
void mesos::internal::tests::MockSlave::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 
)
void mesos::internal::tests::MockSlave::unmocked___recover ( const process::Future< Nothing > &  future)
void 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 
)
process::Future<Nothing> 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 
)
void mesos::internal::tests::MockSlave::unmocked__shutdownExecutor ( slave::Framework framework,
slave::Executor executor 
)
void mesos::internal::tests::MockSlave::unmocked_applyOperation ( const ApplyOperationMessage &  message)
void mesos::internal::tests::MockSlave::unmocked_authenticate ( Duration  minTimeout,
Duration  maxTimeout 
)
void mesos::internal::tests::MockSlave::unmocked_executorTerminated ( const FrameworkID &  frameworkId,
const ExecutorID &  executorId,
const process::Future< Option< mesos::slave::ContainerTermination >> &  termination 
)
void mesos::internal::tests::MockSlave::unmocked_killTask ( const process::UPID from,
const KillTaskMessage &  killTaskMessage 
)
void mesos::internal::tests::MockSlave::unmocked_qosCorrections ( )
void mesos::internal::tests::MockSlave::unmocked_removeFramework ( slave::Framework framework)
void 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 
)
void 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 
)
void mesos::internal::tests::MockSlave::unmocked_shutdownExecutor ( const process::UPID from,
const FrameworkID &  frameworkId,
const ExecutorID &  executorId 
)
process::Future<ResourceUsage> mesos::internal::tests::MockSlave::unmocked_usage ( )

The documentation for this class was generated from the following file: