MCPcopy Create free account

hub / github.com/ProgrammerAnthony/Pantheon / functions

Functions1,226 in github.com/ProgrammerAnthony/Pantheon

↓ 1 callersMethodisAlive
(Server server)
pantheon-spring-cloud-netflix-client/src/main/java/com/pantheon/netflix/client/loadbalancer/NIWSDiscoveryPing.java:28
↓ 1 callersMethodisBlank
(String str)
pantheon-remoting/src/main/java/com/pantheon/remoting/protocol/RemotingCommand.java:197
↓ 1 callersMethodisClientCloseSocketIfTimeout
()
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/NettyClientConfig.java:43
↓ 1 callersMethodisDaemon
()
pantheon-common/src/main/java/com/pantheon/common/ServiceThread.java:144
↓ 1 callersMethodisExpired
Checks if the lease of a given {@link InstanceInfo} has expired or not.
pantheon-server/src/main/java/com/pantheon/server/lease/Lease.java:79
↓ 1 callersMethodisFieldNullable
(Field field)
pantheon-remoting/src/main/java/com/pantheon/remoting/protocol/RemotingCommand.java:306
↓ 1 callersMethodisInitialized
()
pantheon-client/src/main/java/com/pantheon/client/appinfo/InstanceInfo.java:283
↓ 1 callersMethodisResponseType
()
pantheon-remoting/src/main/java/com/pantheon/remoting/protocol/RemotingCommand.java:461
↓ 1 callersMethodisSecure
()
pantheon-spring-cloud-netflix-client/src/main/java/com/pantheon/netflix/client/PantheonDiscoveryClient.java:113
↓ 1 callersMethodisSendRequestOK
()
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/ResponseFuture.java:86
↓ 1 callersMethodisServerPooledByteBufAllocatorEnable
()
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/NettyServerConfig.java:113
↓ 1 callersMethodisStopped
()
pantheon-remoting/src/main/java/com/pantheon/remoting/common/ServiceThread.java:80
↓ 1 callersMethodisUseEpollNativeSelector
()
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/NettyServerConfig.java:121
↓ 1 callersMethodisWritable
()
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/NettyRemotingClient.java:657
↓ 1 callersMethodload
(Key key)
pantheon-server/src/main/java/com/pantheon/server/registry/ResponseCacheImpl.java:68
↓ 1 callersMethodloadSslContext
()
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/NettyRemotingServer.java:160
↓ 1 callersMethodlocateServerBySlot
locate a server node id by slot @param slot @return
pantheon-client/src/main/java/com/pantheon/client/transport/ClientAPIImpl.java:193
↓ 1 callersMethodlogTheFinalUsedTlsConfig
()
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/TlsHelper.java:176
↓ 1 callersMethodlogTotalInstances
Logs the total number of non-filtered instances stored locally.
pantheon-client/src/main/java/com/pantheon/client/DiscoveryClientNode.java:380
↓ 1 callersMethodmakeCustomHeaderToNet
()
pantheon-remoting/src/main/java/com/pantheon/remoting/protocol/RemotingCommand.java:372
↓ 1 callersMethodmanageServerNetwork
(Boolean isControllerCandidate)
pantheon-server/src/main/java/com/pantheon/server/ServerNode.java:106
↓ 1 callersMethodmapDeserialize
(byte[] bytes)
pantheon-remoting/src/main/java/com/pantheon/remoting/protocol/PantheonSerializable.java:167
↓ 1 callersMethodmapSerialize
(HashMap<String, String> map)
pantheon-remoting/src/main/java/com/pantheon/remoting/protocol/PantheonSerializable.java:76
↓ 1 callersMethodmapToInstanceStatus
(Status status)
pantheon-spring-cloud-netflix-client/src/main/java/com/pantheon/netflix/client/PantheonHealthCheckHandler.java:80
↓ 1 callersMethodmarkOnewayRPC
()
pantheon-remoting/src/main/java/com/pantheon/remoting/protocol/RemotingCommand.java:433
↓ 1 callersMethodmaybeInitializeClient
(PantheonRegistration reg)
pantheon-spring-cloud-netflix-client/src/main/java/com/pantheon/netflix/client/serviceregistry/PantheonServiceRegistry.java:34
↓ 1 callersMethodmoveToClosed
()
pantheon-common/src/main/java/com/pantheon/common/lifecycle/Lifecycle.java:163
↓ 1 callersMethodmoveToStarted
()
pantheon-common/src/main/java/com/pantheon/common/lifecycle/Lifecycle.java:108
↓ 1 callersMethodmoveToStopped
()
pantheon-common/src/main/java/com/pantheon/common/lifecycle/Lifecycle.java:137
↓ 1 callersMethodonCacheRefreshed
Invoked every time the local registry cache is refreshed (whether changes have been detected or not). <p> Subclasses may override this method to imple
pantheon-client/src/main/java/com/pantheon/client/DiscoveryClientNode.java:396
↓ 1 callersMethodonChannelClose
(final String remoteAddr, final Channel channel)
pantheon-remoting/src/main/java/com/pantheon/remoting/ChannelEventListener.java:29
↓ 1 callersMethodonChannelConnect
(final String remoteAddr, final Channel channel)
pantheon-remoting/src/main/java/com/pantheon/remoting/ChannelEventListener.java:27
↓ 1 callersMethodonChannelException
(final String remoteAddr, final Channel channel)
pantheon-remoting/src/main/java/com/pantheon/remoting/ChannelEventListener.java:31
↓ 1 callersMethodonChannelIdle
(final String remoteAddr, final Channel channel)
pantheon-remoting/src/main/java/com/pantheon/remoting/ChannelEventListener.java:33
↓ 1 callersMethodonEvent
Notification of an event within the {@link DiscoveryClientNode}. {@link PantheonEventListener#onEvent} is called from the context of an internal pant
pantheon-client/src/main/java/com/pantheon/client/PantheonEventListener.java:16
↓ 1 callersMethodonRemoteStatusChanged
Invoked when the remote status of this client has changed. Subclasses may override this method to implement custom behavior if needed. @param oldStat
pantheon-client/src/main/java/com/pantheon/client/DiscoveryClientNode.java:655
↓ 1 callersMethodoperationComplete
(final ResponseFuture responseFuture)
pantheon-remoting/src/main/java/com/pantheon/remoting/InvokeCallback.java:27
↓ 1 callersMethodpantheonProtocolDecode
(final byte[] headerArray)
pantheon-remoting/src/main/java/com/pantheon/remoting/protocol/PantheonSerializable.java:136
↓ 1 callersMethodpantheonProtocolEncode
(RemotingCommand cmd)
pantheon-remoting/src/main/java/com/pantheon/remoting/protocol/PantheonSerializable.java:28
↓ 1 callersMethodparseClientAuthMode
(String authMode)
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/TlsHelper.java:193
↓ 1 callersMethodpersistReplicaNodeIds
()
pantheon-server/src/main/java/com/pantheon/server/node/Controller.java:228
↓ 1 callersMethodpersistSlotsAllocation
()
pantheon-server/src/main/java/com/pantheon/server/node/Controller.java:216
↓ 1 callersMethodpersistSlotsReplicaAllocation
()
pantheon-server/src/main/java/com/pantheon/server/node/Controller.java:222
↓ 1 callersMethodprepareSharableHandlers
()
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/NettyRemotingServer.java:351
↓ 1 callersMethodprocessRequestCommand
Process incoming request command issued by remote peer. @param ctx channel handler context. @param cmd request command.
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/NettyRemotingAbstract.java:192
↓ 1 callersMethodprocessResponseCommand
Process response from remote peer to the previous issued requests. @param ctx channel handler context. @param cmd response command instance.
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/NettyRemotingAbstract.java:287
↓ 1 callersMethodputSlot
(Integer slotNo, Slot slot)
pantheon-server/src/main/java/com/pantheon/server/slot/Slots.java:40
↓ 1 callersMethodreconcileAndLogDifference
Reconcile the pantheon server and client registry information and logs the differences if any. When reconciling, the following flow is observed: <p> 1
pantheon-client/src/main/java/com/pantheon/client/DiscoveryClientNode.java:557
↓ 1 callersMethodrefreshRegistry
()
pantheon-client/src/main/java/com/pantheon/client/DiscoveryClientNode.java:316
↓ 1 callersMethodrefreshReplicaNodeId
(Integer newReplicaNodeId)
pantheon-server/src/main/java/com/pantheon/server/slot/SlotManager.java:113
↓ 1 callersMethodregister
Registers information about a particular instance for an {@link Application}. @param info {@link InstanceInfo} information of the instance.
pantheon-server/src/main/java/com/pantheon/server/processor/ClientManageProcessor.java:215
↓ 1 callersMethodregisterConsumer
(final ClientChannelInfo clientChannelInfo, final Set<SubscriptionData> su
pantheon-server/src/main/java/com/pantheon/server/client/ConsumerInfoManager.java:177
↓ 1 callersMethodregisterDefaultProcessor
(final NettyRequestProcessor processor, final ExecutorService executor)
pantheon-remoting/src/main/java/com/pantheon/remoting/RemotingServer.java:39
↓ 1 callersMethodregisterEventListener
(PantheonEventListener var1)
pantheon-client/src/main/java/com/pantheon/client/discovery/DiscoveryClient.java:69
↓ 1 callersMethodregisterRPCHook
(RPCHook rpcHook)
pantheon-remoting/src/main/java/com/pantheon/remoting/RemotingService.java:30
↓ 1 callersMethodrejectRequest
()
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/NettyRequestProcessor.java:32
↓ 1 callersMethodremoveInstance
Remove the given instance info the list. @param i the instance info object to be removed.
pantheon-client/src/main/java/com/pantheon/client/appinfo/Application.java:75
↓ 1 callersMethodremoveServerNode
remove server node in memory @param remoteNodeId
pantheon-server/src/main/java/com/pantheon/server/node/RemoteServerNodeManager.java:63
↓ 1 callersMethodremoveSlot
(Integer slotNo)
pantheon-server/src/main/java/com/pantheon/server/slot/Slots.java:57
↓ 1 callersMethodrenew
Marks the given instance of the given app name as renewed, and also marks whether it originated from replication. @return error response when failed
pantheon-server/src/main/java/com/pantheon/server/registry/InstanceRegistryImpl.java:267
↓ 1 callersMethodrequestSlotsData
request slots data
pantheon-server/src/main/java/com/pantheon/server/node/ControllerCandidate.java:270
↓ 1 callersMethodreset
()
pantheon-common/src/main/java/com/pantheon/common/CountDownLatch2.java:126
↓ 1 callersMethodrouteSlot
route server to a specific slot @return
pantheon-client/src/main/java/com/pantheon/client/transport/ClientAPIImpl.java:175
↓ 1 callersMethodrun
()
pantheon-spring-cloud-netflix-client/src/main/java/com/pantheon/netflix/client/loadbalancer/PantheonNotificationServerListUpdater.java:76
↓ 1 callersMethodscanExceptionChannel
()
pantheon-server/src/main/java/com/pantheon/server/client/ClientHousekeepingService.java:40
↓ 1 callersMethodscanNotActiveChannel
()
pantheon-server/src/main/java/com/pantheon/server/client/ConsumerInfoManager.java:76
↓ 1 callersMethodsecond
()
pantheon-client/src/main/java/com/pantheon/client/utils/Pair.java:17
↓ 1 callersMethodsendHeartBeatToServer
(final Server server, String appName, String id, final Long timoutMills)
pantheon-client/src/main/java/com/pantheon/client/transport/ClientAPIImpl.java:224
↓ 1 callersMethodsendHeartbeat
()
pantheon-client/src/main/java/com/pantheon/client/DiscoveryClientNode.java:182
↓ 1 callersMethodsendNodeSlots
()
pantheon-server/src/main/java/com/pantheon/server/node/Controller.java:371
↓ 1 callersMethodsendRegister
default 30s to refresh registry info
pantheon-client/src/main/java/com/pantheon/client/DiscoveryClientNode.java:226
↓ 1 callersMethodserviceRegistry
(ChannelHandlerContext ctx, RemotingCommand request)
pantheon-server/src/main/java/com/pantheon/server/processor/ClientManageProcessor.java:137
↓ 1 callersMethodserviceUnregister
(ChannelHandlerContext ctx, RemotingCommand request)
pantheon-server/src/main/java/com/pantheon/server/processor/ClientManageProcessor.java:99
↓ 1 callersMethodsetCause
(Throwable cause)
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/ResponseFuture.java:106
↓ 1 callersMethodsetClientId
(String clientId)
pantheon-common/src/main/java/com/pantheon/common/protocol/header/GetConsumerRunningInfoRequestHeader.java:25
↓ 1 callersMethodsetEvictionTimestamp
Sets the de-registration timestamp. @param ts time when the lease was removed. @return the {@link LeaseInfo} builder.
pantheon-client/src/main/java/com/pantheon/client/appinfo/LeaseInfo.java:68
↓ 1 callersMethodsetFlag
(int flag)
pantheon-remoting/src/main/java/com/pantheon/remoting/protocol/RemotingCommand.java:495
↓ 1 callersMethodsetId
(String id)
pantheon-spring-cloud-netflix-client/src/main/java/com/pantheon/netflix/client/ribbon/DomainExtractingServer.java:19
↓ 1 callersMethodsetInstancePort
(Integer port)
pantheon-client/src/main/java/com/pantheon/client/config/PantheonInstanceConfig.java:43
↓ 1 callersMethodsetInstanceStatus
(InstanceStatus instanceStatus)
pantheon-client/src/main/java/com/pantheon/client/appinfo/InstanceInfo.java:314
↓ 1 callersMethodsetLanguage
(LanguageCode language)
pantheon-remoting/src/main/java/com/pantheon/remoting/protocol/RemotingCommand.java:471
↓ 1 callersMethodsetLastUpdateTimestamp
(long lastUpdateTimestamp)
pantheon-server/src/main/java/com/pantheon/server/client/ClientChannelInfo.java:63
↓ 1 callersMethodsetLatestHeartbeatTime
(Long latestHeartbeatTime)
pantheon-server/src/main/java/com/pantheon/server/slot/registry/ServiceInstance.java:51
↓ 1 callersMethodsetListenPort
(int listenPort)
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/NettyServerConfig.java:45
↓ 1 callersMethodsetNonSecurePort
(int port)
pantheon-spring-cloud-netflix-client/src/main/java/com/pantheon/netflix/client/serviceregistry/PantheonRegistration.java:92
↓ 1 callersMethodsetRegistrationTimestamp
Sets the registration timestamp. @param ts time when the lease was first registered. @return the {@link LeaseInfo} builder.
pantheon-client/src/main/java/com/pantheon/client/appinfo/LeaseInfo.java:44
↓ 1 callersMethodsetRenewalTimestamp
Sets the last renewal timestamp of lease. @param ts time when the lease was last renewed. @return the {@link LeaseInfo} builder.
pantheon-client/src/main/java/com/pantheon/client/appinfo/LeaseInfo.java:56
↓ 1 callersMethodsetResponseCommand
(RemotingCommand responseCommand)
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/ResponseFuture.java:114
↓ 1 callersMethodsetServerNodeId
(Integer serverNodeId)
pantheon-common/src/main/java/com/pantheon/common/protocol/header/GetServerNodeIdResponseHeader.java:40
↓ 1 callersMethodsetServerRole
(ServerNodeRole serverNodeRole)
pantheon-server/src/main/java/com/pantheon/server/ServerNode.java:228
↓ 1 callersMethodsetStatus
(PantheonRegistration registration, String status)
pantheon-spring-cloud-netflix-client/src/main/java/com/pantheon/netflix/client/serviceregistry/PantheonServiceRegistry.java:50
↓ 1 callersMethodsetStatus
Set the status for this instance. @param status status for this instance. @return the prev status if a different status from the current was set, nul
pantheon-client/src/main/java/com/pantheon/client/appinfo/InstanceInfo.java:513
↓ 1 callersMethodshuffleAndStoreInstances
Shuffles the list of instances in the application and stores it for future retrievals. @param filterUpInstances indicates whether only the
pantheon-client/src/main/java/com/pantheon/client/appinfo/Application.java:156
↓ 1 callersMethodstart
()
pantheon-spring-cloud-netflix-client/src/main/java/com/pantheon/netflix/client/serviceregistry/PantheonAutoServiceRegistration.java:38
↓ 1 callersMethodstartNettyClientServer
()
pantheon-server/src/main/java/com/pantheon/server/ServerNode.java:87
↓ 1 callersMethodstartScheduledTask
()
pantheon-client/src/main/java/com/pantheon/client/DiscoveryClientNode.java:160
↓ 1 callersMethodstartScheduledTask
()
pantheon-server/src/main/java/com/pantheon/server/ServerNode.java:165
↓ 1 callersMethodstartServerConnectionListener
connect server listener
pantheon-server/src/main/java/com/pantheon/server/network/ServerNetworkManager.java:104
↓ 1 callersMethodstartServerNode
()
pantheon-server/src/main/java/com/pantheon/server/ServerBootstrap.java:30
↓ 1 callersMethodstarted
Returns {@code true} if the state is started.
pantheon-common/src/main/java/com/pantheon/common/lifecycle/Lifecycle.java:70
← previousnext →501–600 of 1,226, ranked by callers