innFactory/akka-persistence-gcp-datastore

This system is an Akka Persistence plugin that integrates Google Cloud Datastore as a backend for event sourcing and CQRS patterns. It provides the core infrastructure for persisting actor state, including a write journal for event storage, a read journal for querying events by ID or tag, and a snapshot store for state serialization. The implementation leverages Akka Streams to stream persistence data and supports both Scala and Java DSLs for querying and managing persistent data.

Added the Datastore read journal implementation for Akka Persistence Query, including the Scala DSL (\DatastoreScaladslReadJournal\), the Java DSL wrapper (\DatastoreJavadslReadJournal\), and the provider (\DatastoreReadJournalProvider\). This enables querying persisted events from a Datastore backend using standard Akka Persistence Query interfaces such as \eventsByTag\, \eventsByPersistenceId\, \persistenceIds\, and \currentPersistenceIds\.

src/main/scala/akka/persistence/datastore/journal/read · high confidence

Introduces a new DatastoreSnapshot component that enables Akka Persistence to save and load snapshots using Google Cloud Datastore. This adds support for persisting and retrieving state snapshots to/from the Datastore, allowing users to leverage Datastore as a backend for their Akka Persistence snapshots.

src/main/scala/akka/persistence/datastore/snapshot · high confidence

Introduced new serialization classes for the Datastore persistence module, including DatastoreSerializer, SerializedPayload, and SerializedSnapshot. These components enable the serialization and deserialization of persistent data and snapshots, integrating with Akka's serialization extension to handle byte arrays, serializer IDs, and manifests for Datastore operations.

src/main/scala/akka/persistence/datastore/serialization · high confidence

A new reference.conf file has been added to configure Akka Persistence plugins for Google Cloud Datastore. This includes settings for the journal (gcp-datastore-journal), snapshot store (gcp-datastore-snapshot), and read journal (gcp-datastore-query), along with environment-variable-based project ID and test host configurations.

src/main/resources · high confidence

This change introduces the core components for persisting Akka actor state to Google Cloud Datastore. The update adds the \DatastoreConnection\ object to manage Datastore client initialization for both production and test environments, alongside the \DatastoreJournal\ class which implements \AsyncWriteJournal\ and \AsyncRecovery\ to handle message persistence, deletion, and replay operations via the Datastore API.

src/main/scala/akka/persistence/datastore/journal · high confidence

The repository was initialized with essential configuration and metadata files. A Mergify configuration (.mergify.yml) was added to automate pull request merging and head branch deletion. A Scala Steward configuration (.scala-steward.conf) was introduced to manage dependency updates. The project's code formatting was defined in .scalafmt.conf (version 3.4.3). A CHANGELOG.md was added to track project changes, and an Apache 2.0 LICENSE file was included. Additionally, a test.sh script was added to facilitate local testing with the Google Cloud Datastore emulator, and a .gitignore file was configured to exclude build artifacts and IDE files.

(repo-wide) · high confidence

Added four new Akka Stream GraphStage sources in the Datastore read journal: PersistenceIdsSource and CurrentPersistenceIdsSource for listing persistence IDs, plus PersistenceEventsByPersistenceIdSource and PersistenceEventsByTagSource for retrieving event envelopes by persistence ID and tag respectively. These components enable the journal to stream persistence IDs and tagged events from Google Cloud Datastore with configurable refresh intervals.

src/main/scala/akka/persistence/datastore/journal/read/sources · high confidence

Adds DatastoreCommon and DatastorePersistence traits to the Akka Persistence Datastore plugin, defining shared constants (such as journal and snapshot kinds, and field keys like persistenceId, sequenceNr, and timestamp) and base traits for connecting to the Google Cloud Datastore service. This refactoring extracts common configuration and service access logic, enabling the journal and snapshot components to share a consistent interface for Datastore operations.

src/main/scala/akka/persistence/datastore · high confidence

Added new test suites for the GCP Datastore journal and snapshot store implementations. The DatastoreJournalSpec validates the journal plugin configuration and serialization capabilities, while DatastoreSnapshotSpec covers the snapshot store plugin configuration and serialization support.

src/test · high confidence

The project introduces a new Akka Persistence plugin for Google Cloud Datastore, enabling event sourcing and CQRS patterns with GCP's managed database. The build configuration defines dependencies on Akka 2.6.17, Scala 2.12.15 and 2.13.7, Play JSON 2.9.2, and Google Cloud Datastore 2.2.9, establishing the foundation for this integration.

(dependencies) · high confidence

Written by watchdog.canine.dev from the codebase's own history, inside the signed delivery this page is composed from.

• CAI 48 → 58 (+10.6)
• Rubric changed (rubric-2026.08.19 → rubric-2026.09.15) — scores are not directly comparable.

• Code Health 100 → 99 (-0.7)
• Architecture 69 → 66 (-3.3)
• Maturity 38 → 50 (+12.3)
• Readiness 50 → 63 (+13.7)
• Security 50 → 62 (+11.9)

• Coverage not included — suite not readable by the collector
• Dependency hygiene not measured — dependency manifest found but not parsed for hygiene
• High: security finding (details withheld)
• High: security finding (details withheld)
• High: security finding (details withheld)
• High: security finding (details withheld)
• No exposed public API
• Test reliability not included
• complexity unreadable for .scala — churn × complexity hotspots could not be measured
• dormant codebase — no living knowledge left to concentrate

• Documentation: no installation or build instructions (README.md)
• Documentation: no usage examples (README.md)
• Duplicated block (19 lines × 4) (src/main/scala/akka/persistence/datastore/journal/read/sources/CurrentPersistenceIdsSource.scala)
• Duplicated block (24 lines × 4) (src/main/scala/akka/persistence/datastore/journal/read/sources/CurrentPersistenceIdsSource.scala)
• Duplicated block (37 lines × 2) (src/main/scala/akka/persistence/datastore/journal/read/sources/CurrentPersistenceIdsSource.scala)
• High: security finding (details withheld)
• High: security finding (details withheld)
• High: security finding (details withheld)
• High: security finding (details withheld)
• High: security finding (details withheld)
• High: security finding (details withheld)
• High: security finding (details withheld)
• High: security finding (details withheld)
• High: security finding (details withheld)
• High: security finding (details withheld)
• High: security finding (details withheld)
• High: security finding (details withheld)
• High: security finding (details withheld)
• High: security finding (details withheld)
• High: security finding (details withheld)
• …and 7 more

Written by watchdog.canine.dev from the codebase's own history, inside the signed delivery this page is composed from.

innFactory/akka-persistence-gcp-datastore was measured the same way every project in this corpus was: the same rubric, at a pinned commit, with the result published in full. Point a surveyor at a repository you know and see whether you agree with it.