com.alipay.sofa.jraft.rpc.impl.cli

Class BaseCliRequestProcessor<T extends com.google.protobuf.Message>

java.lang.Object

com.alipay.sofa.jraft.rpc.RpcRequestProcessor<T>

com.alipay.sofa.jraft.rpc.impl.cli.BaseCliRequestProcessor<T>

Type Parameters:

T -

All Implemented Interfaces:

RpcProcessor<T>

Direct Known Subclasses:

AddLearnersRequestProcessor, AddPeerRequestProcessor, ChangePeersRequestProcessor, GetLeaderRequestProcessor, GetPeersRequestProcessor, RemoveLearnersRequestProcessor, RemovePeerRequestProcessor, ResetLearnersRequestProcessor, ResetPeerRequestProcessor, SnapshotRequestProcessor, TransferLeaderRequestProcessor

public abstract class BaseCliRequestProcessor<T extends com.google.protobuf.Message>
extends RpcRequestProcessor<T>

Base template to handle cli requests.

Author:

boyan (boyan@alibaba-inc.com) 2018-Apr-09 11:51:42 AM

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	BaseCliRequestProcessor.CliRequestContext Cli request context

Nested classes/interfaces inherited from interface com.alipay.sofa.jraft.rpc.RpcProcessor

RpcProcessor.ExecutorSelector

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.slf4j.Logger	LOG

Constructor Summary

Constructors

Constructor and Description
BaseCliRequestProcessor(Executor executor, com.google.protobuf.Message defaultResp)

Method Summary

Modifier and Type	Method and Description
protected abstract String	getGroupId(T request) Returns the raft group id
protected Node	getNode(String groupId, PeerId peerId, Status st)
protected abstract String	getPeerId(T request) Returns the peerId that will be find in node manager.
com.google.protobuf.Message	processRequest(T request, RpcRequestClosure done)
protected abstract com.google.protobuf.Message	processRequest0(BaseCliRequestProcessor.CliRequestContext ctx, T request, RpcRequestClosure done) Process the request with CliRequestContext

Methods inherited from class com.alipay.sofa.jraft.rpc.RpcRequestProcessor

defaultResp, executor, handleRequest

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.alipay.sofa.jraft.rpc.RpcProcessor

executorSelector, interest

Field Detail

LOG

protected static final org.slf4j.Logger LOG

Constructor Detail

BaseCliRequestProcessor

public BaseCliRequestProcessor(Executor executor,
                               com.google.protobuf.Message defaultResp)

Method Detail

getPeerId

protected abstract String getPeerId(T request)

Returns the peerId that will be find in node manager.

getGroupId

protected abstract String getGroupId(T request)

Returns the raft group id

processRequest0

protected abstract com.google.protobuf.Message processRequest0(BaseCliRequestProcessor.CliRequestContext ctx,
                                                               T request,
                                                               RpcRequestClosure done)

Process the request with CliRequestContext

processRequest

public com.google.protobuf.Message processRequest(T request,
                                                  RpcRequestClosure done)

Specified by:

processRequest in class RpcRequestProcessor<T extends com.google.protobuf.Message>

getNode

protected Node getNode(String groupId,
                       PeerId peerId,
                       Status st)