com.alipay.sofa.jraft.core

Class Replicator

java.lang.Object

com.alipay.sofa.jraft.core.Replicator

All Implemented Interfaces:

ThreadId.OnError

@ThreadSafe
public class Replicator
extends Object
implements ThreadId.OnError

Replicator for replicating log entry from leader to followers.

Author:

boyan (boyan@alibaba-inc.com) 2018-Apr-04 10:32:02 AM

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	Replicator.ReplicatorStateListener User can implement the ReplicatorStateListener interface by themselves.
static class	Replicator.State Replicator internal state

Field Summary

Fields

Modifier and Type	Field and Description
protected ThreadId	id
protected com.alipay.sofa.jraft.core.Replicator.Stat	statInfo

Constructor Summary

Constructors

Constructor and Description
Replicator(ReplicatorOptions replicatorOptions, RaftOptions raftOptions)

Method Summary

Modifier and Type	Method and Description
static long	getLastRpcSendTimestamp(ThreadId id)
static long	getNextIndex(ThreadId id)
PriorityQueue<com.alipay.sofa.jraft.core.Replicator.RpcResponse>	getPendingResponses()
static boolean	join(ThreadId id)
void	onError(ThreadId id, Object data, int errorCode) Error callback, it will be called in lock.
static void	sendHeartbeat(ThreadId id, RpcResponseClosure<RpcRequests.AppendEntriesResponse> closure)
static boolean	sendTimeoutNowAndStop(ThreadId id, int timeoutMs)
static ThreadId	start(ReplicatorOptions opts, RaftOptions raftOptions)
static boolean	stop(ThreadId id)
static boolean	stopTransferLeadership(ThreadId id)
String	toString()
static boolean	transferLeadership(ThreadId id, long logIndex)
static void	waitForCaughtUp(String groupId, ThreadId id, long maxMargin, long dueTime, CatchUpClosure done)

Methods inherited from class java.lang.Object

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

Field Detail

statInfo

protected com.alipay.sofa.jraft.core.Replicator.Stat statInfo

id

protected ThreadId id

Constructor Detail

Replicator

public Replicator(ReplicatorOptions replicatorOptions,
                  RaftOptions raftOptions)

Method Detail

getPendingResponses

@OnlyForTest
public PriorityQueue<com.alipay.sofa.jraft.core.Replicator.RpcResponse> getPendingResponses()

start

public static ThreadId start(ReplicatorOptions opts,
                             RaftOptions raftOptions)

waitForCaughtUp

public static void waitForCaughtUp(String groupId,
                                   ThreadId id,
                                   long maxMargin,
                                   long dueTime,
                                   CatchUpClosure done)

toString

public String toString()

Overrides:

toString in class Object

onError

public void onError(ThreadId id,
                    Object data,
                    int errorCode)

Description copied from interface: ThreadId.OnError

Error callback, it will be called in lock.

Specified by:

onError in interface ThreadId.OnError

Parameters:

id - the thread id

data - the data

errorCode - the error code

sendHeartbeat

public static void sendHeartbeat(ThreadId id,
                                 RpcResponseClosure<RpcRequests.AppendEntriesResponse> closure)

stop

public static boolean stop(ThreadId id)

join

public static boolean join(ThreadId id)

getLastRpcSendTimestamp

public static long getLastRpcSendTimestamp(ThreadId id)

transferLeadership

public static boolean transferLeadership(ThreadId id,
                                         long logIndex)

stopTransferLeadership

public static boolean stopTransferLeadership(ThreadId id)

sendTimeoutNowAndStop

public static boolean sendTimeoutNowAndStop(ThreadId id,
                                            int timeoutMs)

getNextIndex

public static long getNextIndex(ThreadId id)