MCPcopy Create free account

hub / github.com/ProgrammerAnthony/Pantheon / functions

Functions1,226 in github.com/ProgrammerAnthony/Pantheon

↓ 2 callersMethodstartServerIOThreads
background write and read thread after connecting @param socket
pantheon-server/src/main/java/com/pantheon/server/network/ServerNetworkManager.java:300
↓ 2 callersMethodsyncReplicaNodeIds
()
pantheon-server/src/main/java/com/pantheon/server/node/Controller.java:300
↓ 2 callersMethodsyncSlotsAllocation
sync slots allocation to other controller candidates
pantheon-server/src/main/java/com/pantheon/server/node/Controller.java:260
↓ 2 callersMethodsyncSlotsReplicaAllocation
()
pantheon-server/src/main/java/com/pantheon/server/node/Controller.java:281
↓ 2 callersMethodtoJson
(final Object obj, boolean prettyFormat)
pantheon-remoting/src/main/java/com/pantheon/remoting/protocol/RemotingSerializable.java:39
↓ 2 callersMethodtoString
()
pantheon-client/src/main/java/com/pantheon/client/transport/Server.java:75
↓ 2 callersMethodunzipBytesToStr
(byte[] inputBuf)
pantheon-client/src/main/java/com/pantheon/client/transport/ClientAPIImpl.java:265
↓ 2 callersMethoduseEpoll
()
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/NettyRemotingServer.java:176
↓ 2 callersMethodvalidateConfig
()
pantheon-client/src/main/java/com/pantheon/client/config/DefaultInstanceConfig.java:86
↓ 2 callersMethodvalidateConfig
()
pantheon-server/src/main/java/com/pantheon/server/config/ArchaiusPantheonServerConfig.java:97
↓ 2 callersMethodvalueOf
(byte code)
pantheon-remoting/src/main/java/com/pantheon/remoting/protocol/SerializeType.java:35
↓ 2 callersMethodwaitForSlotsAllocation
()
pantheon-server/src/main/java/com/pantheon/server/node/ControllerCandidate.java:214
↓ 2 callersMethodwaitForSlotsReplicaAllocation
()
pantheon-server/src/main/java/com/pantheon/server/node/ControllerCandidate.java:252
↓ 2 callersMethodwaitReplicaNodeIds
()
pantheon-server/src/main/java/com/pantheon/server/node/ControllerCandidate.java:260
↓ 1 callersMethod_shuffleAndStoreInstances
(boolean filterUpInstances)
pantheon-client/src/main/java/com/pantheon/client/appinfo/Application.java:160
↓ 1 callersMethodafterClose
()
pantheon-common/src/main/java/com/pantheon/common/lifecycle/LifecycleListener.java:26
↓ 1 callersMethodafterStart
()
pantheon-common/src/main/java/com/pantheon/common/lifecycle/LifecycleListener.java:10
↓ 1 callersMethodafterStop
()
pantheon-common/src/main/java/com/pantheon/common/lifecycle/LifecycleListener.java:18
↓ 1 callersMethodallocateSlots
allocate all slots to master node
pantheon-server/src/main/java/com/pantheon/server/node/Controller.java:77
↓ 1 callersMethodapply
(InstanceInfo instanceInfo, Lease<InstanceInfo> existingLease)
pantheon-server/src/main/java/com/pantheon/server/rule/FirstMatchWinsCompositeRule.java:33
↓ 1 callersMethodasyncProcessRequest
(ChannelHandlerContext ctx, RemotingCommand request, RemotingResponseCallback responseCallback)
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/AsyncNettyRequestProcessor.java:30
↓ 1 callersMethodbeforeClose
()
pantheon-common/src/main/java/com/pantheon/common/lifecycle/LifecycleListener.java:22
↓ 1 callersMethodbeforeStart
()
pantheon-common/src/main/java/com/pantheon/common/lifecycle/LifecycleListener.java:6
↓ 1 callersMethodbeforeStop
()
pantheon-common/src/main/java/com/pantheon/common/lifecycle/LifecycleListener.java:14
↓ 1 callersMethodbroadcastControllerId
()
pantheon-server/src/main/java/com/pantheon/server/node/Controller.java:468
↓ 1 callersMethodbroadcastNodeSlotsReplicas
()
pantheon-server/src/main/java/com/pantheon/server/node/Controller.java:403
↓ 1 callersMethodbroadcastReplicaNodeId
()
pantheon-server/src/main/java/com/pantheon/server/node/Controller.java:425
↓ 1 callersMethodbuildInstanceInfo
()
pantheon-client/src/main/java/com/pantheon/client/DiscoveryClientNode.java:267
↓ 1 callersMethodcalTotalLen
(int remark, int ext)
pantheon-remoting/src/main/java/com/pantheon/remoting/protocol/PantheonSerializable.java:117
↓ 1 callersMethodcanMoveToClosed
()
pantheon-common/src/main/java/com/pantheon/common/lifecycle/Lifecycle.java:152
↓ 1 callersMethodcanMoveToStarted
()
pantheon-common/src/main/java/com/pantheon/common/lifecycle/Lifecycle.java:93
↓ 1 callersMethodcanMoveToStopped
()
pantheon-common/src/main/java/com/pantheon/common/lifecycle/Lifecycle.java:123
↓ 1 callersMethodcancel
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 callersMethodcancel
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 callersMethodcancelLease
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 callersMethodcheckConfig
()
pantheon-client/src/main/java/com/pantheon/client/DiscoveryClientNode.java:155
↓ 1 callersMethodcheckFields
()
pantheon-remoting/src/main/java/com/pantheon/remoting/CommandCustomHeader.java:28
↓ 1 callersMethodchooseControllerCandidate
()
pantheon-client/src/main/java/com/pantheon/client/transport/ClientAPIImpl.java:211
↓ 1 callersMethodclearConnection
(Integer remoteNodeId)
pantheon-server/src/main/java/com/pantheon/server/network/ServerNetworkManager.java:546
↓ 1 callersMethodconnect
(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress,
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/NettyRemotingClient.java:683
↓ 1 callersMethodconnectAllControllerCandidates
connect to all controller candidate servers @return
pantheon-server/src/main/java/com/pantheon/server/network/ServerNetworkManager.java:113
↓ 1 callersMethodconnectBeforeControllerCandidateServers
connect before candidates avoid of nodes' duplicate connection @return
pantheon-server/src/main/java/com/pantheon/server/network/ServerNetworkManager.java:131
↓ 1 callersMethodcontrollerCandidateInit
(ServerNodeRole serverNodeRole)
pantheon-server/src/main/java/com/pantheon/server/ServerNode.java:132
↓ 1 callersMethodcreateClientConfig
(String vipAddresses)
pantheon-spring-cloud-netflix-client/src/main/java/com/pantheon/netflix/client/loadbalancer/DiscoveryEnabledNIWSServerList.java:152
↓ 1 callersMethoddecode
(final byte[] data, Class<T> classOfT)
pantheon-remoting/src/main/java/com/pantheon/remoting/protocol/RemotingSerializable.java:43
↓ 1 callersMethoddeleteStatusOverride
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 callersMethoddeleteStatusOverride
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 callersMethodderegister
(PantheonRegistration reg)
pantheon-spring-cloud-netflix-client/src/main/java/com/pantheon/netflix/client/serviceregistry/PantheonServiceRegistry.java:39
↓ 1 callersMethoddoAfterResponse
(final String remoteAddr, final RemotingCommand request, final RemotingCommand response)
pantheon-remoting/src/main/java/com/pantheon/remoting/RPCHook.java:30
↓ 1 callersMethoddoBeforeRequest
(final String remoteAddr, final RemotingCommand request)
pantheon-remoting/src/main/java/com/pantheon/remoting/RPCHook.java:28
↓ 1 callersMethoddoClose
()
pantheon-common/src/main/java/com/pantheon/common/lifecycle/AbstractLifecycleComponent.java:95
↓ 1 callersMethoddoStart
()
pantheon-common/src/main/java/com/pantheon/common/lifecycle/AbstractLifecycleComponent.java:49
↓ 1 callersMethoddoStop
()
pantheon-common/src/main/java/com/pantheon/common/lifecycle/AbstractLifecycleComponent.java:68
↓ 1 callersMethodelectController
elect controller within controller candidate @return
pantheon-server/src/main/java/com/pantheon/server/node/ControllerCandidate.java:64
↓ 1 callersMethodencode
(final Object obj)
pantheon-remoting/src/main/java/com/pantheon/remoting/protocol/RemotingSerializable.java:31
↓ 1 callersMethodencodeHeader
()
pantheon-remoting/src/main/java/com/pantheon/remoting/protocol/RemotingCommand.java:400
↓ 1 callersMethodexecuteSlotsAllocation
calculate slots allocation with {@link #SLOTS_COUNT} and master node count
pantheon-server/src/main/java/com/pantheon/server/node/Controller.java:134
↓ 1 callersMethodexecuteSlotsReplicaAllocation
get node id of all nodes and then allocate slots replica
pantheon-server/src/main/java/com/pantheon/server/node/Controller.java:170
↓ 1 callersMethodextractId
(Server server)
pantheon-spring-cloud-netflix-client/src/main/java/com/pantheon/netflix/client/ribbon/DomainExtractingServer.java:38
↓ 1 callersMethodextractTlsConfigFromFile
(final File configFile)
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/TlsHelper.java:139
↓ 1 callersMethodfailFast
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 callersMethodfetchServerAddresses
fetch server addresses to local map @param controllerCandidate
pantheon-client/src/main/java/com/pantheon/client/transport/ClientAPIImpl.java:131
↓ 1 callersMethodfetchSlotsAllocation
fetch slots allocation @param controllerCandidate @return
pantheon-client/src/main/java/com/pantheon/client/transport/ClientAPIImpl.java:107
↓ 1 callersMethodfindChannel
(final String clientId)
pantheon-server/src/main/java/com/pantheon/server/client/ConsumerInfoManager.java:50
↓ 1 callersMethodfirst
()
pantheon-client/src/main/java/com/pantheon/client/utils/Pair.java:9
↓ 1 callersMethodfromJson
(String json, Class<T> classOfT)
pantheon-remoting/src/main/java/com/pantheon/remoting/protocol/RemotingSerializable.java:48
↓ 1 callersMethodgeneratePayload
(Key key)
pantheon-server/src/main/java/com/pantheon/server/registry/ResponseCacheImpl.java:81
↓ 1 callersMethodgetAddress
()
pantheon-server/src/main/java/com/pantheon/server/slot/registry/ServiceInstance.java:55
↓ 1 callersMethodgetAllChannel
()
pantheon-server/src/main/java/com/pantheon/server/client/ConsumerInfoManager.java:107
↓ 1 callersMethodgetAndCreateServerChannel
()
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/NettyRemotingClient.java:437
↓ 1 callersMethodgetAndUpdateDelta
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 callersMethodgetAppGroupName
()
pantheon-client/src/main/java/com/pantheon/client/appinfo/InstanceInfo.java:386
↓ 1 callersMethodgetApplication
(String appName)
pantheon-client/src/main/java/com/pantheon/client/DiscoveryClientNode.java:454
↓ 1 callersMethodgetApplication
(String appName)
pantheon-server/src/main/java/com/pantheon/server/registry/InstanceRegistryImpl.java:486
↓ 1 callersMethodgetApplication
(String appName)
pantheon-server/src/main/java/com/pantheon/server/registry/InstanceRegistry.java:97
↓ 1 callersMethodgetApplicationDeltas
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 callersMethodgetApplications
()
pantheon-spring-cloud-netflix-client/src/main/java/com/pantheon/netflix/client/PantheonHealthIndicator.java:71
↓ 1 callersMethodgetApplications
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 callersMethodgetApplications
Get the registry information about all {@link Applications}.
pantheon-server/src/main/java/com/pantheon/server/registry/InstanceRegistryImpl.java:158
↓ 1 callersMethodgetApplications
(ChannelHandlerContext ctx, RemotingCommand request)
pantheon-server/src/main/java/com/pantheon/server/processor/ClientManageProcessor.java:76
↓ 1 callersMethodgetBeforeControllerCandidateServers
get 'before candidates' avoid of nodes' duplicate connection @return
pantheon-server/src/main/java/com/pantheon/server/config/CachedPantheonServerConfig.java:124
↓ 1 callersMethodgetBeginTimestamp
()
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/ResponseFuture.java:82
↓ 1 callersMethodgetBetterControllerNodeId
get least controller id @param votes @return
pantheon-server/src/main/java/com/pantheon/server/node/ControllerCandidate.java:200
↓ 1 callersMethodgetCacheUpdateTask
transfer cache data from readWriteCacheMap to readOnlyCacheMap
pantheon-server/src/main/java/com/pantheon/server/registry/ResponseCacheImpl.java:194
↓ 1 callersMethodgetCallbackExecutor
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 callersMethodgetChannelEventListener
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 callersMethodgetClientAsyncSemaphoreValue
()
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/NettyClientConfig.java:91
↓ 1 callersMethodgetClientCallbackExecutorThreads
()
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/NettyClientConfig.java:75
↓ 1 callersMethodgetClientChannelMaxIdleTimeSeconds
()
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/NettyClientConfig.java:99
↓ 1 callersMethodgetClientId
()
pantheon-client/src/main/java/com/pantheon/client/DiscoveryClientNode.java:688
↓ 1 callersMethodgetClientId
()
pantheon-common/src/main/java/com/pantheon/common/protocol/header/GetConsumerRunningInfoRequestHeader.java:21
↓ 1 callersMethodgetClientOnewaySemaphoreValue
()
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/NettyClientConfig.java:59
↓ 1 callersMethodgetClientSocketRcvBufSize
()
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/NettyClientConfig.java:115
↓ 1 callersMethodgetClientSocketSndBufSize
()
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/NettyClientConfig.java:107
↓ 1 callersMethodgetClientWorkerThreads
()
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/NettyClientConfig.java:51
↓ 1 callersMethodgetClusterNodeCount
()
pantheon-server/src/main/java/com/pantheon/server/config/ArchaiusPantheonServerConfig.java:300
↓ 1 callersMethodgetCode
()
pantheon-remoting/src/main/java/com/pantheon/remoting/protocol/SerializeType.java:44
↓ 1 callersMethodgetConsumerRunningInfo
server can load consumer state @param ctx @param request @return
pantheon-client/src/main/java/com/pantheon/client/transport/ClientRemotingProcessor.java:39
↓ 1 callersMethodgetConsumerRunningInfo
()
pantheon-server/src/main/java/com/pantheon/server/ServerNode.java:192
↓ 1 callersMethodgetController
()
pantheon-server/src/main/java/com/pantheon/server/node/RemoteServerNodeManager.java:80
← previousnext →301–400 of 1,226, ranked by callers