pjfanning opened a new pull request, #374: URL: https://github.com/apache/pekko-persistence-r2dbc/pull/374
Ports the `EventSourcedCleanup` and `DurableStateCleanup` tools from [akka-persistence-r2dbc#326](https://github.com/akka/akka-persistence-r2dbc/pull/326) and [akka-persistence-r2dbc#329](https://github.com/akka/akka-persistence-r2dbc/pull/329), adapted for the pekko codebase. These changes are now available under the Apache License, version 2.0. ## Changes ### New classes - `cleanup/scaladsl/EventSourcedCleanup` — Scala API for deleting events and/or snapshots for a list of `persistenceIds` - `cleanup/scaladsl/DurableStateCleanup` — Scala API for deleting durable state for a list of `persistenceIds` - `cleanup/javadsl/EventSourcedCleanup` — Java API wrapper - `cleanup/javadsl/DurableStateCleanup` — Java API wrapper ### Modified files - **`R2dbcSettings.scala`** — added `CleanupSettings` class (`logProgressEvery`, `eventsJournalDeleteBatchSize`) - **`reference.conf`** — added `pekko.persistence.r2dbc.cleanup` config block - **`JournalDao.scala`** — added `readLowestSequenceNr`, `deleteEventsRangeSql` (range-based DELETE), and `deleteEventsTo` with batch deletion support (from PR #329) ## Adaptations from the original akka code - Packages and annotations changed from `akka` → `pekko` - Uses separate settings classes (`JournalSettings`, `SnapshotSettings`, `StateSettings`) instead of akka's unified `R2dbcSettings` - Uses `deleteStateForRevision` (pekko's equivalent of akka's `deleteState`) - Uses `scala.jdk.FutureConverters` / `scala.jdk.CollectionConverters` instead of `scala-java8-compat` - `deleteEventsTo` takes `batchSize` as an explicit parameter since `JournalSettings` doesn't include cleanup settings - Default config path uses `pekko.persistence.r2dbc.cleanup` -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
