From 646412f2885db3a8933520df881ff7592c0fc6f1 Mon Sep 17 00:00:00 2001 From: Aaron Stannard Date: Sat, 6 Feb 2021 16:40:44 -0600 Subject: [PATCH 1/4] adding Akka.Persistence.Redis v1.4.16 release notes --- RELEASE_NOTES.md | 32 ++++++-------------------------- 1 file changed, 6 insertions(+), 26 deletions(-) diff --git a/RELEASE_NOTES.md b/RELEASE_NOTES.md index 3f79b67..87b016a 100644 --- a/RELEASE_NOTES.md +++ b/RELEASE_NOTES.md @@ -1,28 +1,8 @@ -#### 1.4.4 April 11th 2020 #### -- Bump Akka to version 1.4.4 -- Update build system to use Docker.DotNet +#### 1.4.16 February 8th 2021 #### +This is a major update to the Akka.Persistence.Redis plugin. -#### 1.0.0-beta2 March 2nd 2020 #### -- Update Akka to version 1.4.1-RC1 -- Update build system +**Enabled Redis Cluster Support** +Akka.Persistence.Redis will now automatically detect whether or not you are running in clustered mode via your Redis connection string -#### 1.0.0-beta1 Sep 10 2017 #### -- Support for .NET Standard 1.6 -- Support for Persistence Query -- Use Google.Protobuf serialization both for journal and snapshots -- Updated Akka.Persistence to 1.3.1 -- StackExchange.Redis to 1.2.6 - -#### 0.2.5 Oct 16 2016 #### -- Updated Akka.Persistence to 1.1.2 -- Updated Json.Net to 9.0.1 -- StackExchange.Redis to 1.1.608 - -#### 0.2.0 Aug 12 2016 #### -- custom serializer for the events and snapshots -- use intermediate types JournalEntry and SnapshotEntry instead of default persistence types -- fixed sync call inside WriteMessagesAsync -- small optimizations and code refactoring - -#### 0.1.0 Jul 19 2016 #### -- First version of the package +- Bump [Akka.NET to version 1.4.16](https://github.com/akkadotnet/akka.net/releases/tag/1.4.16) +- Enabled Akka.Cl \ No newline at end of file From 15a6c724fb1a752d26ffad7ae1dad8eabcd5af77 Mon Sep 17 00:00:00 2001 From: Aaron Stannard Date: Sat, 6 Feb 2021 17:17:58 -0600 Subject: [PATCH 2/4] completed v1.4.16 release notes --- RELEASE_NOTES.md | 36 ++++++++++++++++++++++++++++++++++-- src/common.props | 37 ++++++++++++++++++++++++++++++++----- 2 files changed, 66 insertions(+), 7 deletions(-) diff --git a/RELEASE_NOTES.md b/RELEASE_NOTES.md index 87b016a..daa3417 100644 --- a/RELEASE_NOTES.md +++ b/RELEASE_NOTES.md @@ -2,7 +2,39 @@ This is a major update to the Akka.Persistence.Redis plugin. **Enabled Redis Cluster Support** -Akka.Persistence.Redis will now automatically detect whether or not you are running in clustered mode via your Redis connection string +Akka.Persistence.Redis will now automatically detect whether or not you are running in clustered mode via your Redis connection string and will distribute journal entries and snapshots accordingly. + +All journal entries and all snapshots for a single entity will all reside inside the same Redis host cost - [using Redis' consistent hash distribution tagging](https://redis.io/topics/cluster-tutorial) scheme. + +**Significant Performance Improvements** +Akka.Persistence.Redis' write throughput was improved significantly in Akka.Persistence.Redis v1.4.16: + +| Test | Akka.Persistence.Redis v1.4.4 (msg/s) | current PR (msg/s) | +|-----------------|---------------------------------------|--------------------| +| Persist | 782 | 772 | +| PersistAll | 15019 | 20275 | +| PersistAsync | 9496 | 13131 | +| PersistAllAsync | 32765 | 44776 | +| PersistGroup10 | 611 | 6523 | +| PersistGroup100 | 8878 | 12533 | +| PersistGroup200 | 9598 | 12214 | +| PersistGroup25 | 9209 | 10819 | +| PersistGroup400 | 9209 | 11824 | +| PersistGroup50 | 9506 | 9704 | +| Recovering | 17374 | 20119 | +| Recovering8 | 36915 | 37290 | +| RecoveringFour | 22432 | 20884 | +| RecoveringTwo | 22209 | 21222 | + +These numbers were generated running a single Redis instance inside a Docker container on Docker for Windows - real-world values generated in cloud environments will likely be much higher. + +**Removed Akka.Persistence.Query Support** +In order to achieve support for clustering and improved write performance, we made the descision to drop Akka.Persistence.Query support from Akka.Persistence.Redis at this time - if you wish to learn more about our decision-making process or if you are affected by this change, please comment on this thread here: https://github.com/akkadotnet/Akka.Persistence.Redis/issues/126 + +**Other Changes** - Bump [Akka.NET to version 1.4.16](https://github.com/akkadotnet/akka.net/releases/tag/1.4.16) -- Enabled Akka.Cl \ No newline at end of file +- Modernized Akka.NET Serialization calls +- [Added benchmarks](https://github.com/akkadotnet/Akka.Persistence.Redis/pull/118) +- Upgraded to [StackExchange.Redis 2.2.11](https://github.com/StackExchange/StackExchange.Redis/blob/main/docs/ReleaseNotes.md) +- Improved documentation \ No newline at end of file diff --git a/src/common.props b/src/common.props index 0f7fa80..f9b6050 100644 --- a/src/common.props +++ b/src/common.props @@ -2,15 +2,42 @@ Copyright © 2013-2020 Akka.NET Project Akka.NET - 1.4.4 + 1.4.16 akka;actors;actor model;Akka;concurrency;persistence;eventsource;redis http://getakka.net/images/AkkaNetLogo.Normal.png https://github.com/AkkaNetContrib/Akka.Persistence.Redis https://github.com/AkkaNetContrib/Akka.Persistence.Redis/blob/dev/LICENSE - - - Bump Akka to version 1.4.4 - - Update build system to use Docker.DotNet - + This is a major update to the Akka.Persistence.Redis plugin. +Enabled Redis Cluster Support** +Akka.Persistence.Redis will now automatically detect whether or not you are running in clustered mode via your Redis connection string and will distribute journal entries and snapshots accordingly. +All journal entries and all snapshots for a single entity will all reside inside the same Redis host cost - [using Redis' consistent hash distribution tagging](https://redis.io/topics/cluster-tutorial) scheme. +Significant Performance Improvements** +Akka.Persistence.Redis' write throughput was improved significantly in Akka.Persistence.Redis v1.4.16: +| Test | Akka.Persistence.Redis v1.4.4 (msg/s) | current PR (msg/s) | +|-----------------|---------------------------------------|--------------------| +| Persist | 782 | 772 | +| PersistAll | 15019 | 20275 | +| PersistAsync | 9496 | 13131 | +| PersistAllAsync | 32765 | 44776 | +| PersistGroup10 | 611 | 6523 | +| PersistGroup100 | 8878 | 12533 | +| PersistGroup200 | 9598 | 12214 | +| PersistGroup25 | 9209 | 10819 | +| PersistGroup400 | 9209 | 11824 | +| PersistGroup50 | 9506 | 9704 | +| Recovering | 17374 | 20119 | +| Recovering8 | 36915 | 37290 | +| RecoveringFour | 22432 | 20884 | +| RecoveringTwo | 22209 | 21222 | +These numbers were generated running a single Redis instance inside a Docker container on Docker for Windows - real-world values generated in cloud environments will likely be much higher. +Removed Akka.Persistence.Query Support** +In order to achieve support for clustering and improved write performance, we made the descision to drop Akka.Persistence.Query support from Akka.Persistence.Redis at this time - if you wish to learn more about our decision-making process or if you are affected by this change, please comment on this thread here: https://github.com/akkadotnet/Akka.Persistence.Redis/issues/126 +Other Changes** +- Bump [Akka.NET to version 1.4.16](https://github.com/akkadotnet/akka.net/releases/tag/1.4.16) +- Modernized Akka.NET Serialization calls +- [Added benchmarks](https://github.com/akkadotnet/Akka.Persistence.Redis/pull/118) +- Upgraded to [StackExchange.Redis 2.2.11](https://github.com/StackExchange/StackExchange.Redis/blob/main/docs/ReleaseNotes.md) +- Improved documentation true Akka.NET Persistence journal and snapshot store backed by Redis. $(NoWarn);CS1591 From e3745de229acaf6ba92f96155b352490e9fc0231 Mon Sep 17 00:00:00 2001 From: Aaron Stannard Date: Sat, 6 Feb 2021 17:33:03 -0600 Subject: [PATCH 3/4] updated README --- README.md | 214 +++++++++++------------------ docs/images/AkkaNetLogo.Normal.png | Bin 0 -> 4288 bytes src/common.props | 6 +- 3 files changed, 86 insertions(+), 134 deletions(-) create mode 100644 docs/images/AkkaNetLogo.Normal.png diff --git a/README.md b/README.md index 57e6d29..77fd4c6 100644 --- a/README.md +++ b/README.md @@ -1,11 +1,14 @@ # Akka.Persistence.Redis +![Akka.NET logo](docs/images/AkkaNetLogo.Normal.png) + [![NuGet Version](http://img.shields.io/nuget/v/Akka.Persistence.Redis.svg?style=flat)](https://www.nuget.org/packages/Akka.Persistence.Redis) Akka Persistence Redis Plugin is a plugin for `Akka persistence` that provides several components: - - a journal store ; - - a snapshot store ; - - a journal query interface implementation. + - a journal store and + - a snapshot store. + + > NOTE: in Akka.Persistence.Redis v1.4.16 we removed [Akka.Persistence.Query](https://getakka.net/articles/persistence/persistence-query.html) support. Please read more about that decision and comment here: https://github.com/akkadotnet/Akka.Persistence.Redis/issues/126 This plugin stores data in a [redis](https://redis.io) database and based on [Stackexchange.Redis](https://github.com/StackExchange/StackExchange.Redis) library. @@ -19,153 +22,56 @@ From `.NET CLI` dotnet add package Akka.Persistence.Redis ``` -## Journal plugin +## Journal To activate the journal plugin, add the following line to your HOCON config: ``` akka.persistence.journal.plugin = "akka.persistence.journal.redis" ``` This will run the journal with its default settings. The default settings can be changed with the configuration properties defined in your HOCON config: -### Configuration -- `configuration-string` - connection string, as described here: https://github.com/StackExchange/StackExchange.Redis/blob/master/docs/Configuration.md#basic-configuration-strings -- `key-prefix` - Redis journals key prefixes. Leave it for default or change it to appropriate value. WARNING: don't change it on production instances. - -## Snapshot config -To activate the snapshot plugin, add the following line to your HOCON config: ``` -akka.persistence.snapshot-store.plugin = "akka.persistence.snapshot-store.redis" +akka.persistence.journal.redis { + # qualified type name of the Redis persistence journal actor + class = "Akka.Persistence.Redis.Journal.RedisJournal, Akka.Persistence.Redis" + + # connection string, as described here: https://github.com/StackExchange/StackExchange.Redis/blob/master/Docs/Configuration.md#basic-configuration-strings + configuration-string = "" + + # Redis journals key prefixes. Leave it for default or change it to appropriate value. WARNING: don't change it on production instances. + key-prefix = "" +} ``` -This will run the snapshot-store with its default settings. The default settings can be changed with the configuration properties defined in your HOCON config: ### Configuration - `configuration-string` - connection string, as described here: https://github.com/StackExchange/StackExchange.Redis/blob/master/docs/Configuration.md#basic-configuration-strings -- `key-prefix` - Redis journals key prefixes. Leave it for default or change it to appropriate value. WARNING: don't change it on production instances. +- `key-prefix` - Redis journals key prefixes. Leave it for default or change it to customized value. WARNING: don't change this value after you've started persisting data in production. -## Persistence Query - -The plugin supports the following queries: - -### PersistenceIdsQuery and CurrentPersistenceIdsQuery - -`PersistenceIds` and `CurrentPersistenceIds` are used for retrieving all persistenceIds of all persistent actors. -```C# -var readJournal = Sys.ReadJournalFor(RedisReadJournal.Identifier); - -Source willNotCompleteTheStream = readJournal.PersistenceIds(); -Source willCompleteTheStream = readJournal.CurrentPersistenceIds(); +## Snapshot Store +To activate the snapshot plugin, add the following line to your HOCON config: ``` -The returned event stream is unordered and you can expect different order for multiple executions of the query. - -When using the `PersistenceIds` query, the stream is not completed when it reaches the end of the currently used `persistenceIds`, but it continues to push new `persistenceIds` when new persistent actors are created. - -When using the `CurrentPersistenceIds` query, the stream is completed when the end of the current list of `persistenceIds` is reached, thus it is not a live query. - -The stream is completed with failure if there is a failure in executing the query in the backend journal. - -### EventsByPersistenceIdQuery and CurrentEventsByPersistenceIdQuery - -`EventsByPersistenceId` and `CurrentEventsByPersistenceId` is used for retrieving events for a specific `PersistentActor` identified by `persistenceId`. -```C# -import akka.actor.ActorSystem -import akka.stream.{Materializer, ActorMaterializer} -import akka.stream.scaladsl.Source -import akka.persistence.query.{ PersistenceQuery, EventEnvelope } -import akka.persistence.jdbc.query.scaladsl.JdbcReadJournal - -implicit val system: ActorSystem = ActorSystem() -implicit val mat: Materializer = ActorMaterializer()(system) -val readJournal: JdbcReadJournal = PersistenceQuery(system).readJournalFor[JdbcReadJournal](JdbcReadJournal.Identifier) - -val willNotCompleteTheStream: Source[EventEnvelope, NotUsed] = readJournal.eventsByPersistenceId("some-persistence-id", 0L, Long.MaxValue) - -val willCompleteTheStream: Source[EventEnvelope, NotUsed] = readJournal.currentEventsByPersistenceId("some-persistence-id", 0L, Long.MaxValue) - - -var readJournal = Sys.ReadJournalFor(RedisReadJournal.Identifier); - -Source willNotCompleteTheStream = queries.EventsByPersistenceId("some-persistence-id", 0L, long.MaxValue); -Source willCompleteTheStream = queries.CurrentEventsByPersistenceId("some-persistence-id", 0L, long.MaxValue); +akka.persistence.snapshot-store.plugin = "akka.persistence.snapshot-store.redis" ``` -You can retrieve a subset of all events by specifying `fromSequenceNr` and `toSequenceNr` or use `0L` and `long.MaxValue` respectively to retrieve all events. Note that the corresponding sequence number of each event is provided in the `EventEnvelope`, which makes it possible to resume the stream at a later point from a given sequence number. - -The returned event stream is ordered by sequence number, i.e. the same order as the `PersistentActor` persisted the events. The same prefix of stream elements (in same order) are returned for multiple executions of the query, except for when events have been deleted. - -The stream is completed with failure if there is a failure in executing the query in the backend journal. - -### EventsByTag and CurrentEventsByTag +This will run the snapshot-store with its default settings. The default settings can be changed with the configuration properties defined in your HOCON config: -`EventsByTag` and `CurrentEventsByTag` are used for retrieving events that were marked with a given tag, e.g. all domain events of an Aggregate Root type. -```C# -var readJournal = Sys.ReadJournalFor(RedisReadJournal.Identifier); -Source willNotCompleteTheStream = queries.EventsByTag("apple", 0L); -Source willCompleteTheStream = queries.CurrentEventsByTag("apple", 0L); ``` +akka.persistence.snapshot-store.redis { + # qualified type name of the Redis persistence journal actor + class = "Akka.Persistence.Redis.Journal.RedisJournal, Akka.Persistence.Redis" -### Tagging Events -To tag events you'll need to create an Event Adapter that will wrap the event in a akka.persistence.journal.Tagged class with the given tags. The Tagged class will instruct akka-persistence-jdbc to tag the event with the given set of tags. + # connection string, as described here: https://github.com/StackExchange/StackExchange.Redis/blob/master/Docs/Configuration.md#basic-configuration-strings + configuration-string = "" -The persistence plugin will not store the Tagged class in the journal. It will strip the tags and payload from the Tagged class, and use the class only as an instruction to tag the event with the given tags and store the payload in the message field of the journal table. -``` -public class ColorTagger : IWriteEventAdapter -{ - public string Manifest(object evt) => string.Empty; - internal Tagged WithTag(object evt, string tag) => new Tagged(evt, ImmutableHashSet.Create(tag)); - - public object ToJournal(object evt) - { - switch (evt) - { - case string s when s.Contains("green"): - return WithTag(evt, "green"); - case string s when s.Contains("black"): - return WithTag(evt, "black"); - case string s when s.Contains("blue"): - return WithTag(evt, "blue"); - default: - return evt; - } - } -} + # Redis journals key prefixes. Leave it for default or change it to appropriate value. WARNING: don't change it on production instances. + key-prefix = "" +} ``` -The EventAdapter must be registered by adding the following to the root of `application.conf` Please see the demo-akka-persistence-jdbc project for more information. -``` -akka.persistence.journal.redis { - event-adapters { - color-tagger = "Akka.Persistence.Redis.Tests.Query.ColorTagger, Akka.Persistence.Redis.Tests" - } - event-adapter-bindings = { - "System.String" = color-tagger - } -} -``` -You can retrieve a subset of all events by specifying `offset`, or use `0L` to retrieve all events with a given tag. The `offset` corresponds to an ordered sequence number for the specific tag. Note that the corresponding offset of each event is provided in the `EventEnvelope`, which makes it possible to resume the stream at a later point from a given `offset`. - -In addition to the `offset` the `EventEnvelope` also provides `persistenceId` and `sequenceNr` for each event. The `sequenceNr` is the sequence number for the persistent actor with the `persistenceId` that persisted the event. The `persistenceId` + `sequenceNr` is an unique identifier for the event. - -The returned event stream contains only events that correspond to the given tag, and is ordered by the creation time of the events. The same stream elements (in same order) are returned for multiple executions of the same query. Deleted events are not deleted from the tagged event stream. -## Serialization -Akka Persistence provided serializers wrap the user payload in an envelope containing all persistence-relevant information. Redis Journal uses provided Protobuf serializers for the wrapper types (e.g. `IPersistentRepresentation`), then the payload will be serialized using the user configured serializer. By default, the payload will be serialized using JSON.NET serializer. This is fine for testing and initial phases of your development (while you’re still figuring out things and the data will not need to stay persisted forever). However, once you move to production you should really pick a different serializer for your payloads. - -Serialization of snapshots and payloads of Persistent messages is configurable with Akka’s Serialization infrastructure. For example, if an application wants to serialize - -- payloads of type `MyPayload` with a custom `MyPayloadSerializer` and -- snapshots of type `MySnapshot` with a custom `MySnapshotSerializer` -it must add -``` -akka.actor { - serializers { - redis = "Akka.Serialization.YourOwnSerializer, YourOwnSerializer" - } - serialization-bindings { - "Akka.Persistence.Redis.Journal.JournalEntry, Akka.Persistence.Redis" = redis - "Akka.Persistence.Redis.Snapshot.SnapshotEntry, Akka.Persistence.Redis" = redis - } -} -``` +### Configuration +- `configuration-string` - connection string, as described here: https://github.com/StackExchange/StackExchange.Redis/blob/master/docs/Configuration.md#basic-configuration-strings +- `key-prefix` - Redis journals key prefixes. Leave it for default or change it to appropriate value. WARNING: don't change it on production instances. -## Securing your Redis server +## Security and Access Control You can secure the Redis server Akka.Persistence.Redis connects to by leveraging Redis ACL and requiring users to use AUTH to connect to the Redis server. 1. Redis ACL @@ -184,7 +90,29 @@ You can secure the Redis server Akka.Persistence.Redis connects to by leveraging To connect to ACL enabled Redis server, you will need to set the user and password option in the [connection string](https://stackexchange.github.io/StackExchange.Redis/Configuration#basic-configuration-strings): "myServer.net:6380,user=\,password=\" -### Minimum command set +All of these features are supported via `StackExchange.Redis`, which Akka.Persistence.Redis uses internally, and you only need to customize your `akka.persistence.journal.redis.configuration-string` and `akka.persistence.snapshot-store.redis.configuration-string` values to customize it. + +### Enabling TLS +For instance, if you want to enable TLS on your Akka.Persistence.Redis instance: + +``` +akka.persistence.journal.redis.configuration-string = "contoso5.redis.cache.windows.net,ssl=true,password=..." +``` + +Or if you need to connect to multiple redis instances in a cluster: + +``` +akka.persistence.journal.redis.configuration-string = "contoso5.redis.cache.windows.net, contoso4.redis.cache.windows.net,ssl=true,password=..." +``` + +### Enabling ACL +To connect to your redis instance with access control (ACL) support for Akka.Persistence.Redis, all you need to do is specify the user name and password in your connection string and this will restrict the `StackExchange.Redis` client used internally by Akka.Persistence.Redis to whatever permissions you specified in your cluster: + +``` +akka.persistence.journal.redis.configuration-string = "contoso5.redis.cache.windows.net, contoso4.redis.cache.windows.net,user=akka-persistence,password=..." +``` + +#### Minimum command set These are the minimum Redis commands that are needed by Akka.Persistence.Redis to work properly. | Redis Command | StackExchange.Redis Command | @@ -217,5 +145,29 @@ These are the minimum Redis commands that are needed by Akka.Persistence.Redis t | PUNSUBSCRIBE | | | PUBLISH | Pub/Sub Publish | -## Maintainer -- [alexvaluyskiy](https://github.com/alexvaluyskiy) + +## Serialization +Akka Persistence provided serializers wrap the user payload in an envelope containing all persistence-relevant information. Redis Journal uses provided Protobuf serializers for the wrapper types (e.g. `IPersistentRepresentation`), then the payload will be serialized using the user configured serializer. + +The payload will be serialized [using Akka.NET's serialization bindings for your events and snapshot objects](https://getakka.net/articles/networking/serialization.html). By default, all `object`s that do not have a specified serializer will use Newtonsoft.Json polymorphic serialization (your CLR types <--> JSON.) + +This is fine for testing and initial phases of your development (while you’re still figuring out things and the data will not need to stay persisted forever). However, once you move to production you _should really pick a different serializer for your payloads_. + +We highly recommend creating schema-based serialization definitions using MsgPack, Google.Protobuf, or something similar and configuring serialization bindings for those in your configuration: https://getakka.net/articles/networking/serialization.html#usage + +Serialization of snapshots and payloads of Persistent messages is configurable with Akka’s Serialization infrastructure. For example, if an application wants to serialize + +- payloads of type `MyPayload` with a custom `MyPayloadSerializer` and +- snapshots of type `MySnapshot` with a custom `MySnapshotSerializer` +it must add +``` +akka.actor { + serializers { + redis = "Akka.Serialization.YourOwnSerializer, YourOwnSerializer" + } + serialization-bindings { + "Akka.Persistence.Redis.Journal.JournalEntry, Akka.Persistence.Redis" = redis + "Akka.Persistence.Redis.Snapshot.SnapshotEntry, Akka.Persistence.Redis" = redis + } +} +``` \ No newline at end of file diff --git a/docs/images/AkkaNetLogo.Normal.png b/docs/images/AkkaNetLogo.Normal.png new file mode 100644 index 0000000000000000000000000000000000000000..028060f7e7b3cfb453c8ece59f69479907404e92 GIT binary patch literal 4288 zcmV;x5I^sUP)N2bZe?^J zG%heMF*h@ApJM<35IspmK~#8N?Oh3Q8`T-M33p;SAp{6e0%YYJ6zD;Lbjr{IEp36) zmZpi5>a)+_B>pOU>=zi;LnN$-B||MtEA?WGC<0fDkXwvxUG2owj?mSv80tL?2b z;~U0NkbuC@Ag$hfh&!HH3uYxXv$7(aJ%FMF1O|z0w$iPpA7G-=six*rtboAa;EuOn zpC>9!Sn1B1mdvG;L_lC*nA*JUdy<;&FbS)hd#AQ!PNAd%0{z2`6+5R$@$~x~K^d5S zXZk~LPNXaX0=?t3r{5hb#WU;qVk)4Te!3!_9Ya|K1S}AbkCD{&X0C`V2oZ)Uw}1d2 z5X!tl;q*y0-34Fl3MxWCARq4L)Q_1+xZ>%X`=_;J&Y+?M1iIl~o|*x1>?sh-z^G<2 zCoS7@G!-c@+Hu0t%mhizY~+e%fW(scubJ@;2UF1kqZU5j0T9F!g#sB0rRL1NRJy=u z1!kB9JaG(_lA8JhRUt6i;EuP?8G^IkDLS z=(gjjN&%;%X6cS2;jC}vilNw4Gp|g3e8=HbwSZH>c5Lo=`tMv3l!|J4DZBlKnjqjn zRAQ#OlWY7^Q%!rQ4FXOBc4}8)wknCU-WS>JH&dIpUPw(5a0;a6)Y+J=KIa*I*r;Z9 zpR{~S4K+!i+~HQ+kAqR)WaW%P*wZ%SrF3adBXB0yQ;m<%%&s*hSZ$71Us!xlflY~YWh?0 zK*k_(_)Skvc6k%q3q++6OX9xqp5$qiwBM*%v12+6GqeXGY(mVs+owO0o=ja6=ntm& z+75-Y{ya}qIYM+>t8Pp5`?2*?S7j!^Ae##fRMu28Yo*4`hfo&GC8V;EAb_ zNVlfK*LEP~w8XhcgB{gsu5rqolA5}Yx+%~bT(zy&@kC@vPqLA+S^_>vJ5q8^aSAaTcSvgcxzuF=BdTw0 zI}x+b2VC*=$;5uw+~k>5lnJGL%Em_Ab#i>m3Dji)hDpA*aV~Fi9bYv4BX){ACVE?s zr6Ns$quanShO;Oh$S?rTI%cY7o>&IK=PIsW&D|xP+vZ#c-bhJJH;V@{09S2d9!DU9 zrpueSpNcjCOGPyXe^a3`oJJ|0xsAF!I#K0KT#VVOlP8d&5dPM6RD}udl{?wnV)hmq z!%1Y$e9iLIkEqL|3*+Xt&VXOFmnV!NlkF^PpE-}JGC^9AxdhI9d0*D)lj;9WA8ik0 z9C7_>7mUA=D~jUrz45irOra`GfTMc{-yqH*{H=}BBb!~+WrxGpb|99&RU9D{otP0{ zo$PzrYL`?Aam9HCaTL||$JlK`)Mw|S+S^*s6G7>ih_iQFQT2IX|94YvH~S5SlG+}m zE;|#h+SXsf&|Q21l#VV>@(yZ(3GNk{ld+5XfM*crFx@Gw*mfCp*;yEW^HZl|Y5JIF z_>vROeAV1F7g1A8s8Q4BL0n((jp7Vym$jO=o=#nM2FBJteU!_aNOO%oOvJ3Ur^@@x zG-{Fw*d^Y;Gl-KYshO?QS8jL6KV)3<@ACH~bPQFp?LHK>2RNs>LIyKn@EQwcZ?@izv#Tiu7+t>_EUA8&cgAm@t3p``m zjV@0jHSU(SBdO(uV6Tf@#5IV6$b8BvOHzkYpY00vAVl&(o)PUzmp9pFwM%06aN($K z;~B(Z{0q8k-+Q>mdy_ZvjAwr)7E>2Ykkp-%a8#!`#&8n5Z~$4}YBZvNPj!KIy9(EE zWk65s@2D##Xn!K0rc3)L0wYYeS()0h?Yq=vdthh}LfC|!#Qv(et!Go0OpsbKvta;7 zJM&UJ^ZvBusS~NoBa4aNzg4-siPyNsDl@`A?Dc^RDW0z58N^A%vcHbK;)%LELYN&N z15vf`j8wMtBwjrJX7w=YVLssGW64;>Gl-+uoK{Elfeh@ZZs!`O%*l4PY==wT%mcRO z<1uqN{(%f|9(8$m(fuGqqUaAo*o0kGa}zgES526vZlC5>GrKv)a1PaUr__?Zn7TYX z7+0H|iKBWS#~=B|pq-*2+zaH^r4;T#(WUviO zN$=ru%}vh1V6zvZjV^kUb7=@nVDCy`Pr|?e&pVs#bEwM#0s;a80s;a80s;a>K)o!V z90`VWlA$k=xLabRaChhwpC&BFfTWH2SmIeY{1kKf>}iDAQ2K zTExG?i0`I*r1~Q)Ut^;S?OK^D2fUBDDz$P?bTpZ zSv)@+`xYe~G_bIrS$K|hb&ZoKOKC7a zq|8FYpEERoOAJoZw|FuCt^lAfVfhMelWb3uQ`3=!?QEne? zhs|W!^whI2wD=f)dK0gtETsV&=*v~c1_Ywmgzrxx{2v&EJ-Ik7J|aIv*-Yq7SlUdL zFRE48r5sGrdFV}8Y^Fk(E-IAy4sUP)2uoR$ONV}a2ENMbMV^-t_IXbk8V5bdC{Gs_ z>S)DhSMIkp<=;|v6Y3(d@1vYA4C(iyFVA8Id;(mLna?0v`Q^fKw2iQQO-+ZR!Ed9% z_XHXnr&6#6Haox=OAU?btc%5trszCa2`dl|pMJqPh;qBwvR5a|=lH_mqp<9p ziLi%^X)xX!kkvG6)z{ZgKw7vUR8~Y@?F)sDp=b>_kiLPqt%fvzq$mw+iChqkO2Gy# zoxT*ZWuJxT*wAo)(f;V&5Y zzhQX7@-10%CC@W%o>AL(8<);)?v0%ZS6A`9w z$C*)iXWS9Td^~Ck|CB^96rJ5uj$MQmyIn5}eJDKDV8lX2nbDg&P$(?6L#L?H1A}5X zIjX$K8beVGmD;wp`!YhVvy9vmYk9)rop}!{iw$LT)JGR_|5c%2#xk9G_lKi%4Dr}q zDZi&E9T0ZUNz|}>H`^6bly;sc7?LkV_-{Mi z+lP925qaZ+kTT1-(`2V9*ldP4cH*?jY8Og=rhX!r9n9>Mif>`;gkU&!T}fXO!a9cv zKQmOm8%9})L0^Uru1A>hT2qdL5*8a+42FK96!pAhGp0JSb5j_nK3<}OeF@?o|{#=6i4!z87A9ySBK81083Gw>s zp_Lb1Wcj9Kq{-XBAU(SR(e0;3qosYrGAdzPa$`pdnLuOK8Ga8+SPX@J7(4PPN=JW$ zwJ?UGF4E)ZGNB>Zcm!4=o^3?*x{TBYH>}hd!??nV$g2%`R#0#riY+V#?Xr&H5*VLy zhNYt{T+mtiPt184V*yH5I@Eb7Q1BO%U@z>X6ugc<-#{RftX9j=#NASU&W1f%a_2I>@JA6 z@wpBCcokvyETFp@jQKeivMc6CBIhITPULH!A6Cwy;5-=nW3{niU?-koP|P4yXTdC6 z2)1m&@4Xs%TF{2q(SA1Tu7i!1Vn)8azs~}6+g4eQGPa;zcEXxn2fn7as}cgk0OrG3 i`7r_l0z*PY#s2{ds86= - Copyright © 2013-2020 Akka.NET Project + Copyright © 2013-2021 Akka.NET Project Akka.NET 1.4.16 akka;actors;actor model;Akka;concurrency;persistence;eventsource;redis http://getakka.net/images/AkkaNetLogo.Normal.png - https://github.com/AkkaNetContrib/Akka.Persistence.Redis - https://github.com/AkkaNetContrib/Akka.Persistence.Redis/blob/dev/LICENSE + https://github.com/akkadotnet/Akka.Persistence.Redis + https://github.com/akkadotnet/Akka.Persistence.Redis/blob/dev/LICENSE This is a major update to the Akka.Persistence.Redis plugin. Enabled Redis Cluster Support** Akka.Persistence.Redis will now automatically detect whether or not you are running in clustered mode via your Redis connection string and will distribute journal entries and snapshots accordingly. From d6fa7a5a1673c0d275502b441e043f5bb1bac116 Mon Sep 17 00:00:00 2001 From: Aaron Stannard Date: Sat, 6 Feb 2021 17:34:42 -0600 Subject: [PATCH 4/4] updated release notes --- RELEASE_NOTES.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/RELEASE_NOTES.md b/RELEASE_NOTES.md index daa3417..8b3373b 100644 --- a/RELEASE_NOTES.md +++ b/RELEASE_NOTES.md @@ -1,4 +1,4 @@ -#### 1.4.16 February 8th 2021 #### +#### 1.4.16 February 6th 2021 #### This is a major update to the Akka.Persistence.Redis plugin. **Enabled Redis Cluster Support**