path	# lines of code
docker/docker-compose-postgres.yml	9
docker/docker-compose-yugabyte.yml	43
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/snapshot/SnapshotDao.scala	196
core/src/main/scala/org/apache/pekko/persistence/r2dbc/snapshot/R2dbcSnapshotStore.scala	81
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/R2dbcExecutor.scala	240
core/src/main/scala/org/apache/pekko/persistence/r2dbc/internal/PubSub.scala	56
core/src/main/scala/org/apache/pekko/persistence/r2dbc/internal/Sql.scala	40
core/src/main/scala/org/apache/pekko/persistence/r2dbc/internal/ContinuousQuery.scala	142
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
core/src/main/scala/org/apache/pekko/persistence/r2dbc/state/javadsl/R2dbcDurableStateStore.scala	64
core/src/main/scala/org/apache/pekko/persistence/r2dbc/state/R2dbcDurableStateStoreProvider.scala	15
core/src/main/scala/org/apache/pekko/persistence/r2dbc/ConnectionFactoryProvider.scala	106
core/src/main/scala/org/apache/pekko/persistence/r2dbc/query/scaladsl/R2dbcReadJournal.scala	339
core/src/main/scala/org/apache/pekko/persistence/r2dbc/query/scaladsl/QueryDao.scala	291
core/src/main/scala/org/apache/pekko/persistence/r2dbc/query/javadsl/R2dbcReadJournal.scala	74
core/src/main/scala/org/apache/pekko/persistence/r2dbc/query/R2dbcReadJournalProvider.scala	11
ddl-scripts/create_tables_postgres.sql	72
ddl-scripts/drop_tables_postgres.sql	7
ddl-scripts/create_tables_yugabyte.sql	74
project/CommonSettings.scala	33
project/Dependencies.scala	77
project/plugins.sbt	18
project/AutomaticModuleName.scala	7
project/MetaInfLicenseNoticeCopy.scala	11
project/CopyrightHeader.scala	78
migration/src/main/scala/org/apache/pekko/persistence/r2dbc/migration/MigrationTool.scala	259
migration/src/main/scala/org/apache/pekko/persistence/r2dbc/migration/MigrationToolDao.scala	77
build.sbt	80
projection/src/main/scala/org/apache/pekko/projection/r2dbc/R2dbcProjectionSettings.scala	47
projection/src/main/scala/org/apache/pekko/projection/r2dbc/internal/R2dbcProjectionImpl.scala	513
projection/src/main/scala/org/apache/pekko/projection/r2dbc/internal/R2dbcOffsetStore.scala	835
projection/src/main/scala/org/apache/pekko/projection/r2dbc/internal/R2dbcHandlerAdapter.scala	32
projection/src/main/scala/org/apache/pekko/projection/r2dbc/internal/BySliceSourceProviderAdapter.scala	61
projection/src/main/scala/org/apache/pekko/projection/r2dbc/scaladsl/R2dbcSession.scala	22
projection/src/main/scala/org/apache/pekko/projection/r2dbc/scaladsl/R2dbcProjection.scala	221
projection/src/main/scala/org/apache/pekko/projection/r2dbc/scaladsl/R2dbcHandler.scala	20
projection/src/main/scala/org/apache/pekko/projection/r2dbc/javadsl/R2dbcSession.scala	28
projection/src/main/scala/org/apache/pekko/projection/r2dbc/javadsl/R2dbcProjection.scala	118
projection/src/main/scala/org/apache/pekko/projection/r2dbc/javadsl/R2dbcHandler.scala	29