Apache Mesos
|
#include <mock_docker.hpp>
Public Member Functions | |
MockDockerContainerizerProcess (const slave::Flags &flags, slave::Fetcher *fetcher, const process::Owned< mesos::slave::ContainerLogger > &logger, const process::Shared< Docker > &docker, const Option< NvidiaComponents > &nvidia=None()) | |
virtual | ~MockDockerContainerizerProcess () |
MOCK_METHOD1 (fetch, process::Future< Nothing >(const ContainerID &)) | |
MOCK_METHOD1 (pull, process::Future< Nothing >(const ContainerID &)) | |
process::Future< Nothing > | _fetch (const ContainerID &containerId) |
process::Future< Nothing > | _pull (const ContainerID &containerId) |
![]() | |
DockerContainerizerProcess (const Flags &_flags, Fetcher *_fetcher, const process::Owned< mesos::slave::ContainerLogger > &_logger, process::Shared< Docker > _docker, const Option< NvidiaComponents > &_nvidia) | |
virtual process::Future< Nothing > | recover (const Option< state::SlaveState > &state) |
virtual process::Future < Containerizer::LaunchResult > | launch (const ContainerID &containerId, const mesos::slave::ContainerConfig &containerConfig, const std::map< std::string, std::string > &environment, const Option< std::string > &pidCheckpointPath) |
virtual process::Future< Nothing > | update (const ContainerID &containerId, const Resources &resources, bool force) |
virtual process::Future < ResourceStatistics > | usage (const ContainerID &containerId) |
virtual process::Future < ContainerStatus > | status (const ContainerID &containerId) |
virtual process::Future < Option < mesos::slave::ContainerTermination > > | wait (const ContainerID &containerId) |
virtual process::Future< bool > | destroy (const ContainerID &containerId, bool killed=true) |
virtual process::Future< Nothing > | fetch (const ContainerID &containerId) |
virtual process::Future< Nothing > | pull (const ContainerID &containerId) |
virtual process::Future < hashset< ContainerID > > | containers () |
![]() | |
virtual | ~Process () |
PID< DockerContainerizerProcess > | self () const |
Returns the PID of the process. More... | |
![]() | |
ProcessBase (const std::string &id="") | |
virtual | ~ProcessBase () |
const UPID & | self () const |
![]() | |
virtual | ~EventConsumer () |
Additional Inherited Members | |
![]() | |
typedef DockerContainerizerProcess | Self |
typedef DockerContainerizerProcess | This |
![]() | |
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... | |
![]() | |
virtual void | serve (Event &&event) |
Invoked when an event is serviced. More... | |
void | consume (MessageEvent &&event) override |
void | consume (DispatchEvent &&event) override |
void | consume (HttpEvent &&event) override |
void | consume (ExitedEvent &&event) override |
void | consume (TerminateEvent &&event) override |
virtual void | initialize () |
Invoked when a process gets spawned. More... | |
virtual void | finalize () |
Invoked when a process is terminated. More... | |
virtual void | exited (const UPID &) |
Invoked when a linked process has exited. More... | |
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 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()) |
Sets up a handler for HTTP requests with the specified name. 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... | |
mesos::internal::tests::MockDockerContainerizerProcess::MockDockerContainerizerProcess | ( | const slave::Flags & | flags, |
slave::Fetcher * | fetcher, | ||
const process::Owned< mesos::slave::ContainerLogger > & | logger, | ||
const process::Shared< Docker > & | docker, | ||
const Option< NvidiaComponents > & | nvidia = None() |
||
) |
|
virtual |
|
inline |
|
inline |
mesos::internal::tests::MockDockerContainerizerProcess::MOCK_METHOD1 | ( | fetch | , |
process::Future< Nothing > | const ContainerID & | ||
) |
mesos::internal::tests::MockDockerContainerizerProcess::MOCK_METHOD1 | ( | pull | , |
process::Future< Nothing > | const ContainerID & | ||
) |