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
Method
ClusterConfiguration
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/ClusterConfiguration.java:14
Method
ClusterServer
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/ClusterServer.java:11
Method
CommittingThread
(RaftServer server)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:1570
Method
FileBasedSequentialLogStore
(String logContainer)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/FileBasedSequentialLogStore.java:54
Method
FileBasedServerStateManager
(String dataDirectory)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/FileBasedServerStateManager.java:38
Method
H2LogStore
(String path)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/H2LogStore.java:45
Method
HttpRpcClient
(String serverUrl)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/http/HttpRpcClient.java:30
Method
JraftServlet
()
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/http/JraftServlet.java:27
Method
Log4jLogger
(Logger logger)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/Log4jLogger.java:9
Method
LogBuffer
(long startIndex, int maxSize)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/FileBasedSequentialLogStore.java:571
Method
LogEntry
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/LogEntry.java:9
Method
MessagePrinter
(Path baseDir, int listeningPort)
jraft-dmprinter/src/main/java/net/data/technology/jraft/MessagePrinter.java:55
Method
Pair
(TFirst first, TSecond second)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/Pair.java:8
Method
Pair
(T1 item1, T2 item2)
jraft-dmprinter/src/main/java/net/data/technology/jraft/App.java:228
Method
PeerServer
(ClusterServer server, RaftContext context, final Consumer<PeerServer> heartbeatConsumer)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/PeerServer.java:28
Method
RaftClient
(RpcClientFactory rpcClientFactory, ClusterConfiguration configuration, LoggerFactory loggerFactory)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftClient.java:23
Method
RaftContext
(ServerStateManager stateManager, StateMachine stateMachine, RaftParameters raftParameters, RpcListener rpcLis
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftContext.java:15
Method
RaftMessageSenderImpl
(RaftServer server)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:1480
Method
RaftServer
(RaftContext context)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:56
Method
RpcException
(Throwable realException, RaftRequestMessage request)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RpcException.java:11
Method
RpcTcpClient
(InetSocketAddress remote, ExecutorService executorService)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/RpcTcpClient.java:33
Method
RpcTcpClientFactory
(ExecutorService executorService)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/RpcTcpClientFactory.java:16
Method
RpcTcpListener
(int port, ExecutorService executorService)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/RpcTcpListener.java:32
Method
Snapshot
(long lastLogIndex, long lastLogTerm, ClusterConfiguration lastConfig)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/Snapshot.java:10
Method
SnapshotSyncContext
(Snapshot snapshot)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/SnapshotSyncContext.java:8
Method
SnapshotSyncRequest
(Snapshot snapshot, long offset, byte[] data, boolean done)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/SnapshotSyncRequest.java:12
Method
addServer
(ClusterServer server)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:1485
Method
append
(LogEntry entry)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/FileBasedSequentialLogStore.java:683
Method
appendEntries
(byte[][] values)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:1511
Method
applySnapshot
(Snapshot snapshot)
jraft-dmprinter/src/main/java/net/data/technology/jraft/MessagePrinter.java:126
Method
call
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:72
Method
call
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/PeerServer.java:45
Method
cancelled
()
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/http/HttpRpcClient.java:68
Method
commit
(long logIndex, byte[] data)
jraft-dmprinter/src/main/java/net/data/technology/jraft/MessagePrinter.java:101
Method
compare
(Long arg0, Long arg1)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:25
Method
completed
(HttpResponse result)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/http/HttpRpcClient.java:45
Method
contextDestroyed
(ServletContextEvent sce)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/http/JraftServletListener.java:46
Method
contextInitialized
(ServletContextEvent sce)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/http/JraftServletListener.java:33
Method
createRpcClient
(String endpoint)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/RpcTcpClientFactory.java:20
Method
createRpcClient
(String endpoint)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/http/HttpRpcClientFactory.java:8
Method
createSnapshot
(Snapshot snapshot)
jraft-dmprinter/src/main/java/net/data/technology/jraft/MessagePrinter.java:179
Method
debug
(String format, Object... args)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/Log4jLogger.java:13
Method
doGet
(HttpServletRequest request, HttpServletResponse response)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/http/JraftServlet.java:32
Method
doPost
(HttpServletRequest request, HttpServletResponse response)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/http/JraftServlet.java:37
Method
error
(String format, Object... args)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/Log4jLogger.java:37
Method
failed
(Exception ex)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/http/HttpRpcClient.java:63
Method
getLastSnapshot
()
jraft-dmprinter/src/main/java/net/data/technology/jraft/MessagePrinter.java:221
Method
getLogger
(Class<?> clazz)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/Log4jLoggerFactory.java:10
Method
getMessageSender
(ServletContext context)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/http/JraftServletListener.java:29
Method
getTerm
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftMessage.java:34
Method
info
(String format, Object... args)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/Log4jLogger.java:21
Method
lastIndex
()
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/FileBasedSequentialLogStore.java:580
Method
main
( String[] args )
jraft-dmprinter/src/main/java/net/data/technology/jraft/App.java:26
Method
preCommit
(long logIndex, byte[] data)
jraft-dmprinter/src/main/java/net/data/technology/jraft/MessagePrinter.java:274
Method
processRequest
(RaftRequestMessage request)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:131
Method
processRequest
(RaftRequestMessage request)
jraft-dmprinter/src/main/java/net/data/technology/jraft/DummyMessageHandler.java:13
Method
readSnapshotData
(Snapshot snapshot, long offset, byte[] buffer)
jraft-dmprinter/src/main/java/net/data/technology/jraft/MessagePrinter.java:160
Method
removeServer
(int serverId)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:1495
Method
rollback
(long logIndex, byte[] data)
jraft-dmprinter/src/main/java/net/data/technology/jraft/MessagePrinter.java:258
Method
run
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:1581
Method
run
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftClient.java:118
Method
saveSnapshotData
(Snapshot snapshot, long offset, byte[] data)
jraft-dmprinter/src/main/java/net/data/technology/jraft/MessagePrinter.java:109
Method
send
(final RaftRequestMessage request)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/RpcTcpClient.java:48
Method
send
(RaftRequestMessage request)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/http/HttpRpcClient.java:37
Method
startListening
(RaftMessageHandler messageHandler)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/http/JraftServletListener.java:50
Method
stop
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RpcListener.java:7
Method
stop
()
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/RpcTcpListener.java:52
Method
stop
()
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/http/JraftServletListener.java:55
Method
testBooleanConverter
()
jraft-extensions/src/test/java/net/data/technology/jraft/extensions/BinaryUtilTests.java:35
Method
testBuffer
()
jraft-extensions/src/test/java/net/data/technology/jraft/extensions/FileBasedSequentialLogStoreTests.java:22
Method
testCompactAll
()
jraft-extensions/src/test/java/net/data/technology/jraft/extensions/FileBasedSequentialLogStoreTests.java:210
Method
testCompactAll
()
jraft-extensions/src/test/java/net/data/technology/jraft/extensions/H2LogStoreTests.java:192
Method
testCompactRandom
()
jraft-extensions/src/test/java/net/data/technology/jraft/extensions/FileBasedSequentialLogStoreTests.java:155
Method
testCompactRandom
()
jraft-extensions/src/test/java/net/data/technology/jraft/extensions/H2LogStoreTests.java:135
Method
testIntegerConverter
()
jraft-extensions/src/test/java/net/data/technology/jraft/extensions/BinaryUtilTests.java:19
Method
testLogEntryConverter
()
jraft-extensions/src/test/java/net/data/technology/jraft/extensions/BinaryUtilTests.java:43
Method
testLongConverter
()
jraft-extensions/src/test/java/net/data/technology/jraft/extensions/BinaryUtilTests.java:27
Method
testPackAndUnpack
()
jraft-extensions/src/test/java/net/data/technology/jraft/extensions/FileBasedSequentialLogStoreTests.java:48
Method
testPackAndUnpack
()
jraft-extensions/src/test/java/net/data/technology/jraft/extensions/H2LogStoreTests.java:22
Method
testRequestConverter
()
jraft-extensions/src/test/java/net/data/technology/jraft/extensions/BinaryUtilTests.java:73
Method
testRequestSerialization
()
jraft-extensions/src/test/java/net/data/technology/jraft/extensions/GsonSerializationTests.java:43
Method
testResponseConverter
()
jraft-extensions/src/test/java/net/data/technology/jraft/extensions/BinaryUtilTests.java:53
Method
testResponseSerialization
()
jraft-extensions/src/test/java/net/data/technology/jraft/extensions/GsonSerializationTests.java:22
Method
testSerialization
()
net.data.technology.jraft/src/test/java/net/data/technology/jraft/tests/ClusterConfigurationTests.java:15
Method
testSerialization
()
net.data.technology.jraft/src/test/java/net/data/technology/jraft/tests/SnapshotSyncRequestTests.java:17
Method
testSerializationWithZeroData
()
net.data.technology.jraft/src/test/java/net/data/technology/jraft/tests/SnapshotSyncRequestTests.java:60
Method
testStateManager
()
jraft-extensions/src/test/java/net/data/technology/jraft/extensions/FileBasedServerStateManagerTests.java:27
Method
testStore
()
jraft-extensions/src/test/java/net/data/technology/jraft/extensions/FileBasedSequentialLogStoreTests.java:85
Method
testStore
()
jraft-extensions/src/test/java/net/data/technology/jraft/extensions/H2LogStoreTests.java:63
Method
toByte
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftMessageType.java:11
Method
warning
(String format, Object... args)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/Log4jLogger.java:29
← previous
301–391 of 391, ranked by callers