Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/ProgrammerAnthony/Pantheon
/ functions
Functions
1,226 in github.com/ProgrammerAnthony/Pantheon
⨍
Functions
1,226
◇
Types & classes
215
↓ 2 callers
Method
startServerIOThreads
background write and read thread after connecting @param socket
pantheon-server/src/main/java/com/pantheon/server/network/ServerNetworkManager.java:300
↓ 2 callers
Method
syncReplicaNodeIds
()
pantheon-server/src/main/java/com/pantheon/server/node/Controller.java:300
↓ 2 callers
Method
syncSlotsAllocation
sync slots allocation to other controller candidates
pantheon-server/src/main/java/com/pantheon/server/node/Controller.java:260
↓ 2 callers
Method
syncSlotsReplicaAllocation
()
pantheon-server/src/main/java/com/pantheon/server/node/Controller.java:281
↓ 2 callers
Method
toJson
(final Object obj, boolean prettyFormat)
pantheon-remoting/src/main/java/com/pantheon/remoting/protocol/RemotingSerializable.java:39
↓ 2 callers
Method
toString
()
pantheon-client/src/main/java/com/pantheon/client/transport/Server.java:75
↓ 2 callers
Method
unzipBytesToStr
(byte[] inputBuf)
pantheon-client/src/main/java/com/pantheon/client/transport/ClientAPIImpl.java:265
↓ 2 callers
Method
useEpoll
()
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/NettyRemotingServer.java:176
↓ 2 callers
Method
validateConfig
()
pantheon-client/src/main/java/com/pantheon/client/config/DefaultInstanceConfig.java:86
↓ 2 callers
Method
validateConfig
()
pantheon-server/src/main/java/com/pantheon/server/config/ArchaiusPantheonServerConfig.java:97
↓ 2 callers
Method
valueOf
(byte code)
pantheon-remoting/src/main/java/com/pantheon/remoting/protocol/SerializeType.java:35
↓ 2 callers
Method
waitForSlotsAllocation
()
pantheon-server/src/main/java/com/pantheon/server/node/ControllerCandidate.java:214
↓ 2 callers
Method
waitForSlotsReplicaAllocation
()
pantheon-server/src/main/java/com/pantheon/server/node/ControllerCandidate.java:252
↓ 2 callers
Method
waitReplicaNodeIds
()
pantheon-server/src/main/java/com/pantheon/server/node/ControllerCandidate.java:260
↓ 1 callers
Method
_shuffleAndStoreInstances
(boolean filterUpInstances)
pantheon-client/src/main/java/com/pantheon/client/appinfo/Application.java:160
↓ 1 callers
Method
afterClose
()
pantheon-common/src/main/java/com/pantheon/common/lifecycle/LifecycleListener.java:26
↓ 1 callers
Method
afterStart
()
pantheon-common/src/main/java/com/pantheon/common/lifecycle/LifecycleListener.java:10
↓ 1 callers
Method
afterStop
()
pantheon-common/src/main/java/com/pantheon/common/lifecycle/LifecycleListener.java:18
↓ 1 callers
Method
allocateSlots
allocate all slots to master node
pantheon-server/src/main/java/com/pantheon/server/node/Controller.java:77
↓ 1 callers
Method
apply
(InstanceInfo instanceInfo, Lease<InstanceInfo> existingLease)
pantheon-server/src/main/java/com/pantheon/server/rule/FirstMatchWinsCompositeRule.java:33
↓ 1 callers
Method
asyncProcessRequest
(ChannelHandlerContext ctx, RemotingCommand request, RemotingResponseCallback responseCallback)
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/AsyncNettyRequestProcessor.java:30
↓ 1 callers
Method
beforeClose
()
pantheon-common/src/main/java/com/pantheon/common/lifecycle/LifecycleListener.java:22
↓ 1 callers
Method
beforeStart
()
pantheon-common/src/main/java/com/pantheon/common/lifecycle/LifecycleListener.java:6
↓ 1 callers
Method
beforeStop
()
pantheon-common/src/main/java/com/pantheon/common/lifecycle/LifecycleListener.java:14
↓ 1 callers
Method
broadcastControllerId
()
pantheon-server/src/main/java/com/pantheon/server/node/Controller.java:468
↓ 1 callers
Method
broadcastNodeSlotsReplicas
()
pantheon-server/src/main/java/com/pantheon/server/node/Controller.java:403
↓ 1 callers
Method
broadcastReplicaNodeId
()
pantheon-server/src/main/java/com/pantheon/server/node/Controller.java:425
↓ 1 callers
Method
buildInstanceInfo
()
pantheon-client/src/main/java/com/pantheon/client/DiscoveryClientNode.java:267
↓ 1 callers
Method
calTotalLen
(int remark, int ext)
pantheon-remoting/src/main/java/com/pantheon/remoting/protocol/PantheonSerializable.java:117
↓ 1 callers
Method
canMoveToClosed
()
pantheon-common/src/main/java/com/pantheon/common/lifecycle/Lifecycle.java:152
↓ 1 callers
Method
canMoveToStarted
()
pantheon-common/src/main/java/com/pantheon/common/lifecycle/Lifecycle.java:93
↓ 1 callers
Method
canMoveToStopped
()
pantheon-common/src/main/java/com/pantheon/common/lifecycle/Lifecycle.java:123
↓ 1 callers
Method
cancel
Cancels the registration of an instance. <p> This is normally invoked by a client when it shuts down informing the server to remove the instance from
pantheon-server/src/main/java/com/pantheon/server/registry/InstanceRegistryImpl.java:454
↓ 1 callers
Method
cancel
Cancels the registration of an instance. <p> This is normally invoked by a client when it shuts down informing the server to remove the instance from
pantheon-server/src/main/java/com/pantheon/server/registry/InstanceRegistry.java:95
↓ 1 callers
Method
cancelLease
Handles cancellation of leases for this particular instance. @return response indicating whether the operation was a success or failure.
pantheon-server/src/main/java/com/pantheon/server/processor/ClientManageProcessor.java:319
↓ 1 callers
Method
checkConfig
()
pantheon-client/src/main/java/com/pantheon/client/DiscoveryClientNode.java:155
↓ 1 callers
Method
checkFields
()
pantheon-remoting/src/main/java/com/pantheon/remoting/CommandCustomHeader.java:28
↓ 1 callers
Method
chooseControllerCandidate
()
pantheon-client/src/main/java/com/pantheon/client/transport/ClientAPIImpl.java:211
↓ 1 callers
Method
clearConnection
(Integer remoteNodeId)
pantheon-server/src/main/java/com/pantheon/server/network/ServerNetworkManager.java:546
↓ 1 callers
Method
connect
(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress,
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/NettyRemotingClient.java:683
↓ 1 callers
Method
connectAllControllerCandidates
connect to all controller candidate servers @return
pantheon-server/src/main/java/com/pantheon/server/network/ServerNetworkManager.java:113
↓ 1 callers
Method
connectBeforeControllerCandidateServers
connect before candidates avoid of nodes' duplicate connection @return
pantheon-server/src/main/java/com/pantheon/server/network/ServerNetworkManager.java:131
↓ 1 callers
Method
controllerCandidateInit
(ServerNodeRole serverNodeRole)
pantheon-server/src/main/java/com/pantheon/server/ServerNode.java:132
↓ 1 callers
Method
createClientConfig
(String vipAddresses)
pantheon-spring-cloud-netflix-client/src/main/java/com/pantheon/netflix/client/loadbalancer/DiscoveryEnabledNIWSServerList.java:152
↓ 1 callers
Method
decode
(final byte[] data, Class<T> classOfT)
pantheon-remoting/src/main/java/com/pantheon/remoting/protocol/RemotingSerializable.java:43
↓ 1 callers
Method
deleteStatusOverride
Removes status override for a give instance. @param appName the application name of the instance. @param id the unique ide
pantheon-server/src/main/java/com/pantheon/server/registry/InstanceRegistryImpl.java:395
↓ 1 callers
Method
deleteStatusOverride
Removes status override for a give instance. @param appName the application name of the instance. @param id the unique ide
pantheon-server/src/main/java/com/pantheon/server/registry/InstanceRegistry.java:79
↓ 1 callers
Method
deregister
(PantheonRegistration reg)
pantheon-spring-cloud-netflix-client/src/main/java/com/pantheon/netflix/client/serviceregistry/PantheonServiceRegistry.java:39
↓ 1 callers
Method
doAfterResponse
(final String remoteAddr, final RemotingCommand request, final RemotingCommand response)
pantheon-remoting/src/main/java/com/pantheon/remoting/RPCHook.java:30
↓ 1 callers
Method
doBeforeRequest
(final String remoteAddr, final RemotingCommand request)
pantheon-remoting/src/main/java/com/pantheon/remoting/RPCHook.java:28
↓ 1 callers
Method
doClose
()
pantheon-common/src/main/java/com/pantheon/common/lifecycle/AbstractLifecycleComponent.java:95
↓ 1 callers
Method
doStart
()
pantheon-common/src/main/java/com/pantheon/common/lifecycle/AbstractLifecycleComponent.java:49
↓ 1 callers
Method
doStop
()
pantheon-common/src/main/java/com/pantheon/common/lifecycle/AbstractLifecycleComponent.java:68
↓ 1 callers
Method
electController
elect controller within controller candidate @return
pantheon-server/src/main/java/com/pantheon/server/node/ControllerCandidate.java:64
↓ 1 callers
Method
encode
(final Object obj)
pantheon-remoting/src/main/java/com/pantheon/remoting/protocol/RemotingSerializable.java:31
↓ 1 callers
Method
encodeHeader
()
pantheon-remoting/src/main/java/com/pantheon/remoting/protocol/RemotingCommand.java:400
↓ 1 callers
Method
executeSlotsAllocation
calculate slots allocation with {@link #SLOTS_COUNT} and master node count
pantheon-server/src/main/java/com/pantheon/server/node/Controller.java:134
↓ 1 callers
Method
executeSlotsReplicaAllocation
get node id of all nodes and then allocate slots replica
pantheon-server/src/main/java/com/pantheon/server/node/Controller.java:170
↓ 1 callers
Method
extractId
(Server server)
pantheon-spring-cloud-netflix-client/src/main/java/com/pantheon/netflix/client/ribbon/DomainExtractingServer.java:38
↓ 1 callers
Method
extractTlsConfigFromFile
(final File configFile)
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/TlsHelper.java:139
↓ 1 callers
Method
failFast
mark the request of the specified channel as fail and to invoke fail callback immediately @param channel the channel which is close already
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/NettyRemotingAbstract.java:519
↓ 1 callers
Method
fetchServerAddresses
fetch server addresses to local map @param controllerCandidate
pantheon-client/src/main/java/com/pantheon/client/transport/ClientAPIImpl.java:131
↓ 1 callers
Method
fetchSlotsAllocation
fetch slots allocation @param controllerCandidate @return
pantheon-client/src/main/java/com/pantheon/client/transport/ClientAPIImpl.java:107
↓ 1 callers
Method
findChannel
(final String clientId)
pantheon-server/src/main/java/com/pantheon/server/client/ConsumerInfoManager.java:50
↓ 1 callers
Method
first
()
pantheon-client/src/main/java/com/pantheon/client/utils/Pair.java:9
↓ 1 callers
Method
fromJson
(String json, Class<T> classOfT)
pantheon-remoting/src/main/java/com/pantheon/remoting/protocol/RemotingSerializable.java:48
↓ 1 callers
Method
generatePayload
(Key key)
pantheon-server/src/main/java/com/pantheon/server/registry/ResponseCacheImpl.java:81
↓ 1 callers
Method
getAddress
()
pantheon-server/src/main/java/com/pantheon/server/slot/registry/ServiceInstance.java:55
↓ 1 callers
Method
getAllChannel
()
pantheon-server/src/main/java/com/pantheon/server/client/ConsumerInfoManager.java:107
↓ 1 callers
Method
getAndCreateServerChannel
()
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/NettyRemotingClient.java:437
↓ 1 callers
Method
getAndUpdateDelta
Get the delta registry information from the pantheon server and update it locally. When applying the delta, the following flow is observed: <p> if (up
pantheon-client/src/main/java/com/pantheon/client/DiscoveryClientNode.java:503
↓ 1 callers
Method
getAppGroupName
()
pantheon-client/src/main/java/com/pantheon/client/appinfo/InstanceInfo.java:386
↓ 1 callers
Method
getApplication
(String appName)
pantheon-client/src/main/java/com/pantheon/client/DiscoveryClientNode.java:454
↓ 1 callers
Method
getApplication
(String appName)
pantheon-server/src/main/java/com/pantheon/server/registry/InstanceRegistryImpl.java:486
↓ 1 callers
Method
getApplication
(String appName)
pantheon-server/src/main/java/com/pantheon/server/registry/InstanceRegistry.java:97
↓ 1 callers
Method
getApplicationDeltas
Get the registry information about the delta changes. The deltas are cached for a window specified by {@link PantheonServerConfig#getRetentionTimeInMS
pantheon-server/src/main/java/com/pantheon/server/registry/InstanceRegistry.java:42
↓ 1 callers
Method
getApplications
()
pantheon-spring-cloud-netflix-client/src/main/java/com/pantheon/netflix/client/PantheonHealthIndicator.java:71
↓ 1 callers
Method
getApplications
Returns the {@link Applications} object which is basically a container of all currently registered {@link Application}s. @return {@link Applications}
pantheon-client/src/main/java/com/pantheon/client/discovery/DiscoveryClient.java:32
↓ 1 callers
Method
getApplications
Get the registry information about all {@link Applications}.
pantheon-server/src/main/java/com/pantheon/server/registry/InstanceRegistryImpl.java:158
↓ 1 callers
Method
getApplications
(ChannelHandlerContext ctx, RemotingCommand request)
pantheon-server/src/main/java/com/pantheon/server/processor/ClientManageProcessor.java:76
↓ 1 callers
Method
getBeforeControllerCandidateServers
get 'before candidates' avoid of nodes' duplicate connection @return
pantheon-server/src/main/java/com/pantheon/server/config/CachedPantheonServerConfig.java:124
↓ 1 callers
Method
getBeginTimestamp
()
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/ResponseFuture.java:82
↓ 1 callers
Method
getBetterControllerNodeId
get least controller id @param votes @return
pantheon-server/src/main/java/com/pantheon/server/node/ControllerCandidate.java:200
↓ 1 callers
Method
getCacheUpdateTask
transfer cache data from readWriteCacheMap to readOnlyCacheMap
pantheon-server/src/main/java/com/pantheon/server/registry/ResponseCacheImpl.java:194
↓ 1 callers
Method
getCallbackExecutor
This method specifies thread pool to use while invoking callback methods. @return Dedicated thread pool instance if specified; or null if the callbac
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/NettyRemotingAbstract.java:374
↓ 1 callers
Method
getChannelEventListener
Custom channel event listener. @return custom channel event listener if defined; null otherwise.
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/NettyRemotingAbstract.java:126
↓ 1 callers
Method
getClientAsyncSemaphoreValue
()
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/NettyClientConfig.java:91
↓ 1 callers
Method
getClientCallbackExecutorThreads
()
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/NettyClientConfig.java:75
↓ 1 callers
Method
getClientChannelMaxIdleTimeSeconds
()
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/NettyClientConfig.java:99
↓ 1 callers
Method
getClientId
()
pantheon-client/src/main/java/com/pantheon/client/DiscoveryClientNode.java:688
↓ 1 callers
Method
getClientId
()
pantheon-common/src/main/java/com/pantheon/common/protocol/header/GetConsumerRunningInfoRequestHeader.java:21
↓ 1 callers
Method
getClientOnewaySemaphoreValue
()
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/NettyClientConfig.java:59
↓ 1 callers
Method
getClientSocketRcvBufSize
()
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/NettyClientConfig.java:115
↓ 1 callers
Method
getClientSocketSndBufSize
()
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/NettyClientConfig.java:107
↓ 1 callers
Method
getClientWorkerThreads
()
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/NettyClientConfig.java:51
↓ 1 callers
Method
getClusterNodeCount
()
pantheon-server/src/main/java/com/pantheon/server/config/ArchaiusPantheonServerConfig.java:300
↓ 1 callers
Method
getCode
()
pantheon-remoting/src/main/java/com/pantheon/remoting/protocol/SerializeType.java:44
↓ 1 callers
Method
getConsumerRunningInfo
server can load consumer state @param ctx @param request @return
pantheon-client/src/main/java/com/pantheon/client/transport/ClientRemotingProcessor.java:39
↓ 1 callers
Method
getConsumerRunningInfo
()
pantheon-server/src/main/java/com/pantheon/server/ServerNode.java:192
↓ 1 callers
Method
getController
()
pantheon-server/src/main/java/com/pantheon/server/node/RemoteServerNodeManager.java:80
← previous
next →
301–400 of 1,226, ranked by callers