Apache Mesos
Public Member Functions | List of all members
mesos::internal::tests::resource_provider::TestResourceProviderProcess< Event, Call, Driver, ResourceProviderInfo, ResourceProviderID, Resource, Resources, OperationState, Operation > Class Template Reference

#include <mesos.hpp>

Inheritance diagram for mesos::internal::tests::resource_provider::TestResourceProviderProcess< Event, Call, Driver, ResourceProviderInfo, ResourceProviderID, Resource, Resources, OperationState, Operation >:
process::Process< TestResourceProviderProcess< Event, Call, Driver, ResourceProviderInfo, ResourceProviderID, Resource, Resources, OperationState, Operation > > process::ProcessBase process::EventConsumer

Public Member Functions

 TestResourceProviderProcess (const ResourceProviderInfo &_info, const Option< Resources > &_resources=None())
 
 MOCK_METHOD0_T (connected, void())
 
 MOCK_METHOD0_T (disconnected, void())
 
 MOCK_METHOD1_T (subscribed, void(const typename Event::Subscribed &))
 
 MOCK_METHOD1_T (applyOperation, void(const typename Event::ApplyOperation &))
 
 MOCK_METHOD1_T (publishResources, void(const typename Event::PublishResources &))
 
 MOCK_METHOD1_T (acknowledgeOperationStatus, void(const typename Event::AcknowledgeOperationStatus &))
 
 MOCK_METHOD1_T (reconcileOperations, void(const typename Event::ReconcileOperations &))
 
 MOCK_METHOD0_T (teardown, void())
 
void events (std::queue< Event > events)
 
process::Future< Nothingsend (const Call &call)
 
void start (process::Owned< mesos::internal::EndpointDetector > detector, ContentType contentType)
 
void stop ()
 
void connectedDefault ()
 
void subscribedDefault (const typename Event::Subscribed &subscribed)
 
void operationDefault (const typename Event::ApplyOperation &operation)
 
void publishDefault (const typename Event::PublishResources &publish)
 
void teardownDefault ()
 
process::Future< ResourceProviderID > id () const
 
- Public Member Functions inherited from process::Process< TestResourceProviderProcess< Event, Call, Driver, ResourceProviderInfo, ResourceProviderID, Resource, Resources, OperationState, Operation > >
 ~Process () override
 
PID< TestResourceProviderProcess< Event, Call, Driver, ResourceProviderInfo, ResourceProviderID, Resource, Resources, OperationState, Operation > > 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

- Protected Types inherited from process::Process< TestResourceProviderProcess< Event, Call, Driver, ResourceProviderInfo, ResourceProviderID, Resource, Resources, OperationState, Operation > >
typedef TestResourceProviderProcess< Event, Call, Driver, ResourceProviderInfo, ResourceProviderID, Resource, Resources, OperationState, Operation > Self
 
typedef TestResourceProviderProcess< Event, Call, Driver, ResourceProviderInfo, ResourceProviderID, Resource, Resources, OperationState, Operation > 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 process::ProcessBase
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 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

template<typename Event , typename Call , typename Driver , typename ResourceProviderInfo , typename ResourceProviderID , typename Resource , typename Resources , typename OperationState , typename Operation >
mesos::internal::tests::resource_provider::TestResourceProviderProcess< Event, Call, Driver, ResourceProviderInfo, ResourceProviderID, Resource, Resources, OperationState, Operation >::TestResourceProviderProcess ( const ResourceProviderInfo &  _info,
const Option< Resources > &  _resources = None() 
)
inline

Member Function Documentation

template<typename Event , typename Call , typename Driver , typename ResourceProviderInfo , typename ResourceProviderID , typename Resource , typename Resources , typename OperationState , typename Operation >
void mesos::internal::tests::resource_provider::TestResourceProviderProcess< Event, Call, Driver, ResourceProviderInfo, ResourceProviderID, Resource, Resources, OperationState, Operation >::connectedDefault ( )
inline
template<typename Event , typename Call , typename Driver , typename ResourceProviderInfo , typename ResourceProviderID , typename Resource , typename Resources , typename OperationState , typename Operation >
void mesos::internal::tests::resource_provider::TestResourceProviderProcess< Event, Call, Driver, ResourceProviderInfo, ResourceProviderID, Resource, Resources, OperationState, Operation >::events ( std::queue< Event >  events)
inline
template<typename Event , typename Call , typename Driver , typename ResourceProviderInfo , typename ResourceProviderID , typename Resource , typename Resources , typename OperationState , typename Operation >
process::Future<ResourceProviderID> mesos::internal::tests::resource_provider::TestResourceProviderProcess< Event, Call, Driver, ResourceProviderInfo, ResourceProviderID, Resource, Resources, OperationState, Operation >::id ( ) const
inline
template<typename Event , typename Call , typename Driver , typename ResourceProviderInfo , typename ResourceProviderID , typename Resource , typename Resources , typename OperationState , typename Operation >
mesos::internal::tests::resource_provider::TestResourceProviderProcess< Event, Call, Driver, ResourceProviderInfo, ResourceProviderID, Resource, Resources, OperationState, Operation >::MOCK_METHOD0_T ( connected  ,
void()   
)
template<typename Event , typename Call , typename Driver , typename ResourceProviderInfo , typename ResourceProviderID , typename Resource , typename Resources , typename OperationState , typename Operation >
mesos::internal::tests::resource_provider::TestResourceProviderProcess< Event, Call, Driver, ResourceProviderInfo, ResourceProviderID, Resource, Resources, OperationState, Operation >::MOCK_METHOD0_T ( disconnected  ,
void()   
)
template<typename Event , typename Call , typename Driver , typename ResourceProviderInfo , typename ResourceProviderID , typename Resource , typename Resources , typename OperationState , typename Operation >
mesos::internal::tests::resource_provider::TestResourceProviderProcess< Event, Call, Driver, ResourceProviderInfo, ResourceProviderID, Resource, Resources, OperationState, Operation >::MOCK_METHOD0_T ( teardown  ,
void()   
)
template<typename Event , typename Call , typename Driver , typename ResourceProviderInfo , typename ResourceProviderID , typename Resource , typename Resources , typename OperationState , typename Operation >
mesos::internal::tests::resource_provider::TestResourceProviderProcess< Event, Call, Driver, ResourceProviderInfo, ResourceProviderID, Resource, Resources, OperationState, Operation >::MOCK_METHOD1_T ( subscribed  ,
void(const typename Event::Subscribed &)   
)
template<typename Event , typename Call , typename Driver , typename ResourceProviderInfo , typename ResourceProviderID , typename Resource , typename Resources , typename OperationState , typename Operation >
mesos::internal::tests::resource_provider::TestResourceProviderProcess< Event, Call, Driver, ResourceProviderInfo, ResourceProviderID, Resource, Resources, OperationState, Operation >::MOCK_METHOD1_T ( applyOperation  ,
void(const typename Event::ApplyOperation &)   
)
template<typename Event , typename Call , typename Driver , typename ResourceProviderInfo , typename ResourceProviderID , typename Resource , typename Resources , typename OperationState , typename Operation >
mesos::internal::tests::resource_provider::TestResourceProviderProcess< Event, Call, Driver, ResourceProviderInfo, ResourceProviderID, Resource, Resources, OperationState, Operation >::MOCK_METHOD1_T ( publishResources  ,
void(const typename Event::PublishResources &)   
)
template<typename Event , typename Call , typename Driver , typename ResourceProviderInfo , typename ResourceProviderID , typename Resource , typename Resources , typename OperationState , typename Operation >
mesos::internal::tests::resource_provider::TestResourceProviderProcess< Event, Call, Driver, ResourceProviderInfo, ResourceProviderID, Resource, Resources, OperationState, Operation >::MOCK_METHOD1_T ( acknowledgeOperationStatus  ,
void(const typename Event::AcknowledgeOperationStatus &)   
)
template<typename Event , typename Call , typename Driver , typename ResourceProviderInfo , typename ResourceProviderID , typename Resource , typename Resources , typename OperationState , typename Operation >
mesos::internal::tests::resource_provider::TestResourceProviderProcess< Event, Call, Driver, ResourceProviderInfo, ResourceProviderID, Resource, Resources, OperationState, Operation >::MOCK_METHOD1_T ( reconcileOperations  ,
void(const typename Event::ReconcileOperations &)   
)
template<typename Event , typename Call , typename Driver , typename ResourceProviderInfo , typename ResourceProviderID , typename Resource , typename Resources , typename OperationState , typename Operation >
void mesos::internal::tests::resource_provider::TestResourceProviderProcess< Event, Call, Driver, ResourceProviderInfo, ResourceProviderID, Resource, Resources, OperationState, Operation >::operationDefault ( const typename Event::ApplyOperation &  operation)
inline
template<typename Event , typename Call , typename Driver , typename ResourceProviderInfo , typename ResourceProviderID , typename Resource , typename Resources , typename OperationState , typename Operation >
void mesos::internal::tests::resource_provider::TestResourceProviderProcess< Event, Call, Driver, ResourceProviderInfo, ResourceProviderID, Resource, Resources, OperationState, Operation >::publishDefault ( const typename Event::PublishResources &  publish)
inline
template<typename Event , typename Call , typename Driver , typename ResourceProviderInfo , typename ResourceProviderID , typename Resource , typename Resources , typename OperationState , typename Operation >
process::Future<Nothing> mesos::internal::tests::resource_provider::TestResourceProviderProcess< Event, Call, Driver, ResourceProviderInfo, ResourceProviderID, Resource, Resources, OperationState, Operation >::send ( const Call &  call)
inline
template<typename Event , typename Call , typename Driver , typename ResourceProviderInfo , typename ResourceProviderID , typename Resource , typename Resources , typename OperationState , typename Operation >
void mesos::internal::tests::resource_provider::TestResourceProviderProcess< Event, Call, Driver, ResourceProviderInfo, ResourceProviderID, Resource, Resources, OperationState, Operation >::start ( process::Owned< mesos::internal::EndpointDetector detector,
ContentType  contentType 
)
inline
template<typename Event , typename Call , typename Driver , typename ResourceProviderInfo , typename ResourceProviderID , typename Resource , typename Resources , typename OperationState , typename Operation >
void mesos::internal::tests::resource_provider::TestResourceProviderProcess< Event, Call, Driver, ResourceProviderInfo, ResourceProviderID, Resource, Resources, OperationState, Operation >::stop ( )
inline
template<typename Event , typename Call , typename Driver , typename ResourceProviderInfo , typename ResourceProviderID , typename Resource , typename Resources , typename OperationState , typename Operation >
void mesos::internal::tests::resource_provider::TestResourceProviderProcess< Event, Call, Driver, ResourceProviderInfo, ResourceProviderID, Resource, Resources, OperationState, Operation >::subscribedDefault ( const typename Event::Subscribed &  subscribed)
inline
template<typename Event , typename Call , typename Driver , typename ResourceProviderInfo , typename ResourceProviderID , typename Resource , typename Resources , typename OperationState , typename Operation >
void mesos::internal::tests::resource_provider::TestResourceProviderProcess< Event, Call, Driver, ResourceProviderInfo, ResourceProviderID, Resource, Resources, OperationState, Operation >::teardownDefault ( )
inline

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