Uses of Class
com.alipay.sofa.jraft.rpc.RpcRequestClosure

Packages that use RpcRequestClosure

Package	Description
com.alipay.sofa.jraft.core
com.alipay.sofa.jraft.rpc
com.alipay.sofa.jraft.rpc.impl.cli
com.alipay.sofa.jraft.rpc.impl.core
com.alipay.sofa.jraft.storage
com.alipay.sofa.jraft.storage.snapshot

Uses of RpcRequestClosure in com.alipay.sofa.jraft.core

Methods in com.alipay.sofa.jraft.core with parameters of type RpcRequestClosure

Modifier and Type	Method and Description
com.google.protobuf.Message	NodeImpl.handleAppendEntriesRequest(RpcRequests.AppendEntriesRequest request, RpcRequestClosure done)
com.google.protobuf.Message	NodeImpl.handleInstallSnapshot(RpcRequests.InstallSnapshotRequest request, RpcRequestClosure done)
com.google.protobuf.Message	NodeImpl.handleTimeoutNowRequest(RpcRequests.TimeoutNowRequest request, RpcRequestClosure done)

Uses of RpcRequestClosure in com.alipay.sofa.jraft.rpc

Methods in com.alipay.sofa.jraft.rpc with parameters of type RpcRequestClosure

Modifier and Type	Method and Description
com.google.protobuf.Message	RaftServerService.handleAppendEntriesRequest(RpcRequests.AppendEntriesRequest request, RpcRequestClosure done) Handle append-entries request, return response message or called done.run() with response.
com.google.protobuf.Message	RaftServerService.handleInstallSnapshot(RpcRequests.InstallSnapshotRequest request, RpcRequestClosure done) Handle install-snapshot request, return response message or called done.run() with response.
com.google.protobuf.Message	RaftServerService.handleTimeoutNowRequest(RpcRequests.TimeoutNowRequest request, RpcRequestClosure done) Handle time-out-now request, return response message or called done.run() with response.
abstract com.google.protobuf.Message	RpcRequestProcessor.processRequest(T request, RpcRequestClosure done)

Uses of RpcRequestClosure in com.alipay.sofa.jraft.rpc.impl.cli

Methods in com.alipay.sofa.jraft.rpc.impl.cli with parameters of type RpcRequestClosure

Modifier and Type	Method and Description
com.google.protobuf.Message	GetLeaderRequestProcessor.processRequest(CliRequests.GetLeaderRequest request, RpcRequestClosure done)
com.google.protobuf.Message	BaseCliRequestProcessor.processRequest(T request, RpcRequestClosure done)
protected com.google.protobuf.Message	AddLearnersRequestProcessor.processRequest0(BaseCliRequestProcessor.CliRequestContext ctx, CliRequests.AddLearnersRequest request, RpcRequestClosure done)
protected com.google.protobuf.Message	AddPeerRequestProcessor.processRequest0(BaseCliRequestProcessor.CliRequestContext ctx, CliRequests.AddPeerRequest request, RpcRequestClosure done)
protected com.google.protobuf.Message	ChangePeersRequestProcessor.processRequest0(BaseCliRequestProcessor.CliRequestContext ctx, CliRequests.ChangePeersRequest request, RpcRequestClosure done)
protected com.google.protobuf.Message	GetLeaderRequestProcessor.processRequest0(BaseCliRequestProcessor.CliRequestContext ctx, CliRequests.GetLeaderRequest request, RpcRequestClosure done)
protected com.google.protobuf.Message	GetPeersRequestProcessor.processRequest0(BaseCliRequestProcessor.CliRequestContext ctx, CliRequests.GetPeersRequest request, RpcRequestClosure done)
protected com.google.protobuf.Message	RemoveLearnersRequestProcessor.processRequest0(BaseCliRequestProcessor.CliRequestContext ctx, CliRequests.RemoveLearnersRequest request, RpcRequestClosure done)
protected com.google.protobuf.Message	RemovePeerRequestProcessor.processRequest0(BaseCliRequestProcessor.CliRequestContext ctx, CliRequests.RemovePeerRequest request, RpcRequestClosure done)
protected com.google.protobuf.Message	ResetLearnersRequestProcessor.processRequest0(BaseCliRequestProcessor.CliRequestContext ctx, CliRequests.ResetLearnersRequest request, RpcRequestClosure done)
protected com.google.protobuf.Message	ResetPeerRequestProcessor.processRequest0(BaseCliRequestProcessor.CliRequestContext ctx, CliRequests.ResetPeerRequest request, RpcRequestClosure done)
protected com.google.protobuf.Message	SnapshotRequestProcessor.processRequest0(BaseCliRequestProcessor.CliRequestContext ctx, CliRequests.SnapshotRequest request, RpcRequestClosure done)
protected com.google.protobuf.Message	TransferLeaderRequestProcessor.processRequest0(BaseCliRequestProcessor.CliRequestContext ctx, CliRequests.TransferLeaderRequest request, RpcRequestClosure done)
protected abstract com.google.protobuf.Message	BaseCliRequestProcessor.processRequest0(BaseCliRequestProcessor.CliRequestContext ctx, T request, RpcRequestClosure done) Process the request with CliRequestContext

Uses of RpcRequestClosure in com.alipay.sofa.jraft.rpc.impl.core

Methods in com.alipay.sofa.jraft.rpc.impl.core with parameters of type RpcRequestClosure

Modifier and Type	Method and Description
com.google.protobuf.Message	GetFileRequestProcessor.processRequest(RpcRequests.GetFileRequest request, RpcRequestClosure done)
com.google.protobuf.Message	NodeRequestProcessor.processRequest(T request, RpcRequestClosure done)
com.google.protobuf.Message	AppendEntriesRequestProcessor.processRequest0(RaftServerService service, RpcRequests.AppendEntriesRequest request, RpcRequestClosure done)
com.google.protobuf.Message	InstallSnapshotRequestProcessor.processRequest0(RaftServerService service, RpcRequests.InstallSnapshotRequest request, RpcRequestClosure done)
com.google.protobuf.Message	ReadIndexRequestProcessor.processRequest0(RaftServerService service, RpcRequests.ReadIndexRequest request, RpcRequestClosure done)
com.google.protobuf.Message	RequestVoteRequestProcessor.processRequest0(RaftServerService service, RpcRequests.RequestVoteRequest request, RpcRequestClosure done)
com.google.protobuf.Message	TimeoutNowRequestProcessor.processRequest0(RaftServerService service, RpcRequests.TimeoutNowRequest request, RpcRequestClosure done)
protected abstract com.google.protobuf.Message	NodeRequestProcessor.processRequest0(RaftServerService serviceService, T request, RpcRequestClosure done)

Uses of RpcRequestClosure in com.alipay.sofa.jraft.storage

Methods in com.alipay.sofa.jraft.storage with parameters of type RpcRequestClosure

Modifier and Type	Method and Description
com.google.protobuf.Message	FileService.handleGetFile(RpcRequests.GetFileRequest request, RpcRequestClosure done) Handle GetFileRequest, run the response or set the response with done.
void	SnapshotExecutor.installSnapshot(RpcRequests.InstallSnapshotRequest request, RpcRequests.InstallSnapshotResponse.Builder response, RpcRequestClosure done) Install snapshot according to the very RPC from leader After the installing succeeds (StateMachine is reset with the snapshot) or fails, done will be called to respond Errors: - Term mismatches: which happens interrupt_downloading_snapshot was called before install_snapshot, indicating that this RPC was issued by the old leader.

Uses of RpcRequestClosure in com.alipay.sofa.jraft.storage.snapshot

Methods in com.alipay.sofa.jraft.storage.snapshot with parameters of type RpcRequestClosure

Modifier and Type	Method and Description
void	SnapshotExecutorImpl.installSnapshot(RpcRequests.InstallSnapshotRequest request, RpcRequests.InstallSnapshotResponse.Builder response, RpcRequestClosure done)