Path Lines of Code distributed-data/src/main/protobuf/ReplicatedDataMessages.proto 130 distributed-data/src/main/protobuf/ReplicatorMessages.proto 136 distributed-data/src/main/scala-2/org/apache/pekko/cluster/ddata/GSet.scala 53 distributed-data/src/main/scala-3/org/apache/pekko/cluster/ddata/GSet.scala 51 distributed-data/src/main/scala/org/apache/pekko/cluster/ddata/DeltaPropagationSelector.scala 149 distributed-data/src/main/scala/org/apache/pekko/cluster/ddata/DistributedData.scala 41 distributed-data/src/main/scala/org/apache/pekko/cluster/ddata/DurableStore.scala 237 distributed-data/src/main/scala/org/apache/pekko/cluster/ddata/EstimatedSize.scala 7 distributed-data/src/main/scala/org/apache/pekko/cluster/ddata/FastMerge.scala 16 distributed-data/src/main/scala/org/apache/pekko/cluster/ddata/Flag.scala 23 distributed-data/src/main/scala/org/apache/pekko/cluster/ddata/GCounter.scala 91 distributed-data/src/main/scala/org/apache/pekko/cluster/ddata/Key.scala 14 distributed-data/src/main/scala/org/apache/pekko/cluster/ddata/LWWMap.scala 99 distributed-data/src/main/scala/org/apache/pekko/cluster/ddata/LWWRegister.scala 92 distributed-data/src/main/scala/org/apache/pekko/cluster/ddata/ORMap.scala 385 distributed-data/src/main/scala/org/apache/pekko/cluster/ddata/ORMultiMap.scala 211 distributed-data/src/main/scala/org/apache/pekko/cluster/ddata/ORSet.scala 372 distributed-data/src/main/scala/org/apache/pekko/cluster/ddata/PNCounter.scala 110 distributed-data/src/main/scala/org/apache/pekko/cluster/ddata/PNCounterMap.scala 94 distributed-data/src/main/scala/org/apache/pekko/cluster/ddata/PayloadSizeAggregator.scala 43 distributed-data/src/main/scala/org/apache/pekko/cluster/ddata/PruningState.scala 39 distributed-data/src/main/scala/org/apache/pekko/cluster/ddata/ReplicatedData.scala 46 distributed-data/src/main/scala/org/apache/pekko/cluster/ddata/Replicator.scala 1946 distributed-data/src/main/scala/org/apache/pekko/cluster/ddata/VersionVector.scala 201 distributed-data/src/main/scala/org/apache/pekko/cluster/ddata/protobuf/ReplicatedDataSerializer.scala 886 distributed-data/src/main/scala/org/apache/pekko/cluster/ddata/protobuf/ReplicatorMessageSerializer.scala 493 distributed-data/src/main/scala/org/apache/pekko/cluster/ddata/protobuf/SerializationSupport.scala 138 distributed-data/src/multi-jvm/scala/org/apache/pekko/cluster/ddata/DurableDataSpec.scala 266 distributed-data/src/multi-jvm/scala/org/apache/pekko/cluster/ddata/DurablePruningSpec.scala 175 distributed-data/src/multi-jvm/scala/org/apache/pekko/cluster/ddata/JepsenInspiredInsertSpec.scala 232 distributed-data/src/multi-jvm/scala/org/apache/pekko/cluster/ddata/PerformanceSpec.scala 236 distributed-data/src/multi-jvm/scala/org/apache/pekko/cluster/ddata/ReplicatorChaosSpec.scala 197 distributed-data/src/multi-jvm/scala/org/apache/pekko/cluster/ddata/ReplicatorDeltaSpec.scala 351 distributed-data/src/multi-jvm/scala/org/apache/pekko/cluster/ddata/ReplicatorGossipSpec.scala 99 distributed-data/src/multi-jvm/scala/org/apache/pekko/cluster/ddata/ReplicatorMapDeltaSpec.scala 392 distributed-data/src/multi-jvm/scala/org/apache/pekko/cluster/ddata/ReplicatorORSetDeltaSpec.scala 129 distributed-data/src/multi-jvm/scala/org/apache/pekko/cluster/ddata/ReplicatorPruningSpec.scala 227 distributed-data/src/multi-jvm/scala/org/apache/pekko/cluster/ddata/ReplicatorSpec.scala 509 distributed-data/src/multi-jvm/scala/org/apache/pekko/cluster/ddata/STMultiNodeSpec.scala 9