MCPcopy Create free account

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

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

↓ 1 callersMethodacceptRequests
(RaftMessageHandler messageHandler)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/RpcTcpListener.java:78
↓ 1 callersMethodacceptRequests
()
jraft-dmprinter/src/main/java/net/data/technology/jraft/MessagePrinter.java:298
↓ 1 callersMethodaddServer
Add a new server to the cluster @param server @return true if request is accepted, or false if no leader, rpc fails or leader declines
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftMessageSender.java:12
↓ 1 callersMethodaddServer
(ClusterServer server)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftClient.java:52
↓ 1 callersMethodappendEntries
Append multiple application logs to log store @param values, the application log entries @return true if request is accepted or false if no leader, rp
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftMessageSender.java:26
↓ 1 callersMethodapplyLogPack
Apply the log pack to current log store, starting from index @param index, the log index that start applying the logPack, index starts from 1 @param l
net.data.technology.jraft/src/main/java/net/data/technology/jraft/SequentialLogStore.java:66
↓ 1 callersMethodapplyLogPack
(long index, byte[] logPack)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/H2LogStore.java:234
↓ 1 callersMethodapplyLogPack
(long logIndex, byte[] logPack)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/FileBasedSequentialLogStore.java:327
↓ 1 callersMethodapplySnapshot
(Snapshot snapshot)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/StateMachine.java:15
↓ 1 callersMethodbackup
()
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/FileBasedSequentialLogStore.java:480
↓ 1 callersMethodcreateAppendEntriesRequest
(PeerServer peer)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:757
↓ 1 callersMethodcreateMessageSender
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:127
↓ 1 callersMethodcreateSnapshot
(Snapshot snapshot)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/StateMachine.java:21
↓ 1 callersMethodentryAt
(long index)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/FileBasedSequentialLogStore.java:611
↓ 1 callersMethodexecuteAsClient
(ClusterConfiguration configuration, ExecutorService executor)
jraft-dmprinter/src/main/java/net/data/technology/jraft/App.java:89
↓ 1 callersMethodexecuteInDummyMode
This is used to verify the rpc module's functionality @param mode
jraft-dmprinter/src/main/java/net/data/technology/jraft/App.java:138
↓ 1 callersMethodfill
(long start, long end, LogEntry[] result)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/FileBasedSequentialLogStore.java:626
↓ 1 callersMethodfirstIndex
()
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/FileBasedSequentialLogStore.java:589
↓ 1 callersMethodgetClusterConfig
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/PeerServer.java:56
↓ 1 callersMethodgetElectionTimeoutUpperBound
Upper value for election timeout @return
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftParameters.java:112
↓ 1 callersMethodgetHeartbeatInterval
Heartbeat interval for each peer @return
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftParameters.java:128
↓ 1 callersMethodgetLogEntries
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftRequestMessage.java:34
↓ 1 callersMethodgetLogSyncBatchSize
The batch size for each ReplicateLogRequest message @return
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftParameters.java:152
↓ 1 callersMethodgetLogSyncStopGap
the max gap allowed for log sync, if the gap between the client and leader is less than this value, the ReplicateLogRequest will be stopped @return
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftParameters.java:161
↓ 1 callersMethodgetLoggerFactory
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftContext.java:53
↓ 1 callersMethodgetLoggerFactory
()
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/http/JraftServletListener.java:64
↓ 1 callersMethodgetMatchedIndex
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/PeerServer.java:104
↓ 1 callersMethodgetMaximumAppendingSize
The maximum log entries in an appendEntries request @return
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftParameters.java:185
↓ 1 callersMethodgetMessageHandler
(ServletContext context)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/http/JraftServletListener.java:25
↓ 1 callersMethodgetOrCreateRpcClient
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftClient.java:130
↓ 1 callersMethodgetParameters
()
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/http/JraftServletListener.java:58
↓ 1 callersMethodgetRequest
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RpcException.java:16
↓ 1 callersMethodgetRpcFailureBackoff
Rpc backoff for peers that failed to be connected @return
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftParameters.java:136
↓ 1 callersMethodgetRpcListener
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftContext.java:49
↓ 1 callersMethodgetServerId
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/ServerStateManager.java:15
↓ 1 callersMethodgetServerId
()
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/FileBasedServerStateManager.java:94
↓ 1 callersMethodgetServerStateManager
()
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/http/JraftServletListener.java:60
↓ 1 callersMethodgetSnapshotBlockSize
The block size to sync while syncing snapshots to peers @return
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftParameters.java:177
↓ 1 callersMethodgetSnapshotSyncBlockSize
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:1398
↓ 1 callersMethodgetStateMachine
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftContext.java:61
↓ 1 callersMethodgetStateMachine
()
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/http/JraftServletListener.java:62
↓ 1 callersMethodhandleAddServerRequest
(RaftRequestMessage request)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:1201
↓ 1 callersMethodhandleAppendEntriesRequest
(RaftRequestMessage request)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:168
↓ 1 callersMethodhandleAppendEntriesResponse
(RaftResponseMessage response)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:453
↓ 1 callersMethodhandleClientRequest
(RaftRequestMessage request)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:279
↓ 1 callersMethodhandleElectionTimeout
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:311
↓ 1 callersMethodhandleExtendedMessages
(RaftRequestMessage request)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:879
↓ 1 callersMethodhandleExtendedResponseError
(Throwable error)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:1078
↓ 1 callersMethodhandleInstallSnapshotRequest
(RaftRequestMessage request)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:900
↓ 1 callersMethodhandleInstallSnapshotResponse
(RaftResponseMessage response)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:497
↓ 1 callersMethodhandleJoinClusterRequest
(RaftRequestMessage request)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:1326
↓ 1 callersMethodhandleLeaveClusterRequest
(RaftRequestMessage request)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:1365
↓ 1 callersMethodhandleLogSyncRequest
(RaftRequestMessage request)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:1242
↓ 1 callersMethodhandleRemoveServerRequest
(RaftRequestMessage request)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:1149
↓ 1 callersMethodhandleSnapshotSyncRequest
(SnapshotSyncRequest snapshotSyncRequest)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:955
↓ 1 callersMethodhandleVoteRequest
(RaftRequestMessage request)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:251
↓ 1 callersMethodhandleVotingResponse
(RaftResponseMessage response)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:538
↓ 1 callersMethodincreaseTerm
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/ServerState.java:25
↓ 1 callersMethodinviteServerToJoinCluster
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:1312
↓ 1 callersMethodisHeartbeatEnabled
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/PeerServer.java:84
↓ 1 callersMethodlastEntry
()
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/FileBasedSequentialLogStore.java:598
↓ 1 callersMethodloadClusterConfiguration
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/ServerStateManager.java:5
↓ 1 callersMethodloadLogStore
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/ServerStateManager.java:13
↓ 1 callersMethodloadLogStore
()
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/FileBasedServerStateManager.java:135
↓ 1 callersMethodlogEntriesEquals
(LogEntry entry1, LogEntry entry2)
jraft-extensions/src/test/java/net/data/technology/jraft/extensions/GsonSerializationTests.java:74
↓ 1 callersMethodmakeBusy
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/PeerServer.java:76
↓ 1 callersMethodmoreToCommit
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:1575
↓ 1 callersMethodpackLog
Pack {@code itemsToPack} log items starts from {@code index} @param index @param itemsToPack @return log pack
net.data.technology.jraft/src/main/java/net/data/technology/jraft/SequentialLogStore.java:59
↓ 1 callersMethodpackLog
(long index, int itemsToPack)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/H2LogStore.java:199
↓ 1 callersMethodpackLog
(long logIndex, int itemsToPack)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/FileBasedSequentialLogStore.java:283
↓ 1 callersMethodpersistState
(ServerState serverState)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/FileBasedServerStateManager.java:98
↓ 1 callersMethodprocessMessage
(String message, CompletableFuture<String> future)
jraft-dmprinter/src/main/java/net/data/technology/jraft/MessagePrinter.java:376
↓ 1 callersMethodrandomLogEntry
()
jraft-extensions/src/test/java/net/data/technology/jraft/extensions/GsonSerializationTests.java:93
↓ 1 callersMethodrandomLogEntry
()
jraft-dmprinter/src/main/java/net/data/technology/jraft/App.java:217
↓ 1 callersMethodrandomMessageType
()
jraft-dmprinter/src/main/java/net/data/technology/jraft/App.java:212
↓ 1 callersMethodrandomMessageType
()
jraft-dmprinter/src/main/java/net/data/technology/jraft/DummyMessageHandler.java:29
↓ 1 callersMethodrandomRequest
()
jraft-dmprinter/src/main/java/net/data/technology/jraft/App.java:194
↓ 1 callersMethodrandomResponse
(int source, long term)
jraft-dmprinter/src/main/java/net/data/technology/jraft/DummyMessageHandler.java:34
↓ 1 callersMethodread
(byte[] buffer)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/FileBasedServerStateManager.java:149
↓ 1 callersMethodreadBody
(AsynchronousSocketChannel connection, ByteBuffer bodyBuffer)
jraft-dmprinter/src/main/java/net/data/technology/jraft/MessagePrinter.java:351
↓ 1 callersMethodreadResponse
(AsyncTask<ByteBuffer> task, boolean skipQueueing)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/RpcTcpClient.java:107
↓ 1 callersMethodreadSnapshotData
(Snapshot snapshot, long offset, byte[] buffer)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/StateMachine.java:17
↓ 1 callersMethodreadState
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/ServerStateManager.java:11
↓ 1 callersMethodrefreshRpcClient
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftClient.java:142
↓ 1 callersMethodremoveServer
Remove a server from cluster, the server will step down when the removal is confirmed @param serverId, the id for the server to be removed @return tru
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftMessageSender.java:19
↓ 1 callersMethodremoveServer
(int serverId)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftClient.java:68
↓ 1 callersMethodrequestVote
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:359
↓ 1 callersMethodrestore
()
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/FileBasedSequentialLogStore.java:462
↓ 1 callersMethodrollback
(long logIndex, byte[] data)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/StateMachine.java:9
↓ 1 callersMethodrun
(RaftMessageSender messageSender)
jraft-dmprinter/src/main/java/net/data/technology/jraft/MessagePrinter.java:69
↓ 1 callersMethodsaveClusterConfiguration
(ClusterConfiguration configuration)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/FileBasedServerStateManager.java:80
↓ 1 callersMethodsaveSnapshotData
(Snapshot snapshot, long offset, byte[] data)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/StateMachine.java:13
↓ 1 callersMethodsetPendingCommit
()
net.data.technology.jraft/src/main/java/net/data/technology/jraft/PeerServer.java:112
↓ 1 callersMethodsnapshotAndCompact
(long indexCommitted)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RaftServer.java:683
↓ 1 callersMethodstartListening
(RaftMessageHandler messageHandler)
net.data.technology.jraft/src/main/java/net/data/technology/jraft/RpcListener.java:5
↓ 1 callersMethodstartListening
(RaftMessageHandler messageHandler)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/RpcTcpListener.java:39
↓ 1 callersMethodstop
()
jraft-dmprinter/src/main/java/net/data/technology/jraft/MessagePrinter.java:84
↓ 1 callersMethodwriteAt
Over writes a log entry at index of {@code index} @param index a value < {@code this.getFirstAvailableIndex()}, and starts from 1 @param logEntry
net.data.technology.jraft/src/main/java/net/data/technology/jraft/SequentialLogStore.java:36
MethodAsyncContext
(A attachment, CompletionHandler<Integer, A> handler)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/AsyncUtility.java:72
MethodAsyncTask
(TInput input, CompletableFuture<RaftResponseMessage> future)
jraft-extensions/src/main/java/net/data/technology/jraft/extensions/RpcTcpClient.java:191
← previousnext →201–300 of 391, ranked by callers