Value Members

1.  final def !=(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

2.  final def ##(): Int

   Definition Classes

   AnyRef → Any

3.  final def ==(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

4.  def asCluster[A](nodes: RaftNode[A]*)(implicit arg0: ClassTag[A], sched: Scheduler): Map[NodeId, RaftPipe[A, Observer, Observable, Observable, RaftNode[A]]]

   Create a cluster of the input nodes, so that each knows about its peers, and sends messages to/receives messages from each of them

5.  final def asInstanceOf[T0]: T0

   Definition Classes

   Any

6.  def clone(): AnyRef

   Attributes

   protected[java.lang]

   Definition Classes

   AnyRef

   Annotations

   @native() @throws( ... )

7.  final def eq(arg0: AnyRef): Boolean

   Definition Classes

   AnyRef

8.  def equals(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

9.  def finalize(): Unit

   Attributes

   protected[java.lang]

   Definition Classes

   AnyRef

   Annotations

   @throws( classOf[java.lang.Throwable] )

10.  final def getClass(): Class[_]

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

11.  def hashCode(): Int

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

12.  def inMemoryClusterOf[A](size: Int)(implicit arg0: ClassTag[A], sched: Scheduler, clock: RaftClock): Map[NodeId, RaftPipe[A, Observer, Observable, Observable, RaftNode[A]]]
13.  final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

14.  final def ne(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

15.  def newSingleNode[A](id: NodeId, dataDir: Path, maxAppendSize: Int = 10)(implicit arg0: FromBytes[A], arg1: ToBytes[A], clock: RaftClock): RaftNode[A]

    convenience method for created a default RaftNode which has an empty cluster

    convenience method for created a default RaftNode which has an empty cluster

    returns

    a new RaftNode

16.  final def notify(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

17.  final def notifyAll(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

18.  implicit def observableAsPublisher(implicit scheduler: Scheduler): AsPublisher[Observable]

    Definition Classes

    LowPriorityRiffMonixImplicits

19.  def observablePipeForNode[A](n: RaftNode[A])(implicit arg0: ClassTag[A], sched: Scheduler): RaftPipe[A, Observer, Observable, Observable, RaftNode[A]]
20.  implicit def observerAsSubscriber(implicit scheduler: Scheduler): AsSubscriber[Observer]

    Definition Classes

    LowPriorityRiffMonixImplicits

21.  def raftPipeForHandler[A](handler: RaftNode[A])(implicit arg0: ClassTag[A], sched: Scheduler): RaftPipe[A, Observer, Observable, Observable, RaftNode[A]]

    Wraps the given RaftMessageHandler in a RaftPipe

    Wraps the given RaftMessageHandler in a RaftPipe

    returns

    a pipe which invokes the handler to produce its outputs

22.  def singleNode[A](id: NodeId, dataDir: Path)(implicit arg0: FromBytes[A], arg1: ToBytes[A], arg2: ClassTag[A], sched: Scheduler): RaftPipe[A, Observer, Observable, Observable, RaftNode[A]]
23.  def singleNode[A](id: NodeId = "single-node-cluster")(implicit arg0: FromBytes[A], arg1: ToBytes[A], arg2: ClassTag[A], sched: Scheduler): RaftPipe[A, Observer, Observable, Observable, RaftNode[A]]
24.  final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes

    AnyRef

25.  def toString(): String

    Definition Classes

    AnyRef → Any

26.  final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

27.  final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

28.  final def wait(arg0: Long): Unit

    Definition Classes

    AnyRef

    Annotations

    @native() @throws( ... )

29.  def wireTogetherMonix[A, H <: RaftMessageHandler[A]](raftInstById: Map[NodeId, RaftPipe[A, Observer, Observable, Observable, H]])(implicit s: Scheduler): Unit