Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Activity
  • Jan 17 14:08
    IgorFedchenko commented #4126
  • Jan 17 14:07
    IgorFedchenko synchronize #4126
  • Jan 17 01:36
    dependabot-preview[bot] synchronize #3985
  • Jan 17 01:36

    dependabot-preview[bot] on nuget

    Bump FsCheck.Xunit from 2.9.0 t… (compare)

  • Jan 17 01:36
    dependabot-preview[bot] edited #3985
  • Jan 17 01:36
    dependabot-preview[bot] synchronize #4066
  • Jan 17 01:36

    dependabot-preview[bot] on nuget

    Bump FSharp.Quotations.Evaluato… (compare)

  • Jan 17 01:36
    dependabot-preview[bot] synchronize #3986
  • Jan 17 01:36

    dependabot-preview[bot] on nuget

    Bump NUnit from 3.6.1 to 3.12.0… (compare)

  • Jan 17 01:36
    dependabot-preview[bot] edited #4066
  • Jan 17 01:36
    dependabot-preview[bot] edited #3986
  • Jan 17 01:35
    dependabot-preview[bot] edited #3986
  • Jan 17 01:35
    dependabot-preview[bot] edited #3985
  • Jan 17 01:35
    dependabot-preview[bot] edited #4066
  • Jan 17 01:34

    dependabot-preview[bot] on nuget

    (compare)

  • Jan 17 01:34

    dependabot-preview[bot] on dev

    Bump System.Configuration.Confi… (compare)

  • Jan 17 01:34
    dependabot-preview[bot] closed #4131
  • Jan 17 00:01
    dependabot-preview[bot] synchronize #4131
  • Jan 17 00:01
    dependabot-preview[bot] synchronize #4066
  • Jan 17 00:01

    dependabot-preview[bot] on nuget

    Bump System.Configuration.Confi… (compare)

Arjen Smits
@Danthar
The merge should trigger an website update
Damian Reeves
@DamianReeves
Just an FYI... the ClusterSharding.Node example throws an exception on running

What are the minimal settings I need to get cluster sharding working?

This does not seem to be enough:

      akka {
        # here we are configuring log levels
        log-config-on-start = off
        stdout-loglevel = DEBUG
        loglevel = DEBUG
        # this config section will be referenced as akka.actor
        actor {
          debug {
              receive = on
              autoreceive = on
              lifecycle = on
              event-stream = on
              unhandled = on
          }
          serializers {
            wire = "Akka.Serialization.WireSerializer, Akka.Serialization.Wire"
          }
          serialization-bindings {
            "System.Object" = wire
          }
        }
        remote {
          helios.tcp {
            public-hostname = "localhost"
            hostname = "localhost"
            port = 0
          }
        }
        cluster {
          auto-down-unreachable-after = 5s
          sharding {
            least-shard-allocation-strategy.rebalance-threshold = 3
          }
        }
        persistence {
          # publish-plugin-commands = on              
          journal {
              plugin = "akka.persistence.journal.sqlite"
              sqlite {
                  class = "Akka.Persistence.Sqlite.Journal.SqliteJournal, Akka.Persistence.Sqlite"
                  plugin-dispatcher = "akka.actor.default-dispatcher"
                  table-name = event_journal
                  metadata-table-name = journal_metadata
                  auto-initialize = on
                  connection-string-name = "SqliteDb"
              }
          }

          snapshot-store {
            plugin = "akka.persistence.snapshot-store.sqlite"
            sqlite {
                # Class name of the plugin.
                class = "Akka.Persistence.Sqlite.Snapshot.SqliteSnapshotStore, Akka.Persistence.Sqlite"

                # Dispatcher for the plugin actor.
                plugin-dispatcher = "akka.persistence.dispatchers.default-plugin-dispatcher"

                # Dispatcher for streaming snapshot IO.
                stream-dispatcher = "akka.persistence.dispatchers.default-stream-dispatcher"

                table-name = snapshot
                auto-initialize = on
                connection-string-name = "SqliteDb"
            }
          }
        }
      }
Damian Reeves
@DamianReeves
Ahh, figured it out was missing:
provider = "Akka.Cluster.ClusterActorRefProvider, Akka.Cluster"
Maciek Misztal
@mmisztal1980
blob
Confirmed - I'm able to get lighthouse started on Mono :) with a minor burp inside TopShelf
@Aaronontheweb I'd like to take this a bit further and have some fun with Docker on Linux on the way, I'm curious about one thing though - how do I determine the addresses of seed nodes running as containers?
clausthalVK
@clausthalVK
Hi,
I need to use akka.net for a portable library
any help would be appreciated
Arjen Smits
@Danthar
@clausthalVK We currently don't have Akka as a PCL.
We are working on .net core support though.
Since .netstandard is the next generation of PCL, i recommend going with that... https://docs.microsoft.com/en-us/dotnet/articles/standard/library
clausthalVK
@clausthalVK
thank you
Daniel D'Agostino
@dandago2_twitter
@Danthar it seems the update did not trigger, because I still see the obsolete note :)
Arjen Smits
@Danthar
@dandago2_twitter Yes i know. Somehow the drone that updates the site is having a hissy-fit. We are looking into it.
Daniel D'Agostino
@dandago2_twitter
Cool :)
I'll also update the docs to fix this one later today. akkadotnet/akka.net#2339
@DamianReeves re async/await, I wrote a little article about that a little while back, in case it helps: http://gigi.nullneuron.net/gigilabs/asynchronous-and-concurrent-processing-in-akka-net-actors/
Damian Reeves
@DamianReeves
cool I'll check it out
Arjen Smits
@Danthar
@dandago2_twitter cool. Thx!
Daniel D'Agostino
@dandago2_twitter
Guys is there any material available on how to use Lighthouse please?
Maciek Misztal
@mmisztal1980
Daniel D'Agostino
@dandago2_twitter
I watched that video a couple of times before, I seem to remember that it explains what Lighthouse does, not how to use it :)
Maciek Misztal
@mmisztal1980
it does. it tells you what needs to be configured in order to get started with lighthouse and other clustered nodes.
Damian Reeves
@DamianReeves
I'm having issues getting Cluster Sharding to work:
I see this in logs:
[WARNING][10/11/2016 1:07:12 PM][Thread 0004][[akka://example/user/sharding/product#924346451]] Trying to register to coordinator at [], but no acknowledgement. Total [12] buffered messages.
Bartosz Sypytkowski
@Horusiath
@DamianReeves are you using cluster sharding on a single node?
Damian Reeves
@DamianReeves
Yes
Wanted to verify single before expanding
Here is the code I'm calling:
    private static void ShardingExample(ActorSystem system)
    {
        var sharding = ClusterSharding.Get(system);
        var shardRef = sharding.Start("product", Props.Create(() => new Product()), ClusterShardingSettings.Create(system),
            message =>
            {
                var productMessage = message as IProductMessage;
                return productMessage != null ? Tuple.Create(productMessage.Id.Value, message) : null;
            }, message => "0001");

        shardRef.Tell(new CreateProduct(ProductId.CreateAsin("ACME001"), "Jetpack"));
        shardRef.Tell(new CreateProduct(ProductId.CreateAsin("ACME002"), "Giant magnet"));



        var rand = new Random();
        for (int idx = 0; idx < 10; idx++)
        {
            var productId = ProductId.CreateAsin($"ACME00{rand.Next(1, 3)}");
            shardRef.Tell(new SubmitReview(productId, rand.Next(1, 6)));                               
        }
    }
Bartosz Sypytkowski
@Horusiath
the reason is that coordinator (the actor working as a central index for all shards) is not available - I'm not 100% sure, what the reason might be, but I would say, that you might have tried to send sharded messages before cluster has started
Damian Reeves
@DamianReeves
Should I wait for a MemberUp, before using cluster sharding?
Bartosz Sypytkowski
@Horusiath
there is a method Cluster.Get(system).RegisterOnMemberUp(() => { ... })
yes
at least this is what I'd suspect
Damian Reeves
@DamianReeves
Think that helped me see the problem:
[INFO][10/11/2016 1:21:11 PM][Thread 0014][[akka://example/system/cluster/core/daemon#301706840]] No seed-nodes configured, manual cluster join required
Does the current node not automatically get added as a seed?
Bartosz Sypytkowski
@Horusiath
no, you need to set itself as a seed node if you want to create 1 node cluster
Damian Reeves
@DamianReeves
Cool.. Set the seed node and now I'm in business. Thanks
Bartosz Sypytkowski
@Horusiath
np :)
Damian Reeves
@DamianReeves
Is there a simple way to programmatically add roles to a Cluster node
?
Peter Bergman
@peter-bannerflow
I think this question has been posted before but I cannot find the answer so here it goes, if I do an ActorSelection, can I then somehow check if that leads to an actor or not? If that makes sense...
Arjen Smits
@Danthar
@peter-bannerflow you can use the ResolveOne method on an actorselection
Peter Bergman
@peter-bannerflow
Ah yes, or actually I only want to do this in a case where the ActorSelection leads to a child of Self, so I guess I can just do Context.Child("name").IsNobody()
Arjen Smits
@Danthar
or send an Identify message, which will return an ActorIdentity response.
ah yes, if you want to know if a child exists checking for the nobody status is faster
Peter Bergman
@peter-bannerflow
Cool, thx
Sean Farrow
@SeanFarrow

@damianReeves are you talking about adding new nodes at the same time as roles, or it is just roles to a node?

+

All Conversations

Activate or click this element to toggle the profile menu

Search

Favourites

People

akkadotnet

Home

Billing

Get Gitter Apps

Sign Out

Add a room

akka.net

101

Leave

Hide

AkkaStreams

Leave

Hide

All Rooms

dotnet-core

akkadotnet.github.com

Wire

Peter Bergman @ akkadotnet/akka.net

Cool, thx

Arjen Smits @ akkadotnet/akka.net

ah yes, if you want to know if a child exists checking for the nobody status is faster