Hey everyone. Fantastic project! Following a while now... Watched your cluster contrib meeting on YT and there you mentioned the need of a MultiNode Visulaizer.
So I did a little something :). It is not pretty and it is written in F# (currently learning so code is probably a mess), so do not expect too much.
But maybe I can do something out of it (spit out static HTML) if needed.
https://github.com/Birnsen/MultiNodeVisualizer/blob/master/mnv.png
The numbers are the amount of events at that given moment. If an test fails is also not implemented yet but should be easy to do...
Had only one file to test it so others will probably fail.
but the json file as input not real time
i am not that much of a js guy though
Does Akka have an equivalent to RxEx's .Buffer()? Buffer works by queuing up messages, but instead of sending them through as they arrive, it will queue up to n messages, or queue up messages for n seconds. When either the time or the capacity limit is reached, it sends through all the messages at once. For example, I might put "buffer 5 seconds" in front of writing changes to the cache to disk. That way I can merge the changes into a bigger write. (Sacrificing up to 5 seconds of data if the program crashes.)
I could probably build this using an Actor, and a delayed message send using the scheduler, but I'm guessing something like this already exists, if I just knew the name.
everything is up to date
not 100% sure what's going on there - haven't investigated yet, but it looks like the Cassandra plugin was depending on something for serialization that the other plugins werent
it's weird man. I can pull the serialization code into the Cassandra project and it serializes just fine
@Aaronontheweb @rogeralsing I think we should include one of the sql-based persistence plugins in core repo - it would be nice to actually being able to test Akka.Persistence.Sql.Common lib changes, and this is hard because we don't have any direct implementation in core repository
I guess sqlserver or sqlite would be good fit, since they have natural dependencies in .net environment or don't have any dependency at all
from jvm akka: remote events
so having a reference implementation, e.g. sqlserver in the core would solve that
@schatekar added html output. you can see some examples at https://github.com/Birnsen/MultiNodeVisualizer/tree/master/output
if you move your mouse over an item you see the corresponding message at that time. Let me know if you miss something...
if you move your mouse over an item you see the corresponding message at that time. Let me know if you miss something...
@rdavisau would you mind taking a peek at https://github.com/rogeralsing/Wire ? I've added tests for F# types and they all pass.. got a local branch of Akka.NET using Wire serializer and all serializer tests pass there too... looking good so far, but Im sure there are edgecases that I havent covered yet, both regardng F# and the normal type system
btw well done, the performance results are impressive :+1:
class FooActor : UntypedActor
{
public FooActor()
{
Console.WriteLine("FooActor: ConstructorB");
}
{
public FooActor()
{
Console.WriteLine("FooActor: ConstructorB");
}
protected override void PreStart()
{
base.PreStart();
Console.WriteLine("FooActor: PreStart");
}
protected override void PostStop()
{
base.PostStop();
Console.WriteLine("FooActor: PostStop");
}
protected override void OnReceive(object message)
{
string number = (string)message;
Console.WriteLine("FooActor: OnReceiving:\t {0}", number);
Thread.Sleep(2000);
Console.WriteLine("FooActor: OnReceived:\t {0}", number);
}
}
class Program
{
static void Main(string[] args)
{
using (ActorSystem system = ActorSystem.Create("BLUE"))
{
IActorRef fooActor = system.ActorOf(Props.Create(() => new FooActor()), "FooActor");
fooActor.Tell("1");
fooActor.Tell("2");
Thread.Sleep(100);
//system.Stop(fooActor);
system.Shutdown();
//fooActor.Tell(PoisonPill.Instance);
system.AwaitTermination();
Console.WriteLine("Shutdon Completed");
Console.ReadLine();
}
Console.ReadLine();
}
}
Sometimes the tests run but no breakpoint is hit. other times visual studio just freezes
which version of visual studio do you use?
i think shutdown method have to wait for all of actors completed.
is it bug?
anyone know how to send to a clustered consistent-hashing-pool created on another port/process? Tried doing an actorselection & tell but it doesn't get there (deadlettered). tried creating the router on the secondary client but then it's a diff actor that receives the message. not sure if i'm trying to do something i shouldn't or just missing something simple