Apache Mesos: mesos::internal::StatusUpdateManagerProcess< IDType, CheckpointType, UpdateType > Class Template Reference

Apache Mesos

#include <status_update_manager_process.hpp>

Inheritance diagram for mesos::internal::StatusUpdateManagerProcess< IDType, CheckpointType, UpdateType >:

Classes
struct	State

Public Member Functions
	StatusUpdateManagerProcess (const std::string &id, const std::string &_statusUpdateType)

	StatusUpdateManagerProcess (const StatusUpdateManagerProcess &that)=delete

StatusUpdateManagerProcess &	operator= (const StatusUpdateManagerProcess &that)=delete

void	initialize (const lambda::function< void(const UpdateType &)> &_forwardCallback, const lambda::function< const std::string(const IDType &)> &_getPath)

process::Future< Nothing >	update (const UpdateType &update, const IDType &streamId, bool checkpoint)

process::Future< bool >	acknowledgement (const IDType &streamId, const id::UUID &uuid)

process::Future< State >	recover (const std::list< IDType > &streamIds, bool strict)

void	cleanup (const FrameworkID &frameworkId)

void	pause ()

void	resume ()

Public Member Functions inherited from ProtobufProcess< StatusUpdateManagerProcess< IDType, CheckpointType, UpdateType > >
	~ProtobufProcess () override

Public Member Functions inherited from process::Process< StatusUpdateManagerProcess< IDType, CheckpointType, UpdateType > >
	~Process () override

PID< StatusUpdateManagerProcess< IDType, CheckpointType, UpdateType > >	self () const
	Returns the `PID` of the process. More...

Public Member Functions inherited from process::ProcessBase
	ProcessBase (const std::string &id="")

	~ProcessBase () override

const UPID &	self () const

Public Member Functions inherited from process::EventConsumer
virtual	~EventConsumer ()

Additional Inherited Members
Protected Types inherited from ProtobufProcess< StatusUpdateManagerProcess< IDType, CheckpointType, UpdateType > >
using	MessageProperty = P(M::*)() const

Protected Types inherited from process::Process< StatusUpdateManagerProcess< IDType, CheckpointType, UpdateType > >
typedef StatusUpdateManagerProcess< IDType, CheckpointType, UpdateType >	Self

typedef StatusUpdateManagerProcess< IDType, CheckpointType, UpdateType >	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< StatusUpdateManagerProcess< IDType, CheckpointType, UpdateType > >
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(StatusUpdateManagerProcess< IDType, CheckpointType, UpdateType >::*method)(const process::UPID &, const M &))

void	install (void(StatusUpdateManagerProcess< IDType, CheckpointType, UpdateType >::*method)(const process::UPID &, M &&))

void	install (void(StatusUpdateManagerProcess< IDType, CheckpointType, UpdateType >::*method)(const process::UPID &))

void	install (void(StatusUpdateManagerProcess< IDType, CheckpointType, UpdateType >::*method)(const process::UPID &, PC...), MessageProperty< M, P >...param)

void	install (void(StatusUpdateManagerProcess< IDType, CheckpointType, UpdateType >::*method)(const M &))

void	install (void(StatusUpdateManagerProcess< IDType, CheckpointType, UpdateType >::*method)(M &&))

void	install (void(StatusUpdateManagerProcess< IDType, CheckpointType, UpdateType >::*method)())

void	install (void(StatusUpdateManagerProcess< IDType, CheckpointType, UpdateType >::*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	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 IDType , typename CheckpointType , typename UpdateType >

mesos::internal::StatusUpdateManagerProcess< IDType, CheckpointType, UpdateType >::StatusUpdateManagerProcess	(	const std::string &	id,
		const std::string &	_statusUpdateType
	)

inline

template<typename IDType , typename CheckpointType , typename UpdateType >

mesos::internal::StatusUpdateManagerProcess< IDType, CheckpointType, UpdateType >::StatusUpdateManagerProcess ( const StatusUpdateManagerProcess< IDType, CheckpointType, UpdateType > & that )

delete

Member Function Documentation

template<typename IDType , typename CheckpointType , typename UpdateType >

process::Future<bool> mesos::internal::StatusUpdateManagerProcess< IDType, CheckpointType, UpdateType >::acknowledgement	(	const IDType &	streamId,
		const id::UUID &	uuid
	)

inline

template<typename IDType , typename CheckpointType , typename UpdateType >

void mesos::internal::StatusUpdateManagerProcess< IDType, CheckpointType, UpdateType >::cleanup ( const FrameworkID & frameworkId )

inline

template<typename IDType , typename CheckpointType , typename UpdateType >

void mesos::internal::StatusUpdateManagerProcess< IDType, CheckpointType, UpdateType >::initialize	(	const lambda::function< void(const UpdateType &)> &	_forwardCallback,
		const lambda::function< const std::string(const IDType &)> &	_getPath
	)

inline

template<typename IDType , typename CheckpointType , typename UpdateType >

StatusUpdateManagerProcess& mesos::internal::StatusUpdateManagerProcess< IDType, CheckpointType, UpdateType >::operator= ( const StatusUpdateManagerProcess< IDType, CheckpointType, UpdateType > & that )

delete

template<typename IDType , typename CheckpointType , typename UpdateType >

void mesos::internal::StatusUpdateManagerProcess< IDType, CheckpointType, UpdateType >::pause ( )

inline

template<typename IDType , typename CheckpointType , typename UpdateType >

process::Future<State> mesos::internal::StatusUpdateManagerProcess< IDType, CheckpointType, UpdateType >::recover	(	const std::list< IDType > &	streamIds,
		bool	strict
	)

inline

template<typename IDType , typename CheckpointType , typename UpdateType >

void mesos::internal::StatusUpdateManagerProcess< IDType, CheckpointType, UpdateType >::resume ( )

inline

template<typename IDType , typename CheckpointType , typename UpdateType >

process::Future<Nothing> mesos::internal::StatusUpdateManagerProcess< IDType, CheckpointType, UpdateType >::update	(	const UpdateType &	update,
		const IDType &	streamId,
		bool	checkpoint
	)

inline

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

src/status_update_manager/status_update_manager_process.hpp