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
fireEvent
Send the given event on the EventBus if one is available @param event the event to send on the eventBus
pantheon-client/src/main/java/com/pantheon/client/DiscoveryClientNode.java:405
↓ 2 callers
Method
getAddress
()
pantheon-client/src/main/java/com/pantheon/client/transport/Server.java:47
↓ 2 callers
Method
getAndStoreFullRegistry
Gets the full registry information from the pantheon server and stores it locally. When applying the full registry, the following flow is observed: <p
pantheon-client/src/main/java/com/pantheon/client/DiscoveryClientNode.java:469
↓ 2 callers
Method
getCause
()
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/ResponseFuture.java:102
↓ 2 callers
Method
getChannelFuture
()
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/NettyRemotingClient.java:665
↓ 2 callers
Method
getClazzFields
(Class<? extends CommandCustomHeader> classHeader)
pantheon-remoting/src/main/java/com/pantheon/remoting/protocol/RemotingCommand.java:294
↓ 2 callers
Method
getClientPort
()
pantheon-server/src/main/java/com/pantheon/server/node/RemoteServerNode.java:70
↓ 2 callers
Method
getClusterNodeCount
()
pantheon-server/src/main/java/com/pantheon/server/config/PantheonServerConfig.java:23
↓ 2 callers
Method
getConnectTimeoutMillis
()
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/NettyClientConfig.java:67
↓ 2 callers
Method
getControllerCandidateServers
()
pantheon-server/src/main/java/com/pantheon/server/config/PantheonServerConfig.java:25
↓ 2 callers
Method
getControllerCandidateServers
()
pantheon-server/src/main/java/com/pantheon/server/config/CachedPantheonServerConfig.java:103
↓ 2 callers
Method
getControllerNodeId
()
pantheon-server/src/main/java/com/pantheon/server/node/ControllerVote.java:44
↓ 2 callers
Method
getDataDir
()
pantheon-server/src/main/java/com/pantheon/server/config/PantheonServerConfig.java:9
↓ 2 callers
Method
getDeltaRetentionTimerIntervalInMs
()
pantheon-server/src/main/java/com/pantheon/server/config/PantheonServerConfig.java:35
↓ 2 callers
Method
getGZIP
Get the compressed information about the applications. @param key the key for which the compressed cached information needs to be obtained. @return c
pantheon-server/src/main/java/com/pantheon/server/registry/ResponseCache.java:33
↓ 2 callers
Method
getGzipped
()
pantheon-server/src/main/java/com/pantheon/server/registry/ResponseCacheImpl.java:250
↓ 2 callers
Method
getHeartBeatCheckInterval
()
pantheon-server/src/main/java/com/pantheon/server/config/PantheonServerConfig.java:27
↓ 2 callers
Method
getIPAddr
Returns the ip address of the instance. @return - the ip address, in AWS scenario it is a private IP.
pantheon-client/src/main/java/com/pantheon/client/appinfo/InstanceInfo.java:419
↓ 2 callers
Method
getInstance
()
pantheon-server/src/main/java/com/pantheon/server/node/ControllerNode.java:15
↓ 2 callers
Method
getInstanceByAppAndId
(String appName, String id)
pantheon-server/src/main/java/com/pantheon/server/registry/InstanceRegistryImpl.java:247
↓ 2 callers
Method
getInstanceId
()
pantheon-common/src/main/java/com/pantheon/common/protocol/heartBeat/ServiceUnregister.java:22
↓ 2 callers
Method
getInstances
(String serviceId)
pantheon-spring-cloud-netflix-client/src/main/java/com/pantheon/netflix/client/PantheonDiscoveryClient.java:74
↓ 2 callers
Method
getIp
()
pantheon-server/src/main/java/com/pantheon/server/node/RemoteServerNode.java:62
↓ 2 callers
Method
getJointime
()
pantheon-common/src/main/java/com/pantheon/common/ServiceThread.java:78
↓ 2 callers
Method
getJointime
()
pantheon-remoting/src/main/java/com/pantheon/remoting/common/ServiceThread.java:76
↓ 2 callers
Method
getMetadata
(Server server)
pantheon-spring-cloud-netflix-client/src/main/java/com/pantheon/netflix/client/ribbon/PantheonServerIntrospector.java:30
↓ 2 callers
Method
getMetadata
Returns all application specific metadata set on the instance. @return application specific metadata.
pantheon-client/src/main/java/com/pantheon/client/appinfo/InstanceInfo.java:646
↓ 2 callers
Method
getNodeId
()
pantheon-server/src/main/java/com/pantheon/server/config/ArchaiusPantheonServerConfig.java:255
↓ 2 callers
Method
getNodeInternTcpPort
()
pantheon-server/src/main/java/com/pantheon/server/config/PantheonServerConfig.java:17
↓ 2 callers
Method
getNodeInternTcpPort
()
pantheon-server/src/main/java/com/pantheon/server/config/CachedPantheonServerConfig.java:71
↓ 2 callers
Method
getNodeIp
()
pantheon-server/src/main/java/com/pantheon/server/config/CachedPantheonServerConfig.java:63
↓ 2 callers
Method
getNonSecurePort
()
pantheon-spring-cloud-netflix-client/src/main/java/com/pantheon/netflix/client/serviceregistry/PantheonRegistration.java:96
↓ 2 callers
Method
getObject2
()
pantheon-remoting/src/main/java/com/pantheon/remoting/common/Pair.java:41
↓ 2 callers
Method
getOrCreateClientNode
()
pantheon-client/src/main/java/com/pantheon/client/ClientManager.java:34
↓ 2 callers
Method
getOverriddenInstanceStatus
(InstanceInfo r, Lease<InstanceInfo> existi
pantheon-server/src/main/java/com/pantheon/server/registry/InstanceRegistryImpl.java:146
↓ 2 callers
Method
getPort
()
pantheon-spring-cloud-netflix-client/src/main/java/com/pantheon/netflix/client/serviceregistry/PantheonRegistration.java:48
↓ 2 callers
Method
getReconcileHashCode
(Applications applications)
pantheon-client/src/main/java/com/pantheon/client/DiscoveryClientNode.java:536
↓ 2 callers
Method
getSecurePort
()
pantheon-client/src/main/java/com/pantheon/client/appinfo/InstanceInfo.java:342
↓ 2 callers
Method
getServerToClient
()
pantheon-server/src/main/java/com/pantheon/server/ServerNode.java:290
↓ 2 callers
Method
getServerWorkerThreads
()
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/NettyServerConfig.java:49
↓ 2 callers
Method
getServiceName
()
pantheon-common/src/main/java/com/pantheon/common/protocol/heartBeat/ServiceUnregister.java:14
↓ 2 callers
Method
getServiceName
()
pantheon-common/src/main/java/com/pantheon/common/protocol/heartBeat/HeartBeat.java:18
↓ 2 callers
Method
getServiceUpTimestamp
Gets the milliseconds since epoch when the service for the lease was marked as up. @return the milliseconds since epoch when the service for the leas
pantheon-server/src/main/java/com/pantheon/server/lease/Lease.java:130
↓ 2 callers
Method
getSlot
get slot @param serviceName @return
pantheon-server/src/main/java/com/pantheon/server/slot/SlotManager.java:124
↓ 2 callers
Method
getType
()
pantheon-remoting/src/main/java/com/pantheon/remoting/protocol/RemotingCommand.java:452
↓ 2 callers
Method
headerEncode
()
pantheon-remoting/src/main/java/com/pantheon/remoting/protocol/RemotingCommand.java:363
↓ 2 callers
Method
init
(String slotScope)
pantheon-server/src/main/java/com/pantheon/server/slot/SlotsReplica.java:19
↓ 2 callers
Method
initConfig
()
pantheon-client/src/main/java/com/pantheon/client/config/DefaultInstanceConfig.java:66
↓ 2 callers
Method
initConfig
()
pantheon-server/src/main/java/com/pantheon/server/config/ArchaiusPantheonServerConfig.java:79
↓ 2 callers
Method
initReplicaNodeId
if replicaNodeId is empty , will blocking in this method
pantheon-server/src/main/java/com/pantheon/server/slot/SlotManager.java:104
↓ 2 callers
Method
initSlotsReplicas
if slotScopes is empty and a controller candidate will blocking in this method @param slotScopes @param isController
pantheon-server/src/main/java/com/pantheon/server/slot/SlotManager.java:82
↓ 2 callers
Method
invokeAsyncImpl
(final Channel channel, final RemotingCommand request, final long timeoutMillis, final InvokeCallback
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/NettyRemotingAbstract.java:450
↓ 2 callers
Method
invokeOnewayImpl
one way message do not process response @param channel @param request @param timeoutMillis @throws InterruptedException @throws RemotingTooMuchRequest
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/NettyRemotingAbstract.java:542
↓ 2 callers
Method
invokeSyncImpl
(final Channel channel, final RemotingCommand request, final long timeoutMillis)
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/NettyRemotingAbstract.java:405
↓ 2 callers
Method
isControllerCandidate
()
pantheon-server/src/main/java/com/pantheon/server/config/ArchaiusPantheonServerConfig.java:295
↓ 2 callers
Method
isInfoEnabled
()
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/NettyLogger.java:224
↓ 2 callers
Method
isLinuxPlatform
()
pantheon-remoting/src/main/java/com/pantheon/remoting/common/RemotingUtil.java:95
↓ 2 callers
Method
isRunning
()
pantheon-server/src/main/java/com/pantheon/server/network/IOThreadRunningSignal.java:14
↓ 2 callers
Method
isUseTLS
()
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/NettyClientConfig.java:131
↓ 2 callers
Method
markProtocolType
(int source, SerializeType type)
pantheon-remoting/src/main/java/com/pantheon/remoting/protocol/RemotingCommand.java:210
↓ 2 callers
Method
markResponseType
()
pantheon-remoting/src/main/java/com/pantheon/remoting/protocol/RemotingCommand.java:220
↓ 2 callers
Method
newInstance
(String s)
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/NettyLogger.java:45
↓ 2 callers
Method
obtainServersViaDiscovery
()
pantheon-spring-cloud-netflix-client/src/main/java/com/pantheon/netflix/client/loadbalancer/DiscoveryEnabledNIWSServerList.java:91
↓ 2 callers
Method
onChange
notify this method when service changed @param serviceInstances
pantheon-server/src/main/java/com/pantheon/server/slot/registry/ServiceChangedListener.java:26
↓ 2 callers
Method
onWaitEnd
()
pantheon-common/src/main/java/com/pantheon/common/ServiceThread.java:137
↓ 2 callers
Method
populateInstanceCountMap
Populates the provided instance count map. The instance count map is used as part of the general app list synchronization mechanism. @param instance
pantheon-client/src/main/java/com/pantheon/client/appinfo/Applications.java:159
↓ 2 callers
Method
processMessageReceived
Entry of incoming command processing. <p> <strong>Note:</strong> The incoming remoting command may be <ul> <li>An inquiry request from a remote peer
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/NettyRemotingAbstract.java:153
↓ 2 callers
Method
processRequest
(ChannelHandlerContext ctx, RemotingCommand request)
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/NettyRequestProcessor.java:29
↓ 2 callers
Method
readRemoteNodeInformation
blocking read information from other nodes @param socket @return
pantheon-server/src/main/java/com/pantheon/server/network/ServerNetworkManager.java:259
↓ 2 callers
Method
register
(final InstanceInfo info)
pantheon-server/src/main/java/com/pantheon/server/registry/InstanceRegistryImpl.java:61
↓ 2 callers
Method
release
()
pantheon-remoting/src/main/java/com/pantheon/remoting/common/SemaphoreReleaseOnlyOnce.java:35
↓ 2 callers
Method
renew
Renew the {@link Lease} associated with the passed in <code>appName</code> and <code>id</code>. @param id - unique id within appName - wh
pantheon-server/src/main/java/com/pantheon/server/lease/LeaseManager.java:48
↓ 2 callers
Method
requestFail
(final int opaque)
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/NettyRemotingAbstract.java:500
↓ 2 callers
Method
routeServer
(String serviceName)
pantheon-client/src/main/java/com/pantheon/client/transport/ClientAPIImpl.java:160
↓ 2 callers
Method
routeSlot
将服务路由到slot @param serviceName @return
pantheon-server/src/main/java/com/pantheon/server/slot/SlotManager.java:233
↓ 2 callers
Method
scanResponseTable
<p> This method is periodically invoked to scan and expire deprecated request. </p>
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/NettyRemotingAbstract.java:381
↓ 2 callers
Method
sendSelfInformation
(Socket socket)
pantheon-server/src/main/java/com/pantheon/server/network/ServerNetworkManager.java:221
↓ 2 callers
Method
sendUnRegister
()
pantheon-client/src/main/java/com/pantheon/client/DiscoveryClientNode.java:204
↓ 2 callers
Method
serviceUp
Mark the service as up. This will only take affect the first time called, subsequent calls will be ignored.
pantheon-server/src/main/java/com/pantheon/server/lease/Lease.java:63
↓ 2 callers
Method
setAppName
(String appName)
pantheon-client/src/main/java/com/pantheon/client/appinfo/InstanceInfo.java:322
↓ 2 callers
Method
setCmdVersion
(RemotingCommand cmd)
pantheon-remoting/src/main/java/com/pantheon/remoting/protocol/RemotingCommand.java:93
↓ 2 callers
Method
setHostName
(String hostName)
pantheon-client/src/main/java/com/pantheon/client/appinfo/InstanceInfo.java:306
↓ 2 callers
Method
setIPAddr
Sets the ip address of this running instance. @param ip the ip address of the instance. @return the {@link InstanceInfo} builder.
pantheon-client/src/main/java/com/pantheon/client/appinfo/InstanceInfo.java:221
↓ 2 callers
Method
setInstanceId
(String instanceId)
pantheon-client/src/main/java/com/pantheon/client/appinfo/InstanceInfo.java:318
↓ 2 callers
Method
setInstanceId
(String instanceId)
pantheon-common/src/main/java/com/pantheon/common/protocol/heartBeat/HeartBeat.java:30
↓ 2 callers
Method
setIsDirty
@param isDirty true if dirty, false otherwise. @deprecated use {@link #setIsDirty()} and {@link #unsetIsDirty(long)} to set and unset <p> Sets the dir
pantheon-client/src/main/java/com/pantheon/client/appinfo/InstanceInfo.java:574
↓ 2 callers
Method
setIsRunning
(Boolean isRunning)
pantheon-server/src/main/java/com/pantheon/server/network/IOThreadRunningSignal.java:18
↓ 2 callers
Method
setLastDirtyTimestamp
Set the time indicating that the instance was touched. @param lastDirtyTimestamp time when the instance was touched.
pantheon-client/src/main/java/com/pantheon/client/appinfo/InstanceInfo.java:503
↓ 2 callers
Method
setNodeId
(Integer nodeId)
pantheon-server/src/main/java/com/pantheon/server/node/ControllerNode.java:23
↓ 2 callers
Method
setReplicaNodeId
corresponding replica slots id @param replicaNodeId
pantheon-server/src/main/java/com/pantheon/server/slot/Slots.java:49
↓ 2 callers
Method
setSerializeTypeCurrentRPC
(SerializeType serializeTypeCurrentRPC)
pantheon-remoting/src/main/java/com/pantheon/remoting/protocol/RemotingCommand.java:541
↓ 2 callers
Method
setServerAddresses
(String serverAddresses)
pantheon-common/src/main/java/com/pantheon/common/protocol/header/GetServerAddressResponseHeader.java:42
↓ 2 callers
Method
setServiceName
(String serviceName)
pantheon-common/src/main/java/com/pantheon/common/protocol/heartBeat/HeartBeat.java:22
↓ 2 callers
Method
setServiceUpTimestamp
Set the leases service UP timestamp.
pantheon-server/src/main/java/com/pantheon/server/lease/Lease.java:72
↓ 2 callers
Method
setSlotNum
(int slotNum)
pantheon-client/src/main/java/com/pantheon/client/transport/Server.java:71
↓ 2 callers
Method
setSlotsAllocation
(String slotsAllocation)
pantheon-common/src/main/java/com/pantheon/common/protocol/header/GetSlotsResponseHeader.java:43
↓ 2 callers
Method
setZones
(List<DiscoveryEnabledServer> servers)
pantheon-spring-cloud-netflix-client/src/main/java/com/pantheon/netflix/client/ribbon/DomainExtractingServerList.java:39
↓ 2 callers
Method
shouldFetchRegistry
should fetch registry ,default true @return
pantheon-client/src/main/java/com/pantheon/client/config/PantheonInstanceConfig.java:49
↓ 2 callers
Method
shouldFilterOnlyUpInstances
()
pantheon-client/src/main/java/com/pantheon/client/config/PantheonInstanceConfig.java:51
↓ 2 callers
Method
startNextRoundVote
开启下一轮投票
pantheon-server/src/main/java/com/pantheon/server/node/ControllerCandidate.java:93
← previous
next →
201–300 of 1,226, ranked by callers