Class ReadWriteAggregator

    • Constructor Detail

      • ReadWriteAggregator

        public ReadWriteAggregator()
    • Method Detail

      • MaxSecondaryNodes

        public static int MaxSecondaryNodes()
      • calculateMajorityWithMinCap

        public static int calculateMajorityWithMinCap​(int minCap,
                                                      int numberOfNodes)
      • context

        public ActorContext context()
        Description copied from interface: Actor
        Scala API: Stores the context for this actor, including self, and sender. It is implicit to support operations such as forward.

        WARNING: Only valid within the Actor itself, so do not close over it and publish it to other threads!

        ActorContext is the Scala API. getContext returns a AbstractActor.ActorContext, which is the Java API of the actor context.

        Specified by:
        context in interface Actor
        Returns:
        (undocumented)
      • self

        public final ActorRef self()
        Description copied from interface: Actor
        The 'self' field holds the ActorRef for this actor.

        Can be used to send messages to itself:
         self ! message
         
        Specified by:
        self in interface Actor
        Returns:
        (undocumented)
      • akka$actor$Actor$_setter_$self_$eq

        protected final void akka$actor$Actor$_setter_$self_$eq​(ActorRef x$1)
        Description copied from interface: Actor
        The 'self' field holds the ActorRef for this actor.

        Can be used to send messages to itself:
         self ! message
         
        Specified by:
        akka$actor$Actor$_setter_$self_$eq in interface Actor
        Parameters:
        x$1 - (undocumented)
      • timeout

        public abstract scala.concurrent.duration.FiniteDuration timeout()
      • nodes

        public abstract scala.collection.immutable.Set<UniqueAddress> nodes()
      • unreachable

        public abstract scala.collection.immutable.Set<UniqueAddress> unreachable()
      • reachableNodes

        public scala.collection.immutable.Set<UniqueAddress> reachableNodes()
      • sendToSecondarySchedule

        public Cancellable sendToSecondarySchedule()
      • sendToSecondarySchedule_$eq

        public void sendToSecondarySchedule_$eq​(Cancellable x$1)
      • timeoutSchedule

        public Cancellable timeoutSchedule()
      • timeoutSchedule_$eq

        public void timeoutSchedule_$eq​(Cancellable x$1)
      • remaining

        public scala.collection.immutable.Set<Address> remaining()
      • remaining_$eq

        public void remaining_$eq​(scala.collection.immutable.Set<Address> x$1)
      • doneWhenRemainingSize

        public abstract int doneWhenRemainingSize()
      • primaryAndSecondaryNodes

        public scala.Tuple2<scala.collection.immutable.Vector<UniqueAddress>,​scala.collection.immutable.Vector<UniqueAddress>> primaryAndSecondaryNodes​(boolean requiresCausalDeliveryOfDeltas)
      • postStop

        public void postStop()
        Description copied from interface: Actor
        User overridable callback.

        Is called asynchronously after 'actor.stop()' is invoked. Empty default implementation.
        Specified by:
        postStop in interface Actor