Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Activity
  • Jun 18 18:39

    github-actions[bot] on master

    [maven-release-plugin] prepare … (compare)

  • Jun 18 18:39

    github-actions[bot] on release-2.10.19

    (compare)

  • Jun 18 18:39

    github-actions[bot] on master

    [maven-release-plugin] prepare … (compare)

  • Jun 18 18:31

    artem-v on 2.10.19

    (compare)

  • Jun 18 18:21

    artem-v on add-connection-reset-handler

    (compare)

  • Jun 18 18:21

    artem-v on master

    Added .handleConnectionReset at… Added .mapConnectionAborted at … Added back Hooks.onErrorDropped… and 1 more (compare)

  • Jun 18 18:21
    artem-v closed #817
  • Jun 18 18:21
    artem-v edited #817
  • Jun 18 18:19
    artem-v edited #817
  • Jun 18 18:18
    artem-v review_requested #817
  • Jun 18 18:18
    artem-v ready_for_review #817
  • Jun 18 18:08
    artem-v synchronize #817
  • Jun 18 18:08

    artem-v on add-connection-reset-handler

    Added back Hooks.onErrorDropped… (compare)

  • Jun 18 17:46
    artem-v synchronize #817
  • Jun 18 17:46

    artem-v on add-connection-reset-handler

    Added .mapConnectionAborted at … (compare)

  • Jun 18 16:31
    artem-v opened #817
  • Jun 18 16:31

    artem-v on add-connection-reset-handler

    Added .handleConnectionReset at… (compare)

  • Jun 18 12:23

    github-actions[bot] on 2.10.19

    (compare)

  • Jun 18 12:16

    artem-v on 2.10.19

    (compare)

  • Jun 18 11:46

    artem-v on master

    Removed static Hooks block from… (compare)

thoheoketket
@thoheoketket
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
Ronen
@ronenhamias
yhea this was just a playground test very long time ago
@thoheoketket
the idea was to check possibilities in scalecube project and learning
thoheoketket
@thoheoketket
so it means that i can not test it now?
thoheoketket
@thoheoketket
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
@thoheoketket
and i cant find class io.scalecube.net.Address. have you deleted that class? :((
Ronen
@ronenhamias
it was moved to another module
@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
Ronen
@ronenhamias
scalecube website moved:
http://scalecube.github.io/
riya-goyal
@riya-goyal
are we able to do the gossip with cluster node having private IP? If yes how exactly can we achieve this?
Ronen
@ronenhamias
@riya-goyal can you explain what do you mean private IP like LAN IPs?
in general you need to have network access for all nodes. so any node may connect to any node.
riya-goyal
@riya-goyal
@ronenhamias private IP means the IP that sits behind the router, which is not unique.
LiorBarnea
@LiorBarnea
Hi all, i am updating scalecube services from an old version, i had this working ->Microservices.builder()
.discovery(opt -> opt.seeds(seed.discovery().address()))
Now it doesnt, can you help me?
LiorBarnea
@LiorBarnea
never mind, found the example... trying to follow it...
Eugene Utkin
@eutkin
Hi all! How are you guys doing?
Ronen
@ronenhamias
Hello
gow are?
how are you ?
Eugene Utkin
@eutkin
I'm doing great. Now I'm in the lead of the development of the antifraud system. How is Scalecube Services doing?
Ronen
@ronenhamias
its doing amazing
its still open source :)
Eugene Utkin
@eutkin
Too bad my last PR was never accepted. But I plan to come back later and do more good
Joseph Tarbit
@Sm0keySa1m0n
Is there any examples of how namespaces work?
@eutkin you didnt finish the PR
basically all examples can be found inside the different modules
Eugene Utkin
@eutkin
@ronenhamias If my pr is still relevant to the project, let me finish it :)
Ronen
@ronenhamias
well there are good things in your PR
but you need to come to consensus about it so it can be accepted.
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.
Joseph Tarbit
@Sm0keySa1m0n
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
Joseph Tarbit
@Sm0keySa1m0n
The problem specifically occurs when you perform the second service call on the same thread as the last service call
Joseph Tarbit
@Sm0keySa1m0n
I've isolated the issue to the TCP transport
The problem doesn't occur with websocket transport
Joseph Tarbit
@Sm0keySa1m0n
More specifically, it's related to the "reactor-tcp-nio" thread group. It seems any time a service call is made inside this thread group, it causes issues, regardless of the transport type of the actual service you're calling.
Joseph Tarbit
@Sm0keySa1m0n
I've narrowed it down further to be an issue with service calls being made using the same event loop group. It seems that if you make another service call using the same event loop it fails to send the connection setup payload correctly
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
Joseph Tarbit
@Sm0keySa1m0n
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
Joseph Tarbit
@Sm0keySa1m0n
It also happens when they are using the same LoopResources instance
Joseph Tarbit
@Sm0keySa1m0n
It was due to using a pooled buffer which was causing data corruption when using the same event loop for multiple connections.
Ronen
@ronenhamias
great catch this should an important fix
will review your PR
@Sm0keySa1m0n