Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Activity
  • 21:29
    Aaronontheweb commented #3863
  • 21:28
    Aaronontheweb synchronize #3863
  • 21:18
    Aaronontheweb synchronize #4000
  • 21:17
    Aaronontheweb commented #3964
  • 21:17
    Aaronontheweb commented #3964
  • 21:16
    Aaronontheweb synchronize #3964
  • 21:12
    Aaronontheweb commented #3964
  • 21:08
    Aaronontheweb synchronize #71
  • 21:04
    Aaronontheweb synchronize #3973
  • 21:00
    Aaronontheweb commented #71
  • 20:58

    Aaronontheweb on dev

    Akka.Persistence.TCK fix - chec… (compare)

  • 20:58
    Aaronontheweb closed #4002
  • 20:51
    Aaronontheweb synchronize #4002
  • 20:45
    Aaronontheweb commented #3811
  • 20:45
    Aaronontheweb commented #3811
  • 20:44
    Aaronontheweb labeled #4002
  • 20:43
    Aaronontheweb milestoned #4002
  • 20:43
    Aaronontheweb opened #4002
  • 20:37
    Aaronontheweb synchronize #71
  • 20:20
    Aaronontheweb synchronize #71
Bartosz Sypytkowski
@Horusiath
@Zetanova I guess not
btw. nice talk about new enterprise stack @Aaronontheweb
Aaron Stannard
@Aaronontheweb
@Zetanova Helios has one internally that you can grab from the soruce
source*
Bartosz Sypytkowski
@Horusiath
I'm always starting presentation from saying how most of the listeners won't probably need a thing, from what I'm gonna talk about ;)
Aaron Stannard
@Aaronontheweb
thanks @Horusiath - glad you liked it
Zetanova
@Zetanova
i am getting so drepssed, with the actor model, resolving one thing leads to 2 new
Or some slim timeout cache for Id's
Bartosz Sypytkowski
@Horusiath
@Zetanova are you sure, you're not over-engineering things? It's really easy to do so by accident
Zetanova
@Zetanova
I have in my AggregateCoordinator a backpressure algo.
no i have two "Importer"
from two sources
the need to lookup if the AR exsists
i made a Flush command (Basicly a Loop to the Projector), it is working
but if the "Create" AR command is in the backpressure Queue
that will not help
Bartosz Sypytkowski
@Horusiath
I'm worried that I won't be able to help without some sort of a drawing here
Zetanova
@Zetanova
Its basicly GetByForeignKeyOrCreate problem
Bartosz Sypytkowski
@Horusiath
what is backpressure queue in your case?
Zetanova
@Zetanova
1000 active AR's rest goes in the queue
the AggregateCoordinator tries to shutdown the AR's and the AR's will maybe passivate
but if two Sources are looking for the ForeignKey in the readside (even with flush-command)
they second will not find it because the "Create" command is still in the backpressure queue
Bartosz Sypytkowski
@Horusiath
what is Create command here?
Zetanova
@Zetanova
Create AggregateRoot
example: Account has Id and Name
First Processor: Flush, GetAccountByName or Create-Command
Second Processor: Flush, GetAccountByName or Create-Command
it is working
until the Create-Command is still in the air
or in the backpressure queue
Bartosz Sypytkowski
@Horusiath
if you're relying on GetByKeyOrCreate, why are you having Create here?
Zetanova
@Zetanova
its not the Key its a query and i need to know if the AR exsists to get his Id or create it
now i thought i am extracting the critical values into a cirucalr buffer
to look it up
I am getting the data from two sources that are basicly two Actors that processing the incoming data
they lookup if it is allready there if not, the create the new AR
one of them should create a new AR, but send to the exsisting one some "patch" commands
Bartosz Sypytkowski
@Horusiath
why they are in order of creating it? shouldn't that be a concern of separate actor?
Zetanova
@Zetanova
yes, thats my plan, but for that i would need some kind of buffer, to lookup the last
will try tomorrow, gn8
Bartosz Sypytkowski
@Horusiath
np, see you tomorrow
Aaron Stannard
@Aaronontheweb
@Horusiath I'll see about helping out with some of these Akka.Persistence test failures too
Vagif Abilov
@object
Good morning, I am trying to build Akka.Net from sources (master branch), but Akka.Cluster.TestKit doesn't compile with plenty of errors (missing ImmutableHashSet etc.).
And 16 of 172 tests in Akka.Persistence.Tests failed. Do they need some machine-specific prerequisite?
Bartosz Sypytkowski
@Horusiath
@object In general our main working branch is dev. It looks like your nuget restore may have failed. Also about tests - if your using R# with xunit test runner, those tests have tendency to fail randomly.
... which is another issue @Aaronontheweb - I don't know how to achieve this, but we cannot afford random false flags in tests. This problem will be even bigger when we'll introduce akka streams, as we'll have 800 additional cases, that also have tendency to give us false negatives.
using xunit with parallel mode off? Maybe switching to NUnit could help?
Alex Valuyskiy
@alexvaluyskiy
@Aaronontheweb I've updated SqlServer and PostgreSql implementations to Akka 1.0.7, and have made a pull request to MySql repo.
But I have failed unit tests in PostgreSql, when I update to Npgsql 3.0.5 (but all works fine with Npgsql 2.x). I need help with that