Type Members

1.  trait AppendOps[A] extends AnyRef
2.  trait CommittedOps[A] extends AnyRef

   Represents observable operations which can be performed on a riff.raft.log.RaftLog for committed log entries

   Represents observable operations which can be performed on a riff.raft.log.RaftLog for committed log entries

   A

   the log entry type

3.  type LogAppended = LogAppendSuccess
4.  type LogCommitted = Seq[LogCoords]
5.  case class ObservableLog[A](underlying: RaftLog[A])(implicit scheduler: Scheduler) extends DelegateLog[A] with CommittedOps[A] with AppendOps[A] with Product with Serializable

   Wraps a riff.raft.log.RaftLog for a local node which exposes Observable data publishers for: $ Appended LogCoords $ Appended LogEntry $ Appended LogCoords from a historic index $ Appended LogEntry from a historic index $ Committed LogCoords $ Committed LogEntry $ Committed LogCoords from a historic index $ Committed LogEntry from a historic index

   Wraps a riff.raft.log.RaftLog for a local node which exposes Observable data publishers for: $ Appended LogCoords $ Appended LogEntry $ Appended LogCoords from a historic index $ Appended LogEntry from a historic index $ Committed LogCoords $ Committed LogEntry $ Committed LogCoords from a historic index $ Committed LogEntry from a historic index

   underlying

   the wrapped log

   scheduler

   the scheduler to use for the observables