mesos::internal::log Namespace Reference

Namespaces
	protocol
	tool

Classes
class	Coordinator
class	LevelDBStorage
class	LogProcess
class	LogReaderProcess
class	LogWriterProcess
struct	Metrics
class	Replica
class	Storage

Functions
process::Future< Nothing >	catchup (size_t quorum, const process::Shared< Replica > &replica, const process::Shared< Network > &network, const Option< uint64_t > &proposal, const IntervalSet< uint64_t > &positions, const Duration &timeout=Seconds(10))
process::Future< uint64_t >	catchup (size_t quorum, const process::Shared< Replica > &replica, const process::Shared< Network > &network, const Option< uint64_t > &proposal=None(), const Duration &timeout=Seconds(10))
process::Future< PromiseResponse >	promise (size_t quorum, const process::Shared< Network > &network, uint64_t proposal, const Option< uint64_t > &position=None())
process::Future< WriteResponse >	write (size_t quorum, const process::Shared< Network > &network, uint64_t proposal, const Action &action)
process::Future< Nothing >	learn (const process::Shared< Network > &network, const Action &action)
process::Future< Action >	fill (size_t quorum, const process::Shared< Network > &network, uint64_t proposal, uint64_t position)
process::Future< Option< RecoverResponse > >	runRecoverProtocol (size_t quorum, const process::Shared< Network > &network, const Metadata::Status &status, bool autoInitialize, const Duration &timeout=Seconds(10))
process::Future< process::Owned< Replica > >	recover (size_t quorum, const process::Owned< Replica > &replica, const process::Shared< Network > &network, bool autoInitialize=false)
std::ostream &	operator<< (std::ostream &stream, const Action::Type &type)
std::ostream &	operator<< (std::ostream &stream, const Metadata::Status &status)

Function Documentation

process::Future<Nothing> mesos::internal::log::catchup	(	size_t	quorum,
		const process::Shared< Replica > &	replica,
		const process::Shared< Network > &	network,
		const Option< uint64_t > &	proposal,
		const IntervalSet< uint64_t > &	positions,
		const Duration &	timeout = Seconds(10)
	)

process::Future<uint64_t> mesos::internal::log::catchup	(	size_t	quorum,
		const process::Shared< Replica > &	replica,
		const process::Shared< Network > &	network,
		const Option< uint64_t > &	proposal = None(),
		const Duration &	timeout = Seconds(10)
	)

process::Future<Action> mesos::internal::log::fill	(	size_t	quorum,
		const process::Shared< Network > &	network,
		uint64_t	proposal,
		uint64_t	position
	)

process::Future<Nothing> mesos::internal::log::learn	(	const process::Shared< Network > &	network,
		const Action &	action
	)

std::ostream& mesos::internal::log::operator<< ( std::ostream &  stream, const Action::Type &  type  )

inline

std::ostream& mesos::internal::log::operator<< ( std::ostream &  stream, const Metadata::Status &  status  )

inline

process::Future<PromiseResponse> mesos::internal::log::promise	(	size_t	quorum,
		const process::Shared< Network > &	network,
		uint64_t	proposal,
		const Option< uint64_t > &	position = None()
	)

process::Future<process::Owned<Replica> > mesos::internal::log::recover	(	size_t	quorum,
		const process::Owned< Replica > &	replica,
		const process::Shared< Network > &	network,
		bool	autoInitialize = false
	)

process::Future<Option<RecoverResponse> > mesos::internal::log::runRecoverProtocol	(	size_t	quorum,
		const process::Shared< Network > &	network,
		const Metadata::Status &	status,
		bool	autoInitialize,
		const Duration &	timeout = Seconds(10)
	)

process::Future<WriteResponse> mesos::internal::log::write	(	size_t	quorum,
		const process::Shared< Network > &	network,
		uint64_t	proposal,
		const Action &	action
	)