dependabot[bot] on nuget
Bump NUnit from 3.7.1 to 3.13.3… (compare)
dependabot[bot] on nuget
Bump Fsharp.Core from 6.0.1 to … (compare)
dependabot[bot] on nuget
Bump FluentAssertions from 5.10… (compare)
dependabot[bot] on nuget
Bump System.Collections.Immutab… (compare)
dependabot[bot] on nuget
Bump System.Threading.Channels … (compare)
dependabot[bot] on nuget
Bump System.Configuration.Confi… (compare)
dependabot[bot] on nuget
Bump Microsoft.Extensions.Depen… (compare)
dependabot[bot] on nuget
Bump Microsoft.Extensions.Depen… (compare)
I ran a 200 node cluster with Phobos 2.0.2 this week and pushed 2.1b+ messages through it
in the span of about 2 hours
I need to try channelexecutor again on Akka.Persistence.Linq2Db... I tried it once early on and couldn't get it to work =/
OTOH, Every ADO Provider but SQLite is async AFAIK so it's not a big deal at present.
The main thing that would be nice IMO, and maybe there is a way to do this and it's just not doc'd, It would be nice to do something along the lines of, 'I want a dedicated channel just for this thing'.
@Aaronontheweb One thing to maybe look into, https://github.com/Cysharp/ValueTaskSupplement/blob/master/src/ValueTaskSupplement/ValueTaskEx.WhenAny.cs (Or it's non-generic version, you get the idea.)
Specifically, around https://github.com/akkadotnet/akka.net/blob/189380020609d7dec7ae2c90910dde1cd3236f98/src/core/Akka/Dispatch/ChannelSchedulerExtension.cs#L139-L177
You may need to do some refactoring to use it effectively, BUT there's some side benefits too, because Task.WhenAny
AFAIK will always allocate a new array anyway, and this uses ValueTaskSource for pooling IIRC
On a related note, Task.WhenAll
does the same thing, that one (on the coworkers) likely winds up being a bigger alloc, but would be harder to elide I would guess, short of reflection magic (i.e. calling InternalWhenAll to elide the defensive copy.
Hi @Aaronontheweb, I'm trying to use Remember Entities Persistence Mode by mongodb plugin but it not persist any entities or states
akka {
cluster {
sharding {
remember-entities = true
journal-plugin-id = "akka.persistence.journal.sharding"
snapshot-plugin-id = "akka.persistence.snapshot-store.sharding"
}
}
persistence{
journal {
plugin = "akka.persistence.journal.mongodb"
mongodb.class = "Akka.Persistence.MongoDb.Journal.MongoDbJournal, Akka.Persistence.MongoDb"
mongodb.collection = "EventJournal"
sharding {
class = "Akka.Persistence.MongoDb.Journal.MongoDbJournal, Akka.Persistence.MongoDb"
connection-string = "mongodb://localhost:27017/db"
collection = "ShardingEventJournal"
}
}
snapshot-store {
plugin = "akka.persistence.snapshot-store.mongodb"
mongodb.class = "Akka.Persistence.MongoDb.Snapshot.MongoDbSnapshotStore, Akka.Persistence.MongoDb"
mongodb.collection = "SnapshotStore"
sharding {
class = "Akka.Persistence.MongoDb.Snapshot.MongoDbSnapshotStore, Akka.Persistence.MongoDb"
connection-string = "mongodb://localhost:27017/db"
collection = "TradeOrderShardingSnapshotStore"
}
}
}
}
Any ideals?