sofastack/sofa-jraft

RFC: Add streaming APIs (RpcClient, RpcServer)

Open

#856 ouverte le 24 juin 2022

Voir sur GitHub
 (5 commentaires) (0 réactions) (1 assigné)Java (3 406 stars) (1 125 forks)batch import
enhancementhelp wanted

Description

Add streaming APIs (RpcClient, RpcServer), implement it based on gRPC.

This is a subtask that belongs to the first step of #672 In this subtask, we need a streaming impl, for the leader (client) to continuously send raft logs to followers.

Main goals:

  • Add streaming API to RpcClient and RpcServer
  • Implement streaming based on gRPC (We are not going to use bolt to implement)

Guide contributeur

Stack technique
javagrpc
Domaine
backendapi
Type d'issue
feature
DifficultéDifficulté estimée pour un nouveau contributeur, de 1 pour un très petit changement à 5 pour un travail expert.
4
Temps estiméFourchette de temps approximative pour investiguer, implémenter, tester et préparer une pull request.
3-5 days
Statut d'activitéDisponibilité apparente de l'issue : fraîche, active, ancienne, bloquée ou en attente d'un mainteneur.
stale
ClartéClarté avec laquelle l'issue explique le changement attendu, les critères d'acceptation et la prochaine étape.
clear
Prérequis
Java programminggRPC basicsRaft algorithm fundamentals
Accessibilité débutantScore de 1 à 100 estimant l'accessibilité de cette issue pour un premier contributeur.
25
Direction de recherche
Study the existing RpcClient and RpcServer interfaces (jraft core/src/main/java/com/alipay/sofa/jraft/rpc/). Based on gRPC streaming, design and implement streaming versions. Refer to subtask #672 for context. The implementation should allow leader to continuously send raft logs to followers. Consider using gRPC's bidirectional streaming.