Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Activity
  • 07:55
    ismaelhamed commented #3284
  • Sep 13 16:35
    Aaronontheweb commented #3905
  • Sep 13 16:35
    Aaronontheweb labeled #3905
  • Sep 13 16:35
    Aaronontheweb labeled #3905
  • Sep 13 16:35
    Aaronontheweb labeled #3914
  • Sep 13 16:34
    Aaronontheweb commented #3914
  • Sep 13 01:50
    Aaronontheweb synchronize #3914
  • Sep 13 01:45
    Aaronontheweb commented #3914
  • Sep 12 14:10
    Aaronontheweb synchronize #3914
  • Sep 12 14:10

    Aaronontheweb on dev

    name AzureDevops artifacts per … (compare)

  • Sep 12 14:10
    Aaronontheweb closed #3915
  • Sep 12 13:57
    Aaronontheweb synchronize #3915
  • Sep 12 13:37
    Aaronontheweb opened #3915
  • Sep 12 06:43
    Horusiath commented #3628
  • Sep 12 05:57
    Horusiath synchronize #3628
  • Sep 12 02:05
    Aaronontheweb synchronize #3901
  • Sep 12 02:04
    Aaronontheweb commented #3914
  • Sep 12 02:03
    Aaronontheweb synchronize #3914
  • Sep 12 01:11
    Aaronontheweb commented #3105
  • Sep 12 01:10
    Aaronontheweb closed #3105
rsinohara
@rsinohara
A hack would be to do it through a property setter/getter (ewww)
Bartosz Sypytkowski
@Horusiath
if I make a shortcut to test only the specific behavior without steps that I need to make on the way, then I'm not truly testing that behavior. Simply because the tested scenario is artificial and doesn't occur in reality
heh, testing only the behavior is something that's going to happen, when akka-typed goes out :P
rsinohara
@rsinohara
I get what you mean now
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