akka-persistence-mongo

akka-persistence-mongo copied to clipboard

Document (code & config) for sample event adapter translating back and forth from scala classes to document types.

scullxbones

ReadJournal deduplication logic can cause lost events

2

Deduplicators used could cause skipped events if upstream doesn't present the events in order. Definite possibility with `live` streams. Solution should be memory-bounded over infinite stream.

scullxbones

In read journals, long running 'All*' queries could stress memory due to de-duplication logic, storing keys to what has been seen before. May need to allow users to select a...

scullxbones

Add monotonic atomic counters for sequential ordering

1

- Use atomic `findAndModify` with counters per: - Global - Tag (when implemented) - Migrate existing data to add `global` counter - On append, grab batch via `{$inc: N}` and...

scullxbones

Need to add clarity to docs (see #75 for more) around mongo url & write concerns > update the documentation to make it clear that the plugin does not (or...

scullxbones

Add `Sink` to extension as a writer endpoint

5

Closes flow for `ReadJournal` queries to write to journal

scullxbones

Read Preference of Event Consumer

3

It would be nice to have the choice of MongoDB read preference at the event consumer side to achieve some serious load balancing. Using the casbah driver we are interested...

aisven

Updates * [io.netty:netty-buffer](https://github.com/netty/netty) * [io.netty:netty-handler](https://github.com/netty/netty) * [io.netty:netty-transport](https://github.com/netty/netty) from 4.1.72.Final to 4.1.82.Final. I'll automatically update this PR to resolve conflicts as long as you don't change it yourself. If you'd like...

scala-steward

Updates * [com.typesafe.akka:akka-actor](https://github.com/akka/akka) * [com.typesafe.akka:akka-cluster-sharding](https://github.com/akka/akka) * [com.typesafe.akka:akka-persistence](https://github.com/akka/akka) * [com.typesafe.akka:akka-persistence-query](https://github.com/akka/akka) * [com.typesafe.akka:akka-persistence-tck](https://github.com/akka/akka) * [com.typesafe.akka:akka-slf4j](https://github.com/akka/akka) * [com.typesafe.akka:akka-testkit](https://github.com/akka/akka) from 2.6.17 to 2.6.20. [GitHub Release Notes](https://github.com/akka/akka/releases/tag/v2.6.20) - [Version Diff](https://github.com/akka/akka/compare/v2.6.17...v2.6.20) I'll automatically update this PR...

scala-steward

## About this PR 📦 Updates [org.scala-lang:scala-library](https://github.com/scala/scala) from `2.13.12` to `2.13.13` 📜 [GitHub Release Notes](https://github.com/scala/scala/releases/tag/v2.13.13) - [Version Diff](https://github.com/scala/scala/compare/v2.13.12...v2.13.13) ## Usage ✅ **Please merge!** I'll automatically update this PR to resolve...

scala-steward