Package org.apache.pekko.cluster.ddata

Class WriteAggregator$

  • public class WriteAggregator$
extends java.lang.Object
    INTERNAL API

    • Field Summary

      Fields 
      Modifier and Type Field Description
      static WriteAggregator$ MODULE$
      Static reference to the singleton instance of this Scala object.

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      Props props​(Key<ReplicatedData> key, org.apache.pekko.cluster.ddata.Replicator.Internal.DataEnvelope envelope, scala.Option<org.apache.pekko.cluster.ddata.Replicator.Internal.Delta> delta, Replicator.WriteConsistency consistency, scala.Option<java.lang.Object> req, UniqueAddress selfUniqueAddress, scala.collection.immutable.Vector<UniqueAddress> nodes, scala.collection.immutable.Set<UniqueAddress> unreachable, boolean shuffle, ActorRef replyTo, boolean durable)  

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Field Detail

      • MODULE$

        public static final WriteAggregator$ MODULE$
        Static reference to the singleton instance of this Scala object.

    • Constructor Detail

      • WriteAggregator$

        public WriteAggregator$()

    • Method Detail

      • props

        public Props props​(Key<ReplicatedData> key,
                   org.apache.pekko.cluster.ddata.Replicator.Internal.DataEnvelope envelope,
                   scala.Option<org.apache.pekko.cluster.ddata.Replicator.Internal.Delta> delta,
                   Replicator.WriteConsistency consistency,
                   scala.Option<java.lang.Object> req,
                   UniqueAddress selfUniqueAddress,
                   scala.collection.immutable.Vector<UniqueAddress> nodes,
                   scala.collection.immutable.Set<UniqueAddress> unreachable,
                   boolean shuffle,
                   ActorRef replyTo,
                   boolean durable)