io.openmessaging.storage.dledger

Class DLedgerServer

java.lang.Object

io.openmessaging.storage.dledger.AbstractDLedgerServer

io.openmessaging.storage.dledger.DLedgerServer

All Implemented Interfaces:

DLedgerClientProtocolHandler, DLedgerProtocolHandler

public class DLedgerServer
extends AbstractDLedgerServer

Constructor Summary

Constructors

Constructor and Description
DLedgerServer(DLedgerConfig dLedgerConfig)
DLedgerServer(DLedgerConfig dLedgerConfig, DLedgerRpcService dLedgerRpcService) Start in proxy mode, use shared DLedgerRpcService
DLedgerServer(DLedgerConfig dLedgerConfig, org.apache.rocketmq.remoting.netty.NettyServerConfig nettyServerConfig)
DLedgerServer(DLedgerConfig dLedgerConfig, org.apache.rocketmq.remoting.netty.NettyServerConfig nettyServerConfig, org.apache.rocketmq.remoting.netty.NettyClientConfig nettyClientConfig)
DLedgerServer(DLedgerConfig dLedgerConfig, org.apache.rocketmq.remoting.netty.NettyServerConfig nettyServerConfig, org.apache.rocketmq.remoting.netty.NettyClientConfig nettyClientConfig, org.apache.rocketmq.remoting.ChannelEventListener channelEventListener)

Method Summary

Modifier and Type	Method and Description
DLedgerConfig	getdLedgerConfig() Deprecated.
DLedgerConfig	getDLedgerConfig()
DLedgerLeaderElector	getdLedgerLeaderElector() Deprecated.
DLedgerLeaderElector	getDLedgerLeaderElector()
DLedgerRpcService	getdLedgerRpcService() Deprecated.
DLedgerRpcService	getDLedgerRpcService()
DLedgerStore	getdLedgerStore() Deprecated.
DLedgerStore	getDLedgerStore()
StateMachineCaller	getFsmCaller()
String	getListenAddress()
MemberState	getMemberState()
String	getPeerAddr(String groupId, String selfId)
org.apache.rocketmq.remoting.netty.NettyRemotingClient	getRemotingClient()
org.apache.rocketmq.remoting.netty.NettyRemotingServer	getRemotingServer()
StateMachine	getStateMachine()
CompletableFuture<AppendEntryResponse>	handleAppend(AppendEntryRequest request) Handle the append requests: 1.append the entry to local store 2.submit the future to entry pusher and wait the quorum ack 3.if the pending requests are full, then reject it immediately
CompletableFuture<GetEntriesResponse>	handleGet(GetEntriesRequest request)
CompletableFuture<HeartBeatResponse>	handleHeartBeat(HeartBeatRequest request)
CompletableFuture<LeadershipTransferResponse>	handleLeadershipTransfer(LeadershipTransferRequest request)
CompletableFuture<MetadataResponse>	handleMetadata(MetadataRequest request)
CompletableFuture<PullEntriesResponse>	handlePull(PullEntriesRequest request)
CompletableFuture<PushEntryResponse>	handlePush(PushEntryRequest request)
CompletableFuture<VoteResponse>	handleVote(VoteRequest request)
boolean	isLeader()
void	registerStateMachine(StateMachine fsm)
void	shutdown() Shutdown, if the DLedgerRpcService is exclusive for this DLedgerServer, we should also shut down it.
void	startup() Start up, if the DLedgerRpcService is exclusive for this DLedgerServer, we should also start up it.

Methods inherited from class java.lang.Object

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

Constructor Detail

DLedgerServer

public DLedgerServer(DLedgerConfig dLedgerConfig)

DLedgerServer

public DLedgerServer(DLedgerConfig dLedgerConfig,
                     org.apache.rocketmq.remoting.netty.NettyServerConfig nettyServerConfig)

DLedgerServer

public DLedgerServer(DLedgerConfig dLedgerConfig,
                     org.apache.rocketmq.remoting.netty.NettyServerConfig nettyServerConfig,
                     org.apache.rocketmq.remoting.netty.NettyClientConfig nettyClientConfig)

DLedgerServer

public DLedgerServer(DLedgerConfig dLedgerConfig,
                     org.apache.rocketmq.remoting.netty.NettyServerConfig nettyServerConfig,
                     org.apache.rocketmq.remoting.netty.NettyClientConfig nettyClientConfig,
                     org.apache.rocketmq.remoting.ChannelEventListener channelEventListener)

DLedgerServer

public DLedgerServer(DLedgerConfig dLedgerConfig,
                     DLedgerRpcService dLedgerRpcService)

Start in proxy mode, use shared DLedgerRpcService

Parameters:

dLedgerConfig - DLedgerConfig

dLedgerRpcService - Shared DLedgerRpcService

Method Detail

startup

public void startup()

Start up, if the DLedgerRpcService is exclusive for this DLedgerServer, we should also start up it.

shutdown

public void shutdown()

Shutdown, if the DLedgerRpcService is exclusive for this DLedgerServer, we should also shut down it.

getMemberState

public MemberState getMemberState()

registerStateMachine

public void registerStateMachine(StateMachine fsm)

getStateMachine

public StateMachine getStateMachine()

handleHeartBeat

public CompletableFuture<HeartBeatResponse> handleHeartBeat(HeartBeatRequest request)
                                                     throws Exception

Throws:

Exception

handleVote

public CompletableFuture<VoteResponse> handleVote(VoteRequest request)
                                           throws Exception

Throws:

Exception

handleAppend

public CompletableFuture<AppendEntryResponse> handleAppend(AppendEntryRequest request)
                                                    throws IOException

Handle the append requests: 1.append the entry to local store 2.submit the future to entry pusher and wait the quorum ack 3.if the pending requests are full, then reject it immediately

Parameters:

request -

Returns:

Throws:

IOException

handleGet

public CompletableFuture<GetEntriesResponse> handleGet(GetEntriesRequest request)
                                                throws IOException

Throws:

IOException

handleMetadata

public CompletableFuture<MetadataResponse> handleMetadata(MetadataRequest request)
                                                   throws Exception

Throws:

Exception

handlePull

public CompletableFuture<PullEntriesResponse> handlePull(PullEntriesRequest request)

handlePush

public CompletableFuture<PushEntryResponse> handlePush(PushEntryRequest request)
                                                throws Exception

Throws:

Exception

handleLeadershipTransfer

public CompletableFuture<LeadershipTransferResponse> handleLeadershipTransfer(LeadershipTransferRequest request)
                                                                       throws Exception

Throws:

Exception

getdLedgerStore

@Deprecated
public DLedgerStore getdLedgerStore()

Deprecated.

getDLedgerStore

public DLedgerStore getDLedgerStore()

getdLedgerRpcService

@Deprecated
public DLedgerRpcService getdLedgerRpcService()

Deprecated.

getDLedgerRpcService

public DLedgerRpcService getDLedgerRpcService()

getdLedgerLeaderElector

@Deprecated
public DLedgerLeaderElector getdLedgerLeaderElector()

Deprecated.

getDLedgerLeaderElector

public DLedgerLeaderElector getDLedgerLeaderElector()

getdLedgerConfig

@Deprecated
public DLedgerConfig getdLedgerConfig()

Deprecated.

getListenAddress

public String getListenAddress()

Specified by:

getListenAddress in class AbstractDLedgerServer

getPeerAddr

public String getPeerAddr(String groupId,
                          String selfId)

Specified by:

getPeerAddr in class AbstractDLedgerServer

getDLedgerConfig

public DLedgerConfig getDLedgerConfig()

getRemotingServer

public org.apache.rocketmq.remoting.netty.NettyRemotingServer getRemotingServer()

Specified by:

getRemotingServer in class AbstractDLedgerServer

getRemotingClient

public org.apache.rocketmq.remoting.netty.NettyRemotingClient getRemotingClient()

Specified by:

getRemotingClient in class AbstractDLedgerServer

getFsmCaller

public StateMachineCaller getFsmCaller()

isLeader

public boolean isLeader()