MCPcopy Create free account

hub / github.com/andy-yx-chen/jraft / functions

Functions391 in github.com/andy-yx-chen/jraft

↓ 4 callersMethodgetCurrentHeartbeatInterval
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/PeerServer.java:64
↓ 4 callersMethodgetData
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/SnapshotSyncRequest.java:27
↓ 4 callersMethodgetLastSnapshot
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/StateMachine.java:19
↓ 4 callersMethodgetLogEntries
(long startIndex, long endIndex)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/FileBasedSequentialLogStore.java:189
↓ 4 callersMethodgetSecond
()
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/Pair.java:17
↓ 4 callersMethodgetSnapshotSyncContext
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/PeerServer.java:128
↓ 4 callersMethodhandleExtendedResponse
(RaftResponseMessage response, Throwable error)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:1001
↓ 4 callersMethodmessageToBytes
(RaftResponseMessage response)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/BinaryUtils.java:52
↓ 4 callersMethodsaveClusterConfiguration
(ClusterConfiguration configuration)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/ServerStateManager.java:7
↓ 4 callersMethodsend
(RaftRequestMessage request)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RpcClient.java:7
↓ 4 callersMethodsetMatchedIndex
(long matchedIndex)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/PeerServer.java:108
↓ 4 callersMethodsetSnapshotInSync
(Snapshot snapshot)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/PeerServer.java:120
↓ 4 callersMethodtrim
(long fromIndex)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/FileBasedSequentialLogStore.java:652
↓ 4 callersMethodtryCurrentLeader
(RaftRequestMessage request, CompletableFuture<Boolean> future, int rpcBackoff, int retry)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftClient.java:86
↓ 4 callersMethodupdateTerm
(long term)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:648
↓ 3 callersMethodbecomeFollower
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:633
↓ 3 callersMethodbooleanToByte
(boolean value)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/BinaryUtils.java:44
↓ 3 callersMethodbytesToLogEntries
(byte[] data)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/BinaryUtils.java:143
↓ 3 callersMethodfillBuffer
()
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/FileBasedSequentialLogStore.java:530
↓ 3 callersMethodfromBytes
(byte[] bytes)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/SnapshotSyncRequest.java:50
↓ 3 callersMethodgetCommitIndex
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftRequestMessage.java:26
↓ 3 callersMethodgetLastLogIndex
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftRequestMessage.java:18
↓ 3 callersMethodgetLastLogTerm
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftRequestMessage.java:10
↓ 3 callersMethodgetLogEntries
(long start, long end)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/H2LogStore.java:153
↓ 3 callersMethodgetSnapshot
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/SnapshotSyncRequest.java:19
↓ 3 callersMethodgetSnapshotDistance
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 callersMethodhandleHeartbeatTimeout
(PeerServer peer)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:561
↓ 3 callersMethodhandlerFrom
(BiConsumer<V, A> completed, AsynchronousSocketChannel connection)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/RpcTcpListener.java:162
↓ 3 callersMethodhandlerFrom
(BiConsumer<V, AsyncTask<I>> completed)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/RpcTcpClient.java:146
↓ 3 callersMethodhandlerFrom
(BiConsumer<V, A> completed, AsynchronousSocketChannel connection)
jraft-dmprinter/src/main/java/net/data/technology/jraft/MessagePrinter.java:503
↓ 3 callersMethodloadClusterConfiguration
()
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/FileBasedServerStateManager.java:57
↓ 3 callersMethodprocessRequest
(RaftRequestMessage request)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftMessageHandler.java:5
↓ 3 callersMethodread
(InputStream stream, byte[] buffer)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/H2LogStore.java:326
↓ 3 callersMethodread
(RandomAccessFile stream, byte[] buffer)
jraft-dmprinter/src/main/java/net/data/technology/jraft/MessagePrinter.java:284
↓ 3 callersMethodreconfigure
(ClusterConfiguration newConfig)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:812
↓ 3 callersMethodreset
(long startIndex)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/FileBasedSequentialLogStore.java:696
↓ 3 callersMethodresumeHeartbeatingSpeed
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/PeerServer.java:157
↓ 3 callersMethodsendMessageToLeader
(RaftRequestMessage request)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:1528
↓ 3 callersMethodsendResponse
(AsynchronousSocketChannel connection, String message)
jraft-dmprinter/src/main/java/net/data/technology/jraft/MessagePrinter.java:477
↓ 3 callersMethodsetFree
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/PeerServer.java:80
↓ 3 callersMethodstopElectionTimer
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:594
↓ 3 callersMethodsyncLogsToNewComingServer
(long startIndex)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:1272
↓ 3 callersMethodtermForLastLog
(long logIndex)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:1458
↓ 3 callersMethodtoBytes
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/ClusterConfiguration.java:65
↓ 3 callersMethodtoBytes
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/SnapshotSyncRequest.java:35
↓ 3 callersMethodwarning
(String format, Object... args)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/Logger.java:9
↓ 3 callersMethodwriteToChannel
(AsynchronousByteChannel channel, ByteBuffer buffer, A attachment, CompletionHandler<Integer, A> completionHan
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/AsyncUtility.java:46
↓ 2 callersMethodaddMessage
(String message)
jraft-dmprinter/src/main/java/net/data/technology/jraft/MessagePrinter.java:461
↓ 2 callersMethodappendEntries
(byte[][] values)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftClient.java:33
↓ 2 callersMethodassertConfigEquals
(ClusterConfiguration config, ClusterConfiguration config1)
jraft-extensions/src/test/java/net/data/technology/jraft/extensions/FileBasedServerStateManagerTests.java:107
↓ 2 callersMethodbecomeLeader
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:604
↓ 2 callersMethodbyteToBoolean
(byte value)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/BinaryUtils.java:48
↓ 2 callersMethodbytesToRequestMessage
(byte[] data)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/BinaryUtils.java:110
↓ 2 callersMethodbytesToResponseMessage
(byte[] data)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/BinaryUtils.java:63
↓ 2 callersMethodclearPendingCommit
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/PeerServer.java:116
↓ 2 callersMethodcompact
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 callersMethodcompact
(long lastLogIndex)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/H2LogStore.java:278
↓ 2 callersMethodcompact
(long lastLogIndex)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/FileBasedSequentialLogStore.java:373
↓ 2 callersMethodcompleted
(V result, A attachment)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/AsyncUtility.java:12
↓ 2 callersMethodcreateSyncSnapshotRequest
(PeerServer peer, long lastLogIndex, long term, long commitIndex)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:1403
↓ 2 callersMethodenableHeartbeatForPeer
(PeerServer peer)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:627
↓ 2 callersMethodgetElectionTimeoutLowerBound
Lower value for election timeout @return
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftParameters.java:120
↓ 2 callersMethodgetHeartbeartHandler
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/PeerServer.java:60
↓ 2 callersMethodgetLastLogEntry
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 callersMethodgetLeaderEndpoint
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftClient.java:150
↓ 2 callersMethodgetMaxHeartbeatInterval
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 callersMethodgetOffset
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/SnapshotSyncContext.java:21
↓ 2 callersMethodgetRpcClientFactory
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftContext.java:57
↓ 2 callersMethodgetTerm
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/ServerState.java:9
↓ 2 callersMethodhandlePeerResponse
(RaftResponseMessage response, Throwable error)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:417
↓ 2 callersMethodlogEntriesEquals
(LogEntry entry1, LogEntry entry2)
jraft-extensions/src/test/java/net/data/technology/jraft/extensions/BinaryUtilTests.java:109
↓ 2 callersMethodlogEntryToBytes
(LogEntry logEntry)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/BinaryUtils.java:128
↓ 2 callersMethodpreCommit
(long logIndex, byte[] data)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/StateMachine.java:11
↓ 2 callersMethodprocessRequest
(AsynchronousSocketChannel connection, RaftRequestMessage request, RaftMessageHandler messageHandler)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/RpcTcpListener.java:139
↓ 2 callersMethodrandomConfiguration
()
jraft-extensions/src/test/java/net/data/technology/jraft/extensions/FileBasedServerStateManagerTests.java:92
↓ 2 callersMethodrandomLogEntry
()
jraft-extensions/src/test/java/net/data/technology/jraft/extensions/BinaryUtilTests.java:128
↓ 2 callersMethodrandomMessageType
()
jraft-extensions/src/test/java/net/data/technology/jraft/extensions/BinaryUtilTests.java:123
↓ 2 callersMethodrandomMessageType
()
jraft-extensions/src/test/java/net/data/technology/jraft/extensions/GsonSerializationTests.java:88
↓ 2 callersMethodreadEntry
(int size)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/FileBasedSequentialLogStore.java:553
↓ 2 callersMethodreadRequest
(final AsynchronousSocketChannel connection, RaftMessageHandler messageHandler)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/RpcTcpListener.java:96
↓ 2 callersMethodreadRequest
(AsynchronousSocketChannel connection)
jraft-dmprinter/src/main/java/net/data/technology/jraft/MessagePrinter.java:315
↓ 2 callersMethodreadState
()
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/FileBasedServerStateManager.java:113
↓ 2 callersMethodremoveServerFromCluster
(int serverId)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:1382
↓ 2 callersMethodrun
(RaftContext context)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftConsensus.java:5
↓ 2 callersMethodsendAndRead
(AsyncTask<RaftRequestMessage> task, boolean skipQueueing)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/RpcTcpClient.java:69
↓ 2 callersMethodsetHeartbeatTask
(ScheduledFuture<?> heartbeatTask)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/PeerServer.java:68
↓ 2 callersMethodsetOffset
(long offset)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/SnapshotSyncContext.java:17
↓ 2 callersMethodsetTerm
(long term)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/ServerState.java:13
↓ 2 callersMethodslowDownHeartbeating
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/PeerServer.java:153
↓ 2 callersMethodwithElectionTimeoutLower
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 callersMethodwithElectionTimeoutUpper
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 callersMethodwithHeartbeatInterval
heartbeat interval in milliseconds @param heartbeatInterval @return self
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftParameters.java:93
↓ 2 callersMethodwithLogSyncBatchSize
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 callersMethodwithLogSyncStoppingGap
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 callersMethodwithMaximumAppendingSize
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 callersMethodwithRpcFailureBackoff
Rpc failure backoff in milliseconds @param rpcFailureBackoff @return self
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftParameters.java:103
↓ 2 callersMethodwithSnapshotEnabled
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 callersMethodwithSyncSnapshotBlockSize
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 callersMethodwriteAt
(long index, LogEntry logEntry)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/H2LogStore.java:125
↓ 2 callersMethodwriteAt
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
← previousnext →101–200 of 391, ranked by callers