Apache Mesos
Namespaces | Classes | Functions
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< Nothingcatchup (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< Nothinglearn (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 
)