17 #ifndef __LOG_LOG_HPP__ 18 #define __LOG_LOG_HPP__ 48 const std::string&
path,
49 const std::set<process::UPID>&
pids,
55 const std::string& path,
56 const std::string& servers,
58 const std::string& znode,
84 const std::set<zookeeper::Group::Membership>& memberships);
86 void failed(
const std::string&
message);
92 const bool autoInitialize;
97 std::list<process::Promise<process::Shared<Replica>>*> promises;
113 return network->
watch(0u)
158 const std::list<Action>& actions);
166 std::list<process::Promise<Nothing>*> promises;
177 const std::string& bytes);
201 void failed(
const std::string&
message,
const std::string& reason);
207 std::list<process::Promise<Nothing>*> promises;
217 #endif // __LOG_LOG_HPP__
Try< Bytes > size(const std::string &path, const FollowSymlink follow=FollowSymlink::FOLLOW_SYMLINK)
Definition: stat.hpp:130
void finalize() override
Invoked when a process is terminated.
friend class LogReaderProcess
Definition: log.hpp:72
Definition: duration.hpp:32
Try< Nothing > start(const std::string &name)
Starts the slice with the given name (via 'systemctl start <name>').
process::Future< size_t > watch(size_t size, WatchMode mode=NOT_EQUAL_TO) const
Definition: network.hpp:368
process::Future< process::Shared< Replica > > recover()
hashmap< std::string, MessageHandler > message
Definition: process.hpp:455
An "untyped" PID, used to encapsulate the process ID for lower-layer abstractions (eg...
Definition: pid.hpp:39
Try< Nothing > append(const std::string &path, const google::protobuf::Message &message, bool sync=false)
Definition: protobuf.hpp:174
LogProcess(size_t _quorum, const std::string &path, const std::set< process::UPID > &pids, bool _autoInitialize, const Option< std::string > &metricsPrefix)
Future< X > then(lambda::CallableOnce< Future< X >(const T &)> f) const
Definition: future.hpp:1576
Definition: coordinator.hpp:40
Definition: attributes.hpp:24
Result< Credentials > read(const Path &path)
Definition: credentials.hpp:35
std::string error(const std::string &msg, uint32_t code)
void discarded(Future< U > future)
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))
friend class LogWriterProcess
Definition: log.hpp:73
void initialize() override
Invoked when a process gets spawned.
Definition: process.hpp:505
Definition: metrics.hpp:31
Try< std::set< pid_t > > pids()
Definition: freebsd.hpp:62
PID< MetricsProcess > metrics
Definition: future.hpp:58