MCPcopy Create free account

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

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

MethodClusterConfiguration
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/ClusterConfiguration.java:14
MethodClusterServer
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/ClusterServer.java:11
MethodCommittingThread
(RaftServer server)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:1570
MethodFileBasedSequentialLogStore
(String logContainer)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/FileBasedSequentialLogStore.java:54
MethodFileBasedServerStateManager
(String dataDirectory)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/FileBasedServerStateManager.java:38
MethodH2LogStore
(String path)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/H2LogStore.java:45
MethodHttpRpcClient
(String serverUrl)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/http/HttpRpcClient.java:30
MethodJraftServlet
()
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/http/JraftServlet.java:27
MethodLog4jLogger
(Logger logger)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/Log4jLogger.java:9
MethodLogBuffer
(long startIndex, int maxSize)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/FileBasedSequentialLogStore.java:571
MethodLogEntry
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/LogEntry.java:9
MethodMessagePrinter
(Path baseDir, int listeningPort)
jraft-dmprinter/src/main/java/net/data/technology/jraft/MessagePrinter.java:55
MethodPair
(TFirst first, TSecond second)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/Pair.java:8
MethodPair
(T1 item1, T2 item2)
jraft-dmprinter/src/main/java/net/data/technology/jraft/App.java:228
MethodPeerServer
(ClusterServer server, RaftContext context, final Consumer<PeerServer> heartbeatConsumer)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/PeerServer.java:28
MethodRaftClient
(RpcClientFactory rpcClientFactory, ClusterConfiguration configuration, LoggerFactory loggerFactory)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftClient.java:23
MethodRaftContext
(ServerStateManager stateManager, StateMachine stateMachine, RaftParameters raftParameters, RpcListener rpcLis
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftContext.java:15
MethodRaftMessageSenderImpl
(RaftServer server)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:1480
MethodRaftServer
(RaftContext context)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:56
MethodRpcException
(Throwable realException, RaftRequestMessage request)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RpcException.java:11
MethodRpcTcpClient
(InetSocketAddress remote, ExecutorService executorService)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/RpcTcpClient.java:33
MethodRpcTcpClientFactory
(ExecutorService executorService)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/RpcTcpClientFactory.java:16
MethodRpcTcpListener
(int port, ExecutorService executorService)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/RpcTcpListener.java:32
MethodSnapshot
(long lastLogIndex, long lastLogTerm, ClusterConfiguration lastConfig)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/Snapshot.java:10
MethodSnapshotSyncContext
(Snapshot snapshot)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/SnapshotSyncContext.java:8
MethodSnapshotSyncRequest
(Snapshot snapshot, long offset, byte[] data, boolean done)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/SnapshotSyncRequest.java:12
MethodaddServer
(ClusterServer server)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:1485
Methodappend
(LogEntry entry)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/FileBasedSequentialLogStore.java:683
MethodappendEntries
(byte[][] values)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:1511
MethodapplySnapshot
(Snapshot snapshot)
jraft-dmprinter/src/main/java/net/data/technology/jraft/MessagePrinter.java:126
Methodcall
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:72
Methodcall
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/PeerServer.java:45
Methodcancelled
()
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/http/HttpRpcClient.java:68
Methodcommit
(long logIndex, byte[] data)
jraft-dmprinter/src/main/java/net/data/technology/jraft/MessagePrinter.java:101
Methodcompare
(Long arg0, Long arg1)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:25
Methodcompleted
(HttpResponse result)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/http/HttpRpcClient.java:45
MethodcontextDestroyed
(ServletContextEvent sce)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/http/JraftServletListener.java:46
MethodcontextInitialized
(ServletContextEvent sce)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/http/JraftServletListener.java:33
MethodcreateRpcClient
(String endpoint)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/RpcTcpClientFactory.java:20
MethodcreateRpcClient
(String endpoint)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/http/HttpRpcClientFactory.java:8
MethodcreateSnapshot
(Snapshot snapshot)
jraft-dmprinter/src/main/java/net/data/technology/jraft/MessagePrinter.java:179
Methoddebug
(String format, Object... args)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/Log4jLogger.java:13
MethoddoGet
(HttpServletRequest request, HttpServletResponse response)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/http/JraftServlet.java:32
MethoddoPost
(HttpServletRequest request, HttpServletResponse response)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/http/JraftServlet.java:37
Methoderror
(String format, Object... args)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/Log4jLogger.java:37
Methodfailed
(Exception ex)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/http/HttpRpcClient.java:63
MethodgetLastSnapshot
()
jraft-dmprinter/src/main/java/net/data/technology/jraft/MessagePrinter.java:221
MethodgetLogger
(Class<?> clazz)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/Log4jLoggerFactory.java:10
MethodgetMessageSender
(ServletContext context)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/http/JraftServletListener.java:29
MethodgetTerm
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftMessage.java:34
Methodinfo
(String format, Object... args)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/Log4jLogger.java:21
MethodlastIndex
()
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/FileBasedSequentialLogStore.java:580
Methodmain
( String[] args )
jraft-dmprinter/src/main/java/net/data/technology/jraft/App.java:26
MethodpreCommit
(long logIndex, byte[] data)
jraft-dmprinter/src/main/java/net/data/technology/jraft/MessagePrinter.java:274
MethodprocessRequest
(RaftRequestMessage request)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:131
MethodprocessRequest
(RaftRequestMessage request)
jraft-dmprinter/src/main/java/net/data/technology/jraft/DummyMessageHandler.java:13
MethodreadSnapshotData
(Snapshot snapshot, long offset, byte[] buffer)
jraft-dmprinter/src/main/java/net/data/technology/jraft/MessagePrinter.java:160
MethodremoveServer
(int serverId)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:1495
Methodrollback
(long logIndex, byte[] data)
jraft-dmprinter/src/main/java/net/data/technology/jraft/MessagePrinter.java:258
Methodrun
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:1581
Methodrun
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftClient.java:118
MethodsaveSnapshotData
(Snapshot snapshot, long offset, byte[] data)
jraft-dmprinter/src/main/java/net/data/technology/jraft/MessagePrinter.java:109
Methodsend
(final RaftRequestMessage request)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/RpcTcpClient.java:48
Methodsend
(RaftRequestMessage request)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/http/HttpRpcClient.java:37
MethodstartListening
(RaftMessageHandler messageHandler)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/http/JraftServletListener.java:50
Methodstop
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RpcListener.java:7
Methodstop
()
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/RpcTcpListener.java:52
Methodstop
()
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/http/JraftServletListener.java:55
MethodtestBooleanConverter
()
jraft-extensions/src/test/java/net/data/technology/jraft/extensions/BinaryUtilTests.java:35
MethodtestBuffer
()
jraft-extensions/src/test/java/net/data/technology/jraft/extensions/FileBasedSequentialLogStoreTests.java:22
MethodtestCompactAll
()
jraft-extensions/src/test/java/net/data/technology/jraft/extensions/FileBasedSequentialLogStoreTests.java:210
MethodtestCompactAll
()
jraft-extensions/src/test/java/net/data/technology/jraft/extensions/H2LogStoreTests.java:192
MethodtestCompactRandom
()
jraft-extensions/src/test/java/net/data/technology/jraft/extensions/FileBasedSequentialLogStoreTests.java:155
MethodtestCompactRandom
()
jraft-extensions/src/test/java/net/data/technology/jraft/extensions/H2LogStoreTests.java:135
MethodtestIntegerConverter
()
jraft-extensions/src/test/java/net/data/technology/jraft/extensions/BinaryUtilTests.java:19
MethodtestLogEntryConverter
()
jraft-extensions/src/test/java/net/data/technology/jraft/extensions/BinaryUtilTests.java:43
MethodtestLongConverter
()
jraft-extensions/src/test/java/net/data/technology/jraft/extensions/BinaryUtilTests.java:27
MethodtestPackAndUnpack
()
jraft-extensions/src/test/java/net/data/technology/jraft/extensions/FileBasedSequentialLogStoreTests.java:48
MethodtestPackAndUnpack
()
jraft-extensions/src/test/java/net/data/technology/jraft/extensions/H2LogStoreTests.java:22
MethodtestRequestConverter
()
jraft-extensions/src/test/java/net/data/technology/jraft/extensions/BinaryUtilTests.java:73
MethodtestRequestSerialization
()
jraft-extensions/src/test/java/net/data/technology/jraft/extensions/GsonSerializationTests.java:43
MethodtestResponseConverter
()
jraft-extensions/src/test/java/net/data/technology/jraft/extensions/BinaryUtilTests.java:53
MethodtestResponseSerialization
()
jraft-extensions/src/test/java/net/data/technology/jraft/extensions/GsonSerializationTests.java:22
MethodtestSerialization
()
net.data.technology.jraft/src/test/java/net/data/technology/jraft/tests/ClusterConfigurationTests.java:15
MethodtestSerialization
()
net.data.technology.jraft/src/test/java/net/data/technology/jraft/tests/SnapshotSyncRequestTests.java:17
MethodtestSerializationWithZeroData
()
net.data.technology.jraft/src/test/java/net/data/technology/jraft/tests/SnapshotSyncRequestTests.java:60
MethodtestStateManager
()
jraft-extensions/src/test/java/net/data/technology/jraft/extensions/FileBasedServerStateManagerTests.java:27
MethodtestStore
()
jraft-extensions/src/test/java/net/data/technology/jraft/extensions/FileBasedSequentialLogStoreTests.java:85
MethodtestStore
()
jraft-extensions/src/test/java/net/data/technology/jraft/extensions/H2LogStoreTests.java:63
MethodtoByte
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftMessageType.java:11
Methodwarning
(String format, Object... args)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/Log4jLogger.java:29
← previous301–391 of 391, ranked by callers