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

Class CliClientServiceImpl

java.lang.Object

com.alipay.sofa.jraft.rpc.impl.AbstractClientService

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

All Implemented Interfaces:

Lifecycle<RpcOptions>, CliClientService, ClientService

public class CliClientServiceImpl
extends AbstractClientService
implements CliClientService

Author:

boyan (boyan@alibaba-inc.com), jiachun.fjc

Field Summary

Fields inherited from class com.alipay.sofa.jraft.rpc.impl.AbstractClientService

LOG, rpcClient, rpcExecutor, rpcOptions

Constructor Summary

Constructors

Constructor and Description
CliClientServiceImpl()

Method Summary

Modifier and Type	Method and Description
Future<com.google.protobuf.Message>	addLearners(Endpoint endpoint, CliRequests.AddLearnersRequest request, RpcResponseClosure<CliRequests.LearnersOpResponse> done) Add learners
Future<com.google.protobuf.Message>	addPeer(Endpoint endpoint, CliRequests.AddPeerRequest request, RpcResponseClosure<CliRequests.AddPeerResponse> done) Adds a peer.
Future<com.google.protobuf.Message>	changePeers(Endpoint endpoint, CliRequests.ChangePeersRequest request, RpcResponseClosure<CliRequests.ChangePeersResponse> done) Change peers.
Future<com.google.protobuf.Message>	getLeader(Endpoint endpoint, CliRequests.GetLeaderRequest request, RpcResponseClosure<CliRequests.GetLeaderResponse> done) Get the group leader.
Future<com.google.protobuf.Message>	getPeers(Endpoint endpoint, CliRequests.GetPeersRequest request, RpcResponseClosure<CliRequests.GetPeersResponse> done) Get all peers of the replication group.
boolean	init(RpcOptions rpcOptions) Initialize the service.
Future<com.google.protobuf.Message>	removeLearners(Endpoint endpoint, CliRequests.RemoveLearnersRequest request, RpcResponseClosure<CliRequests.LearnersOpResponse> done) Remove learners
Future<com.google.protobuf.Message>	removePeer(Endpoint endpoint, CliRequests.RemovePeerRequest request, RpcResponseClosure<CliRequests.RemovePeerResponse> done) Removes a peer.
Future<com.google.protobuf.Message>	resetLearners(Endpoint endpoint, CliRequests.ResetLearnersRequest request, RpcResponseClosure<CliRequests.LearnersOpResponse> done) Reset learners
Future<com.google.protobuf.Message>	resetPeer(Endpoint endpoint, CliRequests.ResetPeerRequest request, RpcResponseClosure<RpcRequests.ErrorResponse> done) Reset a peer.
Future<com.google.protobuf.Message>	snapshot(Endpoint endpoint, CliRequests.SnapshotRequest request, RpcResponseClosure<RpcRequests.ErrorResponse> done) Do a snapshot.
Future<com.google.protobuf.Message>	transferLeader(Endpoint endpoint, CliRequests.TransferLeaderRequest request, RpcResponseClosure<RpcRequests.ErrorResponse> done) Transfer leadership to other peer.

Methods inherited from class com.alipay.sofa.jraft.rpc.impl.AbstractClientService

checkConnection, configRpcClient, connect, disconnect, getRpcClient, initRpcClient, invokeWithDone, invokeWithDone, invokeWithDone, invokeWithDone, isConnected, shutdown

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.ClientService

checkConnection, connect, disconnect, invokeWithDone, isConnected

Methods inherited from interface com.alipay.sofa.jraft.Lifecycle

shutdown

Constructor Detail

CliClientServiceImpl

public CliClientServiceImpl()

Method Detail

init

public boolean init(RpcOptions rpcOptions)

Description copied from interface: Lifecycle

Initialize the service.

Specified by:

init in interface Lifecycle<RpcOptions>

Overrides:

init in class AbstractClientService

Returns:

true when successes.

addPeer

public Future<com.google.protobuf.Message> addPeer(Endpoint endpoint,
                                                   CliRequests.AddPeerRequest request,
                                                   RpcResponseClosure<CliRequests.AddPeerResponse> done)

Description copied from interface: CliClientService

Adds a peer.

Specified by:

addPeer in interface CliClientService

Parameters:

endpoint - server address

request - request data

done - callback

Returns:

a future with result

removePeer

public Future<com.google.protobuf.Message> removePeer(Endpoint endpoint,
                                                      CliRequests.RemovePeerRequest request,
                                                      RpcResponseClosure<CliRequests.RemovePeerResponse> done)

Description copied from interface: CliClientService

Removes a peer.

Specified by:

removePeer in interface CliClientService

Parameters:

endpoint - server address

request - request data

done - callback

Returns:

a future with result

resetPeer

public Future<com.google.protobuf.Message> resetPeer(Endpoint endpoint,
                                                     CliRequests.ResetPeerRequest request,
                                                     RpcResponseClosure<RpcRequests.ErrorResponse> done)

Description copied from interface: CliClientService

Reset a peer.

Specified by:

resetPeer in interface CliClientService

Parameters:

endpoint - server address

request - request data

done - callback

Returns:

a future with result

snapshot

public Future<com.google.protobuf.Message> snapshot(Endpoint endpoint,
                                                    CliRequests.SnapshotRequest request,
                                                    RpcResponseClosure<RpcRequests.ErrorResponse> done)

Description copied from interface: CliClientService

Do a snapshot.

Specified by:

snapshot in interface CliClientService

Parameters:

endpoint - server address

request - request data

done - callback

Returns:

a future with result

changePeers

public Future<com.google.protobuf.Message> changePeers(Endpoint endpoint,
                                                       CliRequests.ChangePeersRequest request,
                                                       RpcResponseClosure<CliRequests.ChangePeersResponse> done)

Description copied from interface: CliClientService

Change peers.

Specified by:

changePeers in interface CliClientService

Parameters:

endpoint - server address

request - request data

done - callback

Returns:

a future with result

addLearners

public Future<com.google.protobuf.Message> addLearners(Endpoint endpoint,
                                                       CliRequests.AddLearnersRequest request,
                                                       RpcResponseClosure<CliRequests.LearnersOpResponse> done)

Description copied from interface: CliClientService

Add learners

Specified by:

addLearners in interface CliClientService

Parameters:

endpoint - server address

request - request data

done - callback

Returns:

a future with result

removeLearners

public Future<com.google.protobuf.Message> removeLearners(Endpoint endpoint,
                                                          CliRequests.RemoveLearnersRequest request,
                                                          RpcResponseClosure<CliRequests.LearnersOpResponse> done)

Description copied from interface: CliClientService

Remove learners

Specified by:

removeLearners in interface CliClientService

Parameters:

endpoint - server address

request - request data

done - callback

Returns:

a future with result

resetLearners

public Future<com.google.protobuf.Message> resetLearners(Endpoint endpoint,
                                                         CliRequests.ResetLearnersRequest request,
                                                         RpcResponseClosure<CliRequests.LearnersOpResponse> done)

Description copied from interface: CliClientService

Reset learners

Specified by:

resetLearners in interface CliClientService

Parameters:

endpoint - server address

request - request data

done - callback

Returns:

a future with result

getLeader

public Future<com.google.protobuf.Message> getLeader(Endpoint endpoint,
                                                     CliRequests.GetLeaderRequest request,
                                                     RpcResponseClosure<CliRequests.GetLeaderResponse> done)

Description copied from interface: CliClientService

Get the group leader.

Specified by:

getLeader in interface CliClientService

Parameters:

endpoint - server address

request - request data

done - callback

Returns:

a future with result

transferLeader

public Future<com.google.protobuf.Message> transferLeader(Endpoint endpoint,
                                                          CliRequests.TransferLeaderRequest request,
                                                          RpcResponseClosure<RpcRequests.ErrorResponse> done)

Description copied from interface: CliClientService

Transfer leadership to other peer.

Specified by:

transferLeader in interface CliClientService

Parameters:

endpoint - server address

request - request data

done - callback

Returns:

a future with result

getPeers

public Future<com.google.protobuf.Message> getPeers(Endpoint endpoint,
                                                    CliRequests.GetPeersRequest request,
                                                    RpcResponseClosure<CliRequests.GetPeersResponse> done)

Description copied from interface: CliClientService

Get all peers of the replication group.

Specified by:

getPeers in interface CliClientService

Parameters:

endpoint - server address

request - request data

done - callback

Returns:

a future with result