Path	Lines of Code
persistence-query/src/main/protobuf/QueryMessages.proto	28
persistence-query/src/main/scala/org/apache/pekko/persistence/query/DurableStateChange.scala	28
persistence-query/src/main/scala/org/apache/pekko/persistence/query/EventEnvelope.scala	73
persistence-query/src/main/scala/org/apache/pekko/persistence/query/Offset.scala	54
persistence-query/src/main/scala/org/apache/pekko/persistence/query/PersistenceQuery.scala	38
persistence-query/src/main/scala/org/apache/pekko/persistence/query/ReadJournalProvider.scala	5
persistence-query/src/main/scala/org/apache/pekko/persistence/query/internal/QuerySerializer.scala	177
persistence-query/src/main/scala/org/apache/pekko/persistence/query/javadsl/CurrentEventsByPersistenceIdQuery.scala	11
persistence-query/src/main/scala/org/apache/pekko/persistence/query/javadsl/CurrentEventsByTagQuery.scala	8
persistence-query/src/main/scala/org/apache/pekko/persistence/query/javadsl/CurrentPersistenceIdsQuery.scala	7
persistence-query/src/main/scala/org/apache/pekko/persistence/query/javadsl/DurableStateStorePagedPersistenceIdsQuery.scala	9
persistence-query/src/main/scala/org/apache/pekko/persistence/query/javadsl/DurableStateStoreQuery.scala	11
persistence-query/src/main/scala/org/apache/pekko/persistence/query/javadsl/EventsByPersistenceIdQuery.scala	11
persistence-query/src/main/scala/org/apache/pekko/persistence/query/javadsl/EventsByTagQuery.scala	8
persistence-query/src/main/scala/org/apache/pekko/persistence/query/javadsl/PagedPersistenceIdsQuery.scala	8
persistence-query/src/main/scala/org/apache/pekko/persistence/query/javadsl/PersistenceIdsQuery.scala	7
persistence-query/src/main/scala/org/apache/pekko/persistence/query/javadsl/ReadJournal.scala	2
persistence-query/src/main/scala/org/apache/pekko/persistence/query/journal/leveldb/AllPersistenceIdsStage.scala	53
persistence-query/src/main/scala/org/apache/pekko/persistence/query/journal/leveldb/Buffer.scala	25
persistence-query/src/main/scala/org/apache/pekko/persistence/query/journal/leveldb/EventsByPersistenceIdStage.scala	128
persistence-query/src/main/scala/org/apache/pekko/persistence/query/journal/leveldb/EventsByTagStage.scala	126
persistence-query/src/main/scala/org/apache/pekko/persistence/query/journal/leveldb/LeveldbReadJournalProvider.scala	14
persistence-query/src/main/scala/org/apache/pekko/persistence/query/journal/leveldb/javadsl/LeveldbReadJournal.scala	37
persistence-query/src/main/scala/org/apache/pekko/persistence/query/journal/leveldb/scaladsl/LeveldbReadJournal.scala	140
persistence-query/src/main/scala/org/apache/pekko/persistence/query/scaladsl/CurrentEventsByPersistenceIdQuery.scala	11
persistence-query/src/main/scala/org/apache/pekko/persistence/query/scaladsl/CurrentEventsByTagQuery.scala	8
persistence-query/src/main/scala/org/apache/pekko/persistence/query/scaladsl/CurrentPersistenceIdsQuery.scala	7
persistence-query/src/main/scala/org/apache/pekko/persistence/query/scaladsl/DurableStateStorePagedPersistenceIdsQuery.scala	8
persistence-query/src/main/scala/org/apache/pekko/persistence/query/scaladsl/DurableStateStoreQuery.scala	11
persistence-query/src/main/scala/org/apache/pekko/persistence/query/scaladsl/EventsByPersistenceIdQuery.scala	11
persistence-query/src/main/scala/org/apache/pekko/persistence/query/scaladsl/EventsByTagQuery.scala	8
persistence-query/src/main/scala/org/apache/pekko/persistence/query/scaladsl/PagedPersistenceIdsQuery.scala	7
persistence-query/src/main/scala/org/apache/pekko/persistence/query/scaladsl/PersistenceIdsQuery.scala	7
persistence-query/src/main/scala/org/apache/pekko/persistence/query/scaladsl/ReadJournal.scala	2
persistence-query/src/main/scala/org/apache/pekko/persistence/query/typed/EventEnvelope.scala	77
persistence-query/src/main/scala/org/apache/pekko/persistence/query/typed/javadsl/CurrentEventsBySliceQuery.scala	19
persistence-query/src/main/scala/org/apache/pekko/persistence/query/typed/javadsl/DurableStateStoreBySliceQuery.scala	24
persistence-query/src/main/scala/org/apache/pekko/persistence/query/typed/javadsl/EventTimestampQuery.scala	11
persistence-query/src/main/scala/org/apache/pekko/persistence/query/typed/javadsl/EventsBySliceQuery.scala	19
persistence-query/src/main/scala/org/apache/pekko/persistence/query/typed/javadsl/LoadEventQuery.scala	10
persistence-query/src/main/scala/org/apache/pekko/persistence/query/typed/scaladsl/CurrentEventsBySliceQuery.scala	19
persistence-query/src/main/scala/org/apache/pekko/persistence/query/typed/scaladsl/DurableStateStoreBySliceQuery.scala	24
persistence-query/src/main/scala/org/apache/pekko/persistence/query/typed/scaladsl/EventTimestampQuery.scala	10
persistence-query/src/main/scala/org/apache/pekko/persistence/query/typed/scaladsl/EventsBySliceQuery.scala	19
persistence-query/src/main/scala/org/apache/pekko/persistence/query/typed/scaladsl/LoadEventQuery.scala	10