Path	Lines of Code
core/src/main/scala/org/apache/pekko/persistence/r2dbc/ConnectionFactoryProvider.scala	106
core/src/main/scala/org/apache/pekko/persistence/r2dbc/R2dbcSettings.scala	83
core/src/main/scala/org/apache/pekko/persistence/r2dbc/internal/BySliceQuery.scala	394
core/src/main/scala/org/apache/pekko/persistence/r2dbc/internal/ContinuousQuery.scala	142
core/src/main/scala/org/apache/pekko/persistence/r2dbc/internal/PubSub.scala	56
core/src/main/scala/org/apache/pekko/persistence/r2dbc/internal/R2dbcExecutor.scala	240
core/src/main/scala/org/apache/pekko/persistence/r2dbc/internal/Sql.scala	40
core/src/main/scala/org/apache/pekko/persistence/r2dbc/journal/JournalDao.scala	222
core/src/main/scala/org/apache/pekko/persistence/r2dbc/journal/R2dbcJournal.scala	196
core/src/main/scala/org/apache/pekko/persistence/r2dbc/query/R2dbcReadJournalProvider.scala	11
core/src/main/scala/org/apache/pekko/persistence/r2dbc/query/javadsl/R2dbcReadJournal.scala	74
core/src/main/scala/org/apache/pekko/persistence/r2dbc/query/scaladsl/QueryDao.scala	291
core/src/main/scala/org/apache/pekko/persistence/r2dbc/query/scaladsl/R2dbcReadJournal.scala	339
core/src/main/scala/org/apache/pekko/persistence/r2dbc/snapshot/R2dbcSnapshotStore.scala	81
core/src/main/scala/org/apache/pekko/persistence/r2dbc/snapshot/SnapshotDao.scala	196
core/src/main/scala/org/apache/pekko/persistence/r2dbc/state/R2dbcDurableStateStoreProvider.scala	15
core/src/main/scala/org/apache/pekko/persistence/r2dbc/state/javadsl/R2dbcDurableStateStore.scala	64
core/src/main/scala/org/apache/pekko/persistence/r2dbc/state/scaladsl/DurableStateDao.scala	350
core/src/main/scala/org/apache/pekko/persistence/r2dbc/state/scaladsl/R2dbcDurableStateStore.scala	140