https://github.com/scalecube/scalecube-services ⚛ High-Speed ⚛ Cloud-Native ⚛ Reactive Microservices ⚓
I just want to learn about Raft-leader-election so I have downloaded the raft-leader-election-master project but in the project has Mircoservices and others that related to the bigger project so I have downloaded them all but i still can not run anythings because they got conflicts with each others. can someone have me pls? thank you so much. I have downloaded clumsy/scalecube and scalecube/scalecube-services. I have build them both and change the dependencies of the raft project with both but I still can not run :(( so can someone tell me that have I downloaded the right project? thank you so much
@thoheoketket
the idea was to check possibilities in scalecube project and learning
I have built the clumsy/scalecube successfully and use it as dependency for my raft-leader-election-master. everything is ok except the test folder. in one of the file test, the function startAwait() of Microservices cant be found. I dont know how to fix it to run the test folder. can u help me pls @ronenhamias. thank you so so much
@thoheoketket i am saying it passed long time since i maintained it so dont know the status of it
i suggest to consider it like a code example
in general you need to have network access for all nodes. so any node may connect to any node.
Now it doesnt, can you help me?
gow are?
how are you ?
its still open source :)
@eutkin you didnt finish the PR
basically all examples can be found inside the different modules
but i would not say its something we really need in our day to day life its nice improvement.
so its up to you to make progress on it if you see value.
I'm getting a strange issue where if I call a service from the rsocket-worker thread (e.g. I flat map the result of an earlier service call), RSocket fails to write the setup payload correctly. If I simply add subscribeOn(Schedulers.parallel()) before calling service method, it works with no issues.
I've outlined the issue in more detail in this issue: scalecube/scalecube-services#743
The problem doesn't occur with websocket transport
I've tested it by sending a byte in the ConnectionSetupCodec, when calling two services using the same event loop, the byte received on the server is not the one that was sent implying its got corrupted somehow
I think the issue is using LoopResources::colocate because the problem not only happens on scalecube's own event loop but also when a call is made inside any netty event loop
It was due to using a pooled buffer which was causing data corruption when using the same event loop for multiple connections.
will review your PR
@Sm0keySa1m0n