Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/andy-yx-chen/jraft
/ functions
Functions
391 in github.com/andy-yx-chen/jraft
⨍
Functions
391
◇
Types & classes
61
↓ 4 callers
Method
getCurrentHeartbeatInterval
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/PeerServer.java:64
↓ 4 callers
Method
getData
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/SnapshotSyncRequest.java:27
↓ 4 callers
Method
getLastSnapshot
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/StateMachine.java:19
↓ 4 callers
Method
getLogEntries
(long startIndex, long endIndex)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/FileBasedSequentialLogStore.java:189
↓ 4 callers
Method
getSecond
()
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/Pair.java:17
↓ 4 callers
Method
getSnapshotSyncContext
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/PeerServer.java:128
↓ 4 callers
Method
handleExtendedResponse
(RaftResponseMessage response, Throwable error)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:1001
↓ 4 callers
Method
messageToBytes
(RaftResponseMessage response)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/BinaryUtils.java:52
↓ 4 callers
Method
saveClusterConfiguration
(ClusterConfiguration configuration)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/ServerStateManager.java:7
↓ 4 callers
Method
send
(RaftRequestMessage request)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RpcClient.java:7
↓ 4 callers
Method
setMatchedIndex
(long matchedIndex)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/PeerServer.java:108
↓ 4 callers
Method
setSnapshotInSync
(Snapshot snapshot)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/PeerServer.java:120
↓ 4 callers
Method
trim
(long fromIndex)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/FileBasedSequentialLogStore.java:652
↓ 4 callers
Method
tryCurrentLeader
(RaftRequestMessage request, CompletableFuture<Boolean> future, int rpcBackoff, int retry)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftClient.java:86
↓ 4 callers
Method
updateTerm
(long term)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:648
↓ 3 callers
Method
becomeFollower
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:633
↓ 3 callers
Method
booleanToByte
(boolean value)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/BinaryUtils.java:44
↓ 3 callers
Method
bytesToLogEntries
(byte[] data)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/BinaryUtils.java:143
↓ 3 callers
Method
fillBuffer
()
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/FileBasedSequentialLogStore.java:530
↓ 3 callers
Method
fromBytes
(byte[] bytes)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/SnapshotSyncRequest.java:50
↓ 3 callers
Method
getCommitIndex
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftRequestMessage.java:26
↓ 3 callers
Method
getLastLogIndex
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftRequestMessage.java:18
↓ 3 callers
Method
getLastLogTerm
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftRequestMessage.java:10
↓ 3 callers
Method
getLogEntries
(long start, long end)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/H2LogStore.java:153
↓ 3 callers
Method
getSnapshot
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/SnapshotSyncRequest.java:19
↓ 3 callers
Method
getSnapshotDistance
The commit distances for snapshots, zero means don't take any snapshots @return
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftParameters.java:169
↓ 3 callers
Method
handleHeartbeatTimeout
(PeerServer peer)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:561
↓ 3 callers
Method
handlerFrom
(BiConsumer<V, A> completed, AsynchronousSocketChannel connection)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/RpcTcpListener.java:162
↓ 3 callers
Method
handlerFrom
(BiConsumer<V, AsyncTask<I>> completed)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/RpcTcpClient.java:146
↓ 3 callers
Method
handlerFrom
(BiConsumer<V, A> completed, AsynchronousSocketChannel connection)
jraft-dmprinter/src/main/java/net/data/technology/jraft/MessagePrinter.java:503
↓ 3 callers
Method
loadClusterConfiguration
()
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/FileBasedServerStateManager.java:57
↓ 3 callers
Method
processRequest
(RaftRequestMessage request)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftMessageHandler.java:5
↓ 3 callers
Method
read
(InputStream stream, byte[] buffer)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/H2LogStore.java:326
↓ 3 callers
Method
read
(RandomAccessFile stream, byte[] buffer)
jraft-dmprinter/src/main/java/net/data/technology/jraft/MessagePrinter.java:284
↓ 3 callers
Method
reconfigure
(ClusterConfiguration newConfig)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:812
↓ 3 callers
Method
reset
(long startIndex)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/FileBasedSequentialLogStore.java:696
↓ 3 callers
Method
resumeHeartbeatingSpeed
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/PeerServer.java:157
↓ 3 callers
Method
sendMessageToLeader
(RaftRequestMessage request)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:1528
↓ 3 callers
Method
sendResponse
(AsynchronousSocketChannel connection, String message)
jraft-dmprinter/src/main/java/net/data/technology/jraft/MessagePrinter.java:477
↓ 3 callers
Method
setFree
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/PeerServer.java:80
↓ 3 callers
Method
stopElectionTimer
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:594
↓ 3 callers
Method
syncLogsToNewComingServer
(long startIndex)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:1272
↓ 3 callers
Method
termForLastLog
(long logIndex)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:1458
↓ 3 callers
Method
toBytes
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/ClusterConfiguration.java:65
↓ 3 callers
Method
toBytes
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/SnapshotSyncRequest.java:35
↓ 3 callers
Method
warning
(String format, Object... args)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/Logger.java:9
↓ 3 callers
Method
writeToChannel
(AsynchronousByteChannel channel, ByteBuffer buffer, A attachment, CompletionHandler<Integer, A> completionHan
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/AsyncUtility.java:46
↓ 2 callers
Method
addMessage
(String message)
jraft-dmprinter/src/main/java/net/data/technology/jraft/MessagePrinter.java:461
↓ 2 callers
Method
appendEntries
(byte[][] values)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftClient.java:33
↓ 2 callers
Method
assertConfigEquals
(ClusterConfiguration config, ClusterConfiguration config1)
jraft-extensions/src/test/java/net/data/technology/jraft/extensions/FileBasedServerStateManagerTests.java:107
↓ 2 callers
Method
becomeLeader
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:604
↓ 2 callers
Method
byteToBoolean
(byte value)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/BinaryUtils.java:48
↓ 2 callers
Method
bytesToRequestMessage
(byte[] data)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/BinaryUtils.java:110
↓ 2 callers
Method
bytesToResponseMessage
(byte[] data)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/BinaryUtils.java:63
↓ 2 callers
Method
clearPendingCommit
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/PeerServer.java:116
↓ 2 callers
Method
compact
Compact the log store by removing all log entries including the log at the lastLogIndex @param lastLogIndex @return compact successfully or not
net.data.technology.jraft/src/main/java/net/data/technology/jraft/SequentialLogStore.java:73
↓ 2 callers
Method
compact
(long lastLogIndex)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/H2LogStore.java:278
↓ 2 callers
Method
compact
(long lastLogIndex)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/FileBasedSequentialLogStore.java:373
↓ 2 callers
Method
completed
(V result, A attachment)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/AsyncUtility.java:12
↓ 2 callers
Method
createSyncSnapshotRequest
(PeerServer peer, long lastLogIndex, long term, long commitIndex)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:1403
↓ 2 callers
Method
enableHeartbeatForPeer
(PeerServer peer)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:627
↓ 2 callers
Method
getElectionTimeoutLowerBound
Lower value for election timeout @return
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftParameters.java:120
↓ 2 callers
Method
getHeartbeartHandler
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/PeerServer.java:60
↓ 2 callers
Method
getLastLogEntry
The last log entry in store @return a dummy constant entry with value set to null and term set to zero if no log entry in store
net.data.technology.jraft/src/main/java/net/data/technology/jraft/SequentialLogStore.java:22
↓ 2 callers
Method
getLeaderEndpoint
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftClient.java:150
↓ 2 callers
Method
getMaxHeartbeatInterval
The maximum heartbeat interval, any value beyond this may lead to election timeout for a peer before receiving a heartbeat @return
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftParameters.java:144
↓ 2 callers
Method
getOffset
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/SnapshotSyncContext.java:21
↓ 2 callers
Method
getRpcClientFactory
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftContext.java:57
↓ 2 callers
Method
getTerm
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/ServerState.java:9
↓ 2 callers
Method
handlePeerResponse
(RaftResponseMessage response, Throwable error)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:417
↓ 2 callers
Method
logEntriesEquals
(LogEntry entry1, LogEntry entry2)
jraft-extensions/src/test/java/net/data/technology/jraft/extensions/BinaryUtilTests.java:109
↓ 2 callers
Method
logEntryToBytes
(LogEntry logEntry)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/BinaryUtils.java:128
↓ 2 callers
Method
preCommit
(long logIndex, byte[] data)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/StateMachine.java:11
↓ 2 callers
Method
processRequest
(AsynchronousSocketChannel connection, RaftRequestMessage request, RaftMessageHandler messageHandler)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/RpcTcpListener.java:139
↓ 2 callers
Method
randomConfiguration
()
jraft-extensions/src/test/java/net/data/technology/jraft/extensions/FileBasedServerStateManagerTests.java:92
↓ 2 callers
Method
randomLogEntry
()
jraft-extensions/src/test/java/net/data/technology/jraft/extensions/BinaryUtilTests.java:128
↓ 2 callers
Method
randomMessageType
()
jraft-extensions/src/test/java/net/data/technology/jraft/extensions/BinaryUtilTests.java:123
↓ 2 callers
Method
randomMessageType
()
jraft-extensions/src/test/java/net/data/technology/jraft/extensions/GsonSerializationTests.java:88
↓ 2 callers
Method
readEntry
(int size)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/FileBasedSequentialLogStore.java:553
↓ 2 callers
Method
readRequest
(final AsynchronousSocketChannel connection, RaftMessageHandler messageHandler)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/RpcTcpListener.java:96
↓ 2 callers
Method
readRequest
(AsynchronousSocketChannel connection)
jraft-dmprinter/src/main/java/net/data/technology/jraft/MessagePrinter.java:315
↓ 2 callers
Method
readState
()
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/FileBasedServerStateManager.java:113
↓ 2 callers
Method
removeServerFromCluster
(int serverId)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:1382
↓ 2 callers
Method
run
(RaftContext context)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftConsensus.java:5
↓ 2 callers
Method
sendAndRead
(AsyncTask<RaftRequestMessage> task, boolean skipQueueing)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/RpcTcpClient.java:69
↓ 2 callers
Method
setHeartbeatTask
(ScheduledFuture<?> heartbeatTask)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/PeerServer.java:68
↓ 2 callers
Method
setOffset
(long offset)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/SnapshotSyncContext.java:17
↓ 2 callers
Method
setTerm
(long term)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/ServerState.java:13
↓ 2 callers
Method
slowDownHeartbeating
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/PeerServer.java:153
↓ 2 callers
Method
withElectionTimeoutLower
Election timeout lower bound in milliseconds @param electionTimeoutLower @return self
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftParameters.java:83
↓ 2 callers
Method
withElectionTimeoutUpper
Election timeout upper bound in milliseconds @param electionTimeoutUpper @return self
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftParameters.java:73
↓ 2 callers
Method
withHeartbeatInterval
heartbeat interval in milliseconds @param heartbeatInterval @return self
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftParameters.java:93
↓ 2 callers
Method
withLogSyncBatchSize
For new member that just joined the cluster, we will use log sync to ask it to catch up, and this parameter is to specify how many log entries to pack
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftParameters.java:53
↓ 2 callers
Method
withLogSyncStoppingGap
For new member that just joined the cluster, we will use log sync to ask it to catch up, and this parameter is to tell when to stop using log sync but
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftParameters.java:42
↓ 2 callers
Method
withMaximumAppendingSize
The maximum log entries could be attached to an appendEntries call @param maxAppendingSize @return self
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftParameters.java:63
↓ 2 callers
Method
withRpcFailureBackoff
Rpc failure backoff in milliseconds @param rpcFailureBackoff @return self
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftParameters.java:103
↓ 2 callers
Method
withSnapshotEnabled
Enable log compact and snapshot with the commit distance @param distance, log distance to compact between two snapshots @return self
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftParameters.java:30
↓ 2 callers
Method
withSyncSnapshotBlockSize
The tcp block size for syncing the snapshots @param size @return self
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftParameters.java:20
↓ 2 callers
Method
writeAt
(long index, LogEntry logEntry)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/H2LogStore.java:125
↓ 2 callers
Method
writeAt
write the log entry at the specific index, all log entries after index will be discarded @param logIndex must be >= this.getStartIndex() @param logEnt
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/FileBasedSequentialLogStore.java:140
← previous
next →
101–200 of 391, ranked by callers