Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Activity
  • 14:44
    IgorFedchenko commented #4022
  • 14:16
    IgorFedchenko opened #4057
  • Nov 21 23:45
    nagytech commented #4054
  • Nov 21 23:40
    MaximG1234 commented #4054
  • Nov 21 23:37
    MaximG1234 commented #4054
  • Nov 21 23:37
    MaximG1234 commented #4054
  • Nov 21 23:36
    nagytech commented #4054
  • Nov 21 23:36
    nagytech commented #4054
  • Nov 21 23:36
    MaximG1234 commented #4054
  • Nov 21 23:12
    MaximG1234 commented #4054
  • Nov 21 23:12
    MaximG1234 commented #4054
  • Nov 21 23:11
    MaximG1234 commented #4054
  • Nov 21 21:54
    nagytech commented #4054
  • Nov 21 21:44
    Aaronontheweb commented #4054
  • Nov 21 21:44
    Aaronontheweb commented #4054
  • Nov 21 21:33
    MaximG1234 commented #4054
  • Nov 21 21:31
    Aaronontheweb commented #4054
  • Nov 21 21:31
    MaximG1234 commented #4054
  • Nov 21 21:31
    MaximG1234 commented #4054
  • Nov 21 20:04
    Aaronontheweb synchronize #4022
Peter Bergman
@peter-bannerflow
@Danthar I am also using the stackexchange redis client and it seem to work fine. I create a static ConnectionMultiplexer reference in my main service class where I boot up my actor system, then I do GetDatabase() calls on that reference from inside my actors
Marc Piechura
@marcpiechura
@SeanFarrow out of curiosity, why aren't you allowed to use streams?
Sean Farrow
@SeanFarrow

+

All Conversations

Activate or click this element to toggle the profile menu

Search

Favourites

People

akkadotnet

Home

Billing

Get Gitter Apps

Allow Private Repo Access

Sign Out

Add a room

akka.net

Leave

Hide

Your Suggestions

SuaveIO/suave

aurelia/Discuss

akka/akka

mono/mono

dotnet/corefx

dotnet/coreclr

akka-bootcamp

helios-io/helios

IdentityServer3

visualfsharp

TypeScript

Rx.NET

Your Organisations

Twitterizer

I'm not saying I'm not allowed to use streams, the way the StackExchange Redis subscription system works doesn't lend itself to doing so though!

Marc Piechura
@marcpiechura
Ahhh :) I thought client = customer ;)
Sean Farrow
@SeanFarrow

@Silv3rcircl3 It's nots that simple! I think I've fiund a solution, when I validate it, I'll let you know--you never know, I might release it as open source!

+

All Conversations

Activate or click this element to toggle the profile menu

Search

Favourites

People

akkadotnet

Home

Billing

Get Gitter Apps

Allow Private Repo Access

Sign Out

Add a room

akka.net

Leave

Hide

Your Suggestions

SuaveIO/suave

aurelia/Discuss

akka/akka

mono/mono

dotnet/corefx

dotnet/coreclr

akka-bootcamp

helios-io/helios

IdentityServer3

visualfsharp

TypeScript

Rx.NET

Your Organisations

Twitterizer

It's not that somple. I think I've got a solution though, when I find one, I'll let you know!

Marc Piechura
@marcpiechura
@seanfarrow let me know if you need some help. Also maybe my Azure adapter can give you some inspiration, don't know how Redis works but maybe it helps https://github.com/Silv3rcircl3/Akka.Streams.Azure
Aaron Stannard
@Aaronontheweb
boy, I've missed a lot of messages in here
vacation and doing remote work :p
In the UK at the moment; should be here through the end of the next week
but will go through all of this once I'm back
probably going to do a small point release soon with some minor Streams bug fixes, fixes for the priority mailbox, and others
also thinking about sending in a PR to skip some of the specs we know to be broken like the ClusterClient specs
no point in just re-running stuff repeatedly when the thing under test doesn't work
there's some specs, like the ActorsLeakSpec in Akka.Remote, that are just super complicated and can time out when things get busy... which makes me think maybe I should $$$ and increase the size of our VMs
Peter Bergman
@peter-bannerflow
When running an Akka.Cluster, is there any way for an actor in an actor system that has joined the cluster to get information about the number of nodes that joined the cluster with a specific role? I am just interested in the count nothing more than that
Aaron Stannard
@Aaronontheweb
@peter-bannerflow yep, Cluster.State will have that data
basically just iterate over all members and select them by their role
Peter Bergman
@peter-bannerflow
Nice, perfect :)
Vagif Abilov
@object
I am checking out a WebCrawler sample updated by @Aaronontheweb, the akka-streams branch revised to use Akka.Streams. Am I correct that the sample is not finished and quite a lot code may be removed? Right now it looks like Stream implementation is added on the top of the old code, so it's a hybrid sample supporting both plain actors and Akka streams. Is this so?
Marc Piechura
@marcpiechura
@object akka streams is bound to a local actor system so you need plain actors with clustering to distribute the work across nodes
Problem is that the reactive stream protocol works with demand that is send upstream and needs full deliver guarantees because otherwise the stream would deadlock
Vagif Abilov
@object
@Silv3rcircl3 yes, but I see that DownloadCoordinator code just increased by 50 lines and a new case (StreamCompleteTick). Shouldn't the newly introduced workflow graph replace some of low-level actor arrangements?
Marc Piechura
@marcpiechura
Don't know :) haven't looked at the code and don't know what is planed. Thought your question is more related to the fact that plain actors are used for the distributed work
Cc @Aaronontheweb
Vagif Abilov
@object
I understand that the implementation of Akka streams require materializer to be backed by actual actors, I am just trying to make sense of the example and reacted on the fact that it kept more or less the same complexity plus added stream flow.
Perhaps @Aaronontheweb can clarify it that example needs some cleanup.
Marc Piechura
@marcpiechura
That's not 100% correct, one feature of akka streams is that you can create your own materializer that doesn't need to use actors under the hood, for example on the jvm they released a new Gearpump materializer that can distribute a stream
Vagif Abilov
@object
@Silv3rcircl3 and when it comes to actor system requirement, what if the flow contains a trivial functional transformation, e.g. some arithmetic or string processing function, does it still require an actor for this?
Oh you already answered my next question, but can I combine actors and non-actors in the same flow?
Marc Piechura
@marcpiechura
Not sure I understand your question correctly, if for example you use a where + select these two stages would run in the same actor, this feature is called "Fusing", the stages are fused together, into a single actor, if they doesn't have async boundaries
What exactly do you mean by "actors and non-actors in the same flow" ?
Vagif Abilov
@object
Sorry for being unclear, I am still in the process of getting the concept. What I roughly meant is if I need to do a Select with a functional transformation on an intermediate result. But you already explained fusing and this probably what I had in mind :-)
Marc Piechura
@marcpiechura
Great :) all the select / where / GraphDSl methods only create a blueprint of the stream, they doesn't start any actors nor is any work started until you call one of the Run methods. When you do so the materializer creates actors as needed based on your settings and graph. For example you could disable fusing and therefore every stage would run in its own actor
Vagif Abilov
@object
Makes sense, thanks!
Marc Piechura
@marcpiechura
Np
Vagif Abilov
@object
But that WebCrawler example still suspiciously looks like needing some code cleanup, but I leave this question for @Aaronontheweb :-)
Maciek Misztal
@mmisztal1980
anyone tried starting lighthouse on mono? it fails to bind for some reason :worried:
Chris Morley
@csmorley
Hi all, been googling for past few hours and stepping through source, can anyone point me in the right direction if i want to intercept calls to System.ActorOf(props); bascially i would like to control how the actor is constructed
Corneliu
@corneliutusnea
@csmorley did you try to do it via the DI? The DI can do custom construction
Aaron Stannard
@Aaronontheweb
@object yep, haven't quite finished it yet
using Streams heavily in a real project right now and that's informed my tastes somewhat
so I'll be refining it before I publish it, as well as deleting much of the old code
@mmisztal1980 I need to update it to 1.1.2 Akka
that should fix it
DNS / IPv6 stuff
Daniel D'Agostino
@dandago2_twitter
hey guys, from http://getakka.net/docs/clustering/cluster-overview I read: "NOTE: Akka.Cluster is currently a pre-release nuget package, so you'll need to set the pre flag when you install it into your applications. Akka.Cluster will be considered "fully released" once Akka.NET v1.1 ships." -- I thought both Akka .NET 1.1 and Akka.Cluster were already out, so is this just a case of outdated documentation? :)
Arjen Smits
@Danthar
yes.
You are more then welcome to do a PR :)
Daniel D'Agostino
@dandago2_twitter
I'm not sure what workflow you use for these updates :)
Arjen Smits
@Danthar
Simple. Fork the getakka.net repo. Make the changes in the .md file as needed.