Package org.apache.hadoop.hdds.freon

Class FakeRatisFollower

java.lang.Object
org.apache.hadoop.hdds.freon.FakeRatisFollower
public final class FakeRatisFollower extends Object
Helper class to use it to replace original Ratis GRPC outgoing calls.

  • Method Summary

    Modifier and Type
    Method
    Description
    static org.apache.ratis.thirdparty.io.grpc.stub.StreamObserver<org.apache.ratis.proto.RaftProtos.AppendEntriesRequestProto>
    appendEntries(org.apache.ratis.protocol.RaftPeerId raftPeerId, org.apache.ratis.thirdparty.io.grpc.stub.StreamObserver<org.apache.ratis.proto.RaftProtos.AppendEntriesReplyProto> responseHandler)
     
    static org.apache.ratis.proto.RaftProtos.RequestVoteReplyProto
    requestVote(org.apache.ratis.protocol.RaftPeerId raftPeerId, org.apache.ratis.proto.RaftProtos.RequestVoteRequestProto request)
     

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Method Details

    • appendEntries

      public static org.apache.ratis.thirdparty.io.grpc.stub.StreamObserver<org.apache.ratis.proto.RaftProtos.AppendEntriesRequestProto> appendEntries(org.apache.ratis.protocol.RaftPeerId raftPeerId, org.apache.ratis.thirdparty.io.grpc.stub.StreamObserver<org.apache.ratis.proto.RaftProtos.AppendEntriesReplyProto> responseHandler)

    • requestVote

      public static org.apache.ratis.proto.RaftProtos.RequestVoteReplyProto requestVote(org.apache.ratis.protocol.RaftPeerId raftPeerId, org.apache.ratis.proto.RaftProtos.RequestVoteRequestProto request)