Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Activity
  • Oct 18 19:12
    IgorFedchenko commented #3998
  • Oct 18 18:29
    Aaronontheweb commented #3998
  • Oct 18 18:24
    Aaronontheweb opened #3998
  • Oct 18 18:19

    Aaronontheweb on fix-readme-logo

    (compare)

  • Oct 18 17:30
    Aaronontheweb milestoned #3973
  • Oct 18 16:38
    jaydeboer opened #3997
  • Oct 18 15:53
    Aaronontheweb synchronize #3973
  • Oct 18 15:52

    dependabot-preview[bot] on dev

    Bump Microsoft.NET.Test.Sdk fro… (compare)

  • Oct 18 15:52

    dependabot-preview[bot] on nuget

    (compare)

  • Oct 18 15:52
    dependabot-preview[bot] closed #3996
  • Oct 18 15:52
    Aaronontheweb commented #3996
  • Oct 18 14:53
    Aaronontheweb commented #3973
  • Oct 18 12:20
    IgorFedchenko commented #3973
  • Oct 18 12:17
    IgorFedchenko commented #3973
  • Oct 18 11:58
    IgorFedchenko synchronize #3973
  • Oct 18 11:33
    IgorFedchenko commented #3973
  • Oct 18 11:25
    IgorFedchenko synchronize #3973
  • Oct 18 07:04
    dependabot-preview[bot] labeled #3996
  • Oct 18 07:04
    dependabot-preview[bot] opened #3996
  • Oct 18 07:04

    dependabot-preview[bot] on nuget

    Bump Microsoft.NET.Test.Sdk fro… (compare)

rsinohara
@rsinohara
Maybe I should rethink my testing startegy
Is there any material on actor (unit) testing?
I'd love a book about that.
Bartosz Sypytkowski
@Horusiath
the biggest reference is akka repository - around 4000 examples ;P
rsinohara
@rsinohara
Aren't they too low level?
Bartosz Sypytkowski
@Horusiath
it depends, most of them are actually integration tests - using the testkit itself
rsinohara
@rsinohara
Interesting then. I'll take a look. Thanks :)
Jeff
@jpierson
Is there a way to create a ConsistentHashingGroup router where the hash id determined by the sender as opposed to something in each message?
On second thought, perhaps it would be better to have some other actor responsible for providing another actor for direct communication (routee) based on a consistent hash of the sender without using a router. Is this an existing pattern already that has a name? I'm running into this where I have interfaces between external services where I wanted ordered retry logic but don't want to force everything to be processed in serial, just in proper order based on the sender to keep the sender/receiver order guarantees.
Aaron Stannard
@Aaronontheweb
I think I'll be able to add the ability to log anything on the Scheduler that wasn't executed at the time it was shutdown
as part of some of these changes
Michael
@michaelsg
anyone have familiarity with the F# api? I have one nagging question about the implementation of pipe operator |!>.
Bartosz Sypytkowski
@Horusiath
@michaelsg what's up?
Michael
@michaelsg
Had a question about the implementation of the pipeTo (|!>) operator - how it's supposed to work. I gathered that it was supposed to be non-blocking but it uses Async.StartWithContinuations which starts the async on the current thread. I think it only work right for the things like in the examples of its use - that are already-running .net things wrapped in asyncs.
if I create an f# async - not just something wrapping a task or async pattern, it blocks.
Bartosz Sypytkowski
@Horusiath
what are you creating F# async for?
Michael
@michaelsg
to do background work :-) sorry. not trying to be cheeky. I don't know what you mean.
Bartosz Sypytkowski
@Horusiath
I'm just asking for the use case ;) If you're working with something that already starts an async, it should be good to go.
Michael
@michaelsg
so that's the thing. Async (the kind you make with async {}) aren't running when they are created. and starting one does not return an async - it returns unit.
Bartosz Sypytkowski
@Horusiath
yep, it may be a problem ;) Probably something to be fixed - can you set a github issue on that?
Michael
@michaelsg
async { do! Async.Sleep 50000.; return AMessageToSend("hello") } |!> mbx.Self
you agree that shouldn't block?
Corneliu
@corneliutusnea
guys, any guidance on deploying Akka cluster on Azure?
Maciek Misztal
@mmisztal1980
depends on what you need?
Corneliu
@corneliutusnea
anything to make my life easy-ier :smile: e.g. how do deploy lighthouse-es, experiences, dealing with azure vm virtual ips
Maciek Misztal
@mmisztal1980
right, so far I've used lighthouse deployed on to static IaaS VMs to act as a "fixed cluster anchor" with static public IPs. when setting up the config, you need to take both the public and the private IPs into account :) As for nodes joining the cluster - those can be pretty much anything... old Azure Service Roles, WebJobs, Functions?, ServiceFabric processes, Containers - take your pick :)
Corneliu
@corneliutusnea
thanks, that's already good advice
I'm thinking of doing everything on VMs just to keep it simpler
Yin Zhang
@melcloud
Hi all. I would like to have a bounded stash to cache incoming messages when the database is not available. Since the BoundedStash is not implemented, can I use the ICircularBuffer from Helios to achieve this instead of writing my own circular buffer? Or there is any other ways to do it?
Jeff
@jpierson
@mmisztal1980 From what could find Azure WebJobs don't support any protocol other than HTTP specifically and only over the typical ports. If you understand this differently I'd be interested.
Corneliu
@corneliutusnea
@mmisztal1980 How did you configure your LH to use both public & private IPs? I tried in helios to use the "public" ip (10.0.0.4) and in hostname 127.0.0.1 but I get errors
Dropping message [Akka.Actor.ActorSelectionMessage] for non-local recipient
Aaron Stannard
@Aaronontheweb
@corneliutusnea need to use 0.0.0.0 for hostname instead
since a public IP won't resolve to loopback
but all-addresses can catch it
Alex Michel
@amichel
I have a design question. Let's say I want to build a service that handles currency exchange rates.
I can get rates for €/$ and $/¥ and do some basic processing on them.
I also need to support calculated/synthetic rates for €/¥
So every time either €/$ or $/¥ update I need to recalculate €/¥
Another requirement is to support €/¥ also directly so I can decide in config if I get it from outside or calculate it as synthetic
I obviously need to process all prices in order so I will have a consistenthashpool of actors
Alex Michel
@amichel
Key is currency pair
But I am not sure how to make the routing correctly in case of synthetic pairs
Alex Michel
@amichel
Or should I simply call parent to recalculate and forward update message to correct child?
Alex Valuyskiy
@alexvaluyskiy
The first alpha version of Akka.Net on netstandard is ready. Just add a new myget feed https://www.myget.org/F/akka-netcore/api/v3/index.json and use it
Only Akka, Akka.Persistence (Sqlite) and Akka.TestKit modules are available at the moment
Vaccano
@Vaccano
Is there a way to talk to akka.net from nodeJs?
(JavaScript)
Arjen Smits
@Danthar
@Vaccano not directly.
Bartosz Sypytkowski
@Horusiath
@Vaccano you've got akka.js, which can communicate with akka on JVM