sofastack/sofa-jraft

RFC: Add streaming APIs (RpcClient, RpcServer)

Open

#856 geöffnet am 24. Juni 2022

Auf GitHub ansehen
 (5 Kommentare) (0 Reaktionen) (1 zugewiesene Person)Java (3.406 Stars) (1.125 Forks)batch import
enhancementhelp wanted

Beschreibung

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)

Contributor Guide

Tech Stack
javagrpc
Domain
backendapi
Issue Type
feature
SchwierigkeitGeschätzte Implementierungsschwierigkeit für neue Contributors, von 1 für sehr kleine Änderungen bis 5 für Expertenarbeit.
4
Geschätzte ZeitEin grober Zeitrahmen, um zu recherchieren, zu implementieren, zu testen und einen Pull Request vorzubereiten.
3-5 days
AktivitätsstatusWie verfügbar das Issue gerade wirkt: frisch, aktiv, stale, blockiert oder wartet auf Maintainer-Input.
stale
KlarheitWie klar das Issue die erwartete Änderung, Akzeptanzkriterien und den nächsten Schritt erklärt.
clear
Voraussetzungen
Java programminggRPC basicsRaft algorithm fundamentals
EinsteigerfreundlichkeitEin Score von 1 bis 100, der schätzt, wie zugänglich dieses Issue für First-Time Contributors ist.
25
Research-Richtung
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.