MCPcopy Create free account

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

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

↓ 88 callersMethodgetTerm
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/LogEntry.java:23
↓ 87 callersMethodinfo
(String format, Object... args)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/Logger.java:7
↓ 74 callersMethoderror
(String format, Object... args)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/Logger.java:11
↓ 68 callersMethodgetValue
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/LogEntry.java:27
↓ 48 callersMethodtoString
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftMessageType.java:6
↓ 45 callersMethodgetLastLogIndex
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/Snapshot.java:21
↓ 43 callersMethodgetMessageType
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftMessage.java:10
↓ 42 callersMethoddebug
(String format, Object... args)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/Logger.java:5
↓ 42 callersMethodgetServers
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/ClusterConfiguration.java:51
↓ 37 callersMethodgetId
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/PeerServer.java:52
↓ 34 callersMethodgetSource
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftMessage.java:18
↓ 32 callersMethodgetFirstAvailableIndex
The first available index of the store, starts with 1 @return value >= 1
net.data.technology.jraft/src/main/java/net/data/technology/jraft/SequentialLogStore.java:9
↓ 31 callersMethodclose
()
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/H2LogStore.java:316
↓ 29 callersMethodsetMessageType
(RaftMessageType messageType)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftMessage.java:14
↓ 27 callersMethodsetTerm
(long term)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftMessage.java:38
↓ 25 callersMethodgetNextIndex
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftResponseMessage.java:8
↓ 24 callersMethodsetSource
(int source)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftMessage.java:22
↓ 23 callersMethodgetValueType
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/LogEntry.java:31
↓ 23 callersMethodsetAccepted
(boolean accepted)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftResponseMessage.java:20
↓ 23 callersMethodsetDestination
(int destination)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftMessage.java:30
↓ 20 callersMethodgetLogIndex
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/ClusterConfiguration.java:35
↓ 19 callersMethodgetFirstAvailableIndex
()
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/FileBasedSequentialLogStore.java:85
↓ 19 callersMethodisAccepted
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftResponseMessage.java:16
↓ 18 callersMethodgetDestination
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftMessage.java:26
↓ 18 callersMethodgetFirstAvailableIndex
()
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/H2LogStore.java:93
↓ 18 callersMethodgetLastLogTerm
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/Snapshot.java:25
↓ 18 callersMethodgetLogEntries
Get log entries with index between {@code start} and {@code end} @param start, the start index of log entries @param end, the end index of log entries
net.data.technology.jraft/src/main/java/net/data/technology/jraft/SequentialLogStore.java:44
↓ 18 callersMethodsetNextIndex
(long nextIndex)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftResponseMessage.java:12
↓ 17 callersMethodgetLogger
(Class<?> clazz)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/LoggerFactory.java:5
↓ 16 callersMethodlogEntriesEquals
(LogEntry entry1, LogEntry entry2)
jraft-extensions/src/test/java/net/data/technology/jraft/extensions/FileBasedSequentialLogStoreTests.java:268
↓ 15 callersMethodgetServerStateManager
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftContext.java:45
↓ 15 callersMethodlogEntriesEquals
(LogEntry entry1, LogEntry entry2)
jraft-extensions/src/test/java/net/data/technology/jraft/extensions/H2LogStoreTests.java:243
↓ 15 callersMethodsetLogEntries
(LogEntry[] logEntries)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftRequestMessage.java:38
↓ 14 callersMethodclose
()
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/FileBasedSequentialLogStore.java:438
↓ 14 callersMethodfromByte
(byte b)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/LogValueType.java:38
↓ 14 callersMethodgetCommitIndex
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/ServerState.java:29
↓ 13 callersMethodgetEndpoint
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/ClusterServer.java:32
↓ 13 callersMethodgetScheduledExecutor
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftContext.java:69
↓ 13 callersMethodgetSnapshot
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/SnapshotSyncContext.java:13
↓ 12 callersMethodgetFirst
()
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/Pair.java:13
↓ 12 callersMethodgetRaftParameters
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftContext.java:65
↓ 12 callersMethodgetStartIndex
()
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/H2LogStore.java:98
↓ 12 callersMethodgetStartIndex
()
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/FileBasedSequentialLogStore.java:95
↓ 12 callersMethodremoveTestFiles
(Path container)
jraft-extensions/src/test/java/net/data/technology/jraft/extensions/FileBasedSequentialLogStoreTests.java:259
↓ 11 callersMethodgetId
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/ClusterServer.java:24
↓ 11 callersMethodgetLastLogIndex
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/ClusterConfiguration.java:43
↓ 11 callersMethodread
(InputStream stream, byte[] buffer)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/FileBasedSequentialLogStore.java:494
↓ 10 callersMethodrandomLogEntry
()
jraft-extensions/src/test/java/net/data/technology/jraft/extensions/FileBasedSequentialLogStoreTests.java:251
↓ 10 callersMethodsetLastLogIndex
(long lastLogIndex)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftRequestMessage.java:22
↓ 10 callersMethodsetNextLogIndex
(long nextLogIndex)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/PeerServer.java:100
↓ 9 callersMethodappend
Appends a log entry to store @param logEntry @return the last appended log index
net.data.technology.jraft/src/main/java/net/data/technology/jraft/SequentialLogStore.java:29
↓ 9 callersMethodgetLogEntryAt
(long index)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/H2LogStore.java:177
↓ 9 callersMethodgetLogEntryAt
(long logIndex)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/FileBasedSequentialLogStore.java:245
↓ 9 callersMethodintToBytes
(int value)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/BinaryUtils.java:33
↓ 9 callersMethodrandomLogEntry
()
jraft-extensions/src/test/java/net/data/technology/jraft/extensions/H2LogStoreTests.java:235
↓ 9 callersMethodsetCommitIndex
(long commitIndex)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftRequestMessage.java:30
↓ 8 callersMethodappend
(LogEntry logEntry)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/FileBasedSequentialLogStore.java:111
↓ 8 callersMethodcloseSocket
(AsynchronousSocketChannel connection)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/RpcTcpListener.java:171
↓ 8 callersMethodcloseSocket
(AsynchronousSocketChannel connection)
jraft-dmprinter/src/main/java/net/data/technology/jraft/MessagePrinter.java:512
↓ 8 callersMethodlongToBytes
(long value)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/BinaryUtils.java:22
↓ 8 callersMethodrequestAppendEntries
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:389
↓ 8 callersMethodrestartElectionTimer
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:579
↓ 8 callersMethodsetLastLogTerm
(long lastLogTerm)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftRequestMessage.java:14
↓ 8 callersMethodsetLogIndex
(long logIndex)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/ClusterConfiguration.java:39
↓ 8 callersMethodsetVotedFor
(int votedFor)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/ServerState.java:21
↓ 7 callersMethodappend
(LogEntry logEntry)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/H2LogStore.java:108
↓ 7 callersMethodgetLastConfig
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/Snapshot.java:29
↓ 7 callersMethodgetLastLogEntry
()
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/H2LogStore.java:103
↓ 7 callersMethodgetLastLogEntry
()
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/FileBasedSequentialLogStore.java:105
↓ 7 callersMethodgetLogEntryAt
Gets the log entry at the specified index @param index, starts from 1 @return the log entry or null if index >= {@code this.getFirstAvailableIndex()}
net.data.technology.jraft/src/main/java/net/data/technology/jraft/SequentialLogStore.java:51
↓ 7 callersMethodgetStartIndex
The start index of the log store, at the very beginning, it must be 1 however, after some compact actions, this could be anything greater or equals to
net.data.technology.jraft/src/main/java/net/data/technology/jraft/SequentialLogStore.java:16
↓ 7 callersMethodhandlerFrom
(BiConsumer<V, A> completed, BiConsumer<Throwable, A> failed)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/AsyncUtility.java:10
↓ 7 callersMethodpersistState
(ServerState serverState)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/ServerStateManager.java:9
↓ 7 callersMethodsetLastLogIndex
(long lastLogIndex)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/ClusterConfiguration.java:47
↓ 7 callersMethodtoByte
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/LogValueType.java:6
↓ 7 callersMethodtoBytes
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/ClusterServer.java:40
↓ 6 callersMethodSendRequest
(RaftRequestMessage request)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/PeerServer.java:132
↓ 6 callersMethodcloseSocket
()
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/RpcTcpClient.java:154
↓ 6 callersMethodcommit
(long logIndex, byte[] data)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/StateMachine.java:7
↓ 6 callersMethodfromByte
(byte value)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftMessageType.java:195
↓ 6 callersMethodfromBytes
(ByteBuffer buffer)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/ClusterConfiguration.java:20
↓ 6 callersMethodgetHeartbeatTask
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/PeerServer.java:72
↓ 6 callersMethodgetNextLogIndex
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/PeerServer.java:96
↓ 6 callersMethodgetServer
(int id)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/ClusterConfiguration.java:55
↓ 6 callersMethodsetCommitIndex
(long commitIndex)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/ServerState.java:33
↓ 6 callersMethodsetEndpoint
(String endpoint)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/ClusterServer.java:36
↓ 6 callersMethodsetId
(int id)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/ClusterServer.java:28
↓ 6 callersMethodthrowWhenNotInRange
(long index)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/FileBasedSequentialLogStore.java:451
↓ 5 callersMethodcreateRpcClient
(String endpoint)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RpcClientFactory.java:5
↓ 5 callersMethodgetOffset
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/SnapshotSyncRequest.java:23
↓ 5 callersMethodgetSize
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/Snapshot.java:33
↓ 5 callersMethodgetVotedFor
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/ServerState.java:17
↓ 5 callersMethodisDone
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/SnapshotSyncRequest.java:31
↓ 5 callersMethodreadFromChannel
(AsynchronousByteChannel channel, ByteBuffer buffer, A attachment, CompletionHandler<Integer, A> completionHan
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/AsyncUtility.java:24
↓ 4 callersMethodbytesToInt
(byte[] bytes, int offset)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/BinaryUtils.java:39
↓ 4 callersMethodbytesToLong
(byte[] bytes, int offset)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/BinaryUtils.java:28
↓ 4 callersMethodclose
()
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/FileBasedServerStateManager.java:140
↓ 4 callersMethodcommit
(long targetIndex)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:663
↓ 4 callersMethodenableHeartbeat
(boolean enable)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/PeerServer.java:88
↓ 4 callersMethodfailed
(Throwable exc, A attachment)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/AsyncUtility.java:17
next →1–100 of 391, ranked by callers