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
↓ 1 callers
Method
isAlive
(Server server)
pantheon-spring-cloud-netflix-client/src/main/java/com/pantheon/netflix/client/loadbalancer/NIWSDiscoveryPing.java:28
↓ 1 callers
Method
isBlank
(String str)
pantheon-remoting/src/main/java/com/pantheon/remoting/protocol/RemotingCommand.java:197
↓ 1 callers
Method
isClientCloseSocketIfTimeout
()
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/NettyClientConfig.java:43
↓ 1 callers
Method
isDaemon
()
pantheon-common/src/main/java/com/pantheon/common/ServiceThread.java:144
↓ 1 callers
Method
isExpired
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 callers
Method
isFieldNullable
(Field field)
pantheon-remoting/src/main/java/com/pantheon/remoting/protocol/RemotingCommand.java:306
↓ 1 callers
Method
isInitialized
()
pantheon-client/src/main/java/com/pantheon/client/appinfo/InstanceInfo.java:283
↓ 1 callers
Method
isResponseType
()
pantheon-remoting/src/main/java/com/pantheon/remoting/protocol/RemotingCommand.java:461
↓ 1 callers
Method
isSecure
()
pantheon-spring-cloud-netflix-client/src/main/java/com/pantheon/netflix/client/PantheonDiscoveryClient.java:113
↓ 1 callers
Method
isSendRequestOK
()
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/ResponseFuture.java:86
↓ 1 callers
Method
isServerPooledByteBufAllocatorEnable
()
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/NettyServerConfig.java:113
↓ 1 callers
Method
isStopped
()
pantheon-remoting/src/main/java/com/pantheon/remoting/common/ServiceThread.java:80
↓ 1 callers
Method
isUseEpollNativeSelector
()
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/NettyServerConfig.java:121
↓ 1 callers
Method
isWritable
()
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/NettyRemotingClient.java:657
↓ 1 callers
Method
load
(Key key)
pantheon-server/src/main/java/com/pantheon/server/registry/ResponseCacheImpl.java:68
↓ 1 callers
Method
loadSslContext
()
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/NettyRemotingServer.java:160
↓ 1 callers
Method
locateServerBySlot
locate a server node id by slot @param slot @return
pantheon-client/src/main/java/com/pantheon/client/transport/ClientAPIImpl.java:193
↓ 1 callers
Method
logTheFinalUsedTlsConfig
()
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/TlsHelper.java:176
↓ 1 callers
Method
logTotalInstances
Logs the total number of non-filtered instances stored locally.
pantheon-client/src/main/java/com/pantheon/client/DiscoveryClientNode.java:380
↓ 1 callers
Method
makeCustomHeaderToNet
()
pantheon-remoting/src/main/java/com/pantheon/remoting/protocol/RemotingCommand.java:372
↓ 1 callers
Method
manageServerNetwork
(Boolean isControllerCandidate)
pantheon-server/src/main/java/com/pantheon/server/ServerNode.java:106
↓ 1 callers
Method
mapDeserialize
(byte[] bytes)
pantheon-remoting/src/main/java/com/pantheon/remoting/protocol/PantheonSerializable.java:167
↓ 1 callers
Method
mapSerialize
(HashMap<String, String> map)
pantheon-remoting/src/main/java/com/pantheon/remoting/protocol/PantheonSerializable.java:76
↓ 1 callers
Method
mapToInstanceStatus
(Status status)
pantheon-spring-cloud-netflix-client/src/main/java/com/pantheon/netflix/client/PantheonHealthCheckHandler.java:80
↓ 1 callers
Method
markOnewayRPC
()
pantheon-remoting/src/main/java/com/pantheon/remoting/protocol/RemotingCommand.java:433
↓ 1 callers
Method
maybeInitializeClient
(PantheonRegistration reg)
pantheon-spring-cloud-netflix-client/src/main/java/com/pantheon/netflix/client/serviceregistry/PantheonServiceRegistry.java:34
↓ 1 callers
Method
moveToClosed
()
pantheon-common/src/main/java/com/pantheon/common/lifecycle/Lifecycle.java:163
↓ 1 callers
Method
moveToStarted
()
pantheon-common/src/main/java/com/pantheon/common/lifecycle/Lifecycle.java:108
↓ 1 callers
Method
moveToStopped
()
pantheon-common/src/main/java/com/pantheon/common/lifecycle/Lifecycle.java:137
↓ 1 callers
Method
onCacheRefreshed
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 callers
Method
onChannelClose
(final String remoteAddr, final Channel channel)
pantheon-remoting/src/main/java/com/pantheon/remoting/ChannelEventListener.java:29
↓ 1 callers
Method
onChannelConnect
(final String remoteAddr, final Channel channel)
pantheon-remoting/src/main/java/com/pantheon/remoting/ChannelEventListener.java:27
↓ 1 callers
Method
onChannelException
(final String remoteAddr, final Channel channel)
pantheon-remoting/src/main/java/com/pantheon/remoting/ChannelEventListener.java:31
↓ 1 callers
Method
onChannelIdle
(final String remoteAddr, final Channel channel)
pantheon-remoting/src/main/java/com/pantheon/remoting/ChannelEventListener.java:33
↓ 1 callers
Method
onEvent
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 callers
Method
onRemoteStatusChanged
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 callers
Method
operationComplete
(final ResponseFuture responseFuture)
pantheon-remoting/src/main/java/com/pantheon/remoting/InvokeCallback.java:27
↓ 1 callers
Method
pantheonProtocolDecode
(final byte[] headerArray)
pantheon-remoting/src/main/java/com/pantheon/remoting/protocol/PantheonSerializable.java:136
↓ 1 callers
Method
pantheonProtocolEncode
(RemotingCommand cmd)
pantheon-remoting/src/main/java/com/pantheon/remoting/protocol/PantheonSerializable.java:28
↓ 1 callers
Method
parseClientAuthMode
(String authMode)
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/TlsHelper.java:193
↓ 1 callers
Method
persistReplicaNodeIds
()
pantheon-server/src/main/java/com/pantheon/server/node/Controller.java:228
↓ 1 callers
Method
persistSlotsAllocation
()
pantheon-server/src/main/java/com/pantheon/server/node/Controller.java:216
↓ 1 callers
Method
persistSlotsReplicaAllocation
()
pantheon-server/src/main/java/com/pantheon/server/node/Controller.java:222
↓ 1 callers
Method
prepareSharableHandlers
()
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/NettyRemotingServer.java:351
↓ 1 callers
Method
processRequestCommand
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 callers
Method
processResponseCommand
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 callers
Method
putSlot
(Integer slotNo, Slot slot)
pantheon-server/src/main/java/com/pantheon/server/slot/Slots.java:40
↓ 1 callers
Method
reconcileAndLogDifference
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 callers
Method
refreshRegistry
()
pantheon-client/src/main/java/com/pantheon/client/DiscoveryClientNode.java:316
↓ 1 callers
Method
refreshReplicaNodeId
(Integer newReplicaNodeId)
pantheon-server/src/main/java/com/pantheon/server/slot/SlotManager.java:113
↓ 1 callers
Method
register
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 callers
Method
registerConsumer
(final ClientChannelInfo clientChannelInfo, final Set<SubscriptionData> su
pantheon-server/src/main/java/com/pantheon/server/client/ConsumerInfoManager.java:177
↓ 1 callers
Method
registerDefaultProcessor
(final NettyRequestProcessor processor, final ExecutorService executor)
pantheon-remoting/src/main/java/com/pantheon/remoting/RemotingServer.java:39
↓ 1 callers
Method
registerEventListener
(PantheonEventListener var1)
pantheon-client/src/main/java/com/pantheon/client/discovery/DiscoveryClient.java:69
↓ 1 callers
Method
registerRPCHook
(RPCHook rpcHook)
pantheon-remoting/src/main/java/com/pantheon/remoting/RemotingService.java:30
↓ 1 callers
Method
rejectRequest
()
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/NettyRequestProcessor.java:32
↓ 1 callers
Method
removeInstance
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 callers
Method
removeServerNode
remove server node in memory @param remoteNodeId
pantheon-server/src/main/java/com/pantheon/server/node/RemoteServerNodeManager.java:63
↓ 1 callers
Method
removeSlot
(Integer slotNo)
pantheon-server/src/main/java/com/pantheon/server/slot/Slots.java:57
↓ 1 callers
Method
renew
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 callers
Method
requestSlotsData
request slots data
pantheon-server/src/main/java/com/pantheon/server/node/ControllerCandidate.java:270
↓ 1 callers
Method
reset
()
pantheon-common/src/main/java/com/pantheon/common/CountDownLatch2.java:126
↓ 1 callers
Method
routeSlot
route server to a specific slot @return
pantheon-client/src/main/java/com/pantheon/client/transport/ClientAPIImpl.java:175
↓ 1 callers
Method
run
()
pantheon-spring-cloud-netflix-client/src/main/java/com/pantheon/netflix/client/loadbalancer/PantheonNotificationServerListUpdater.java:76
↓ 1 callers
Method
scanExceptionChannel
()
pantheon-server/src/main/java/com/pantheon/server/client/ClientHousekeepingService.java:40
↓ 1 callers
Method
scanNotActiveChannel
()
pantheon-server/src/main/java/com/pantheon/server/client/ConsumerInfoManager.java:76
↓ 1 callers
Method
second
()
pantheon-client/src/main/java/com/pantheon/client/utils/Pair.java:17
↓ 1 callers
Method
sendHeartBeatToServer
(final Server server, String appName, String id, final Long timoutMills)
pantheon-client/src/main/java/com/pantheon/client/transport/ClientAPIImpl.java:224
↓ 1 callers
Method
sendHeartbeat
()
pantheon-client/src/main/java/com/pantheon/client/DiscoveryClientNode.java:182
↓ 1 callers
Method
sendNodeSlots
()
pantheon-server/src/main/java/com/pantheon/server/node/Controller.java:371
↓ 1 callers
Method
sendRegister
default 30s to refresh registry info
pantheon-client/src/main/java/com/pantheon/client/DiscoveryClientNode.java:226
↓ 1 callers
Method
serviceRegistry
(ChannelHandlerContext ctx, RemotingCommand request)
pantheon-server/src/main/java/com/pantheon/server/processor/ClientManageProcessor.java:137
↓ 1 callers
Method
serviceUnregister
(ChannelHandlerContext ctx, RemotingCommand request)
pantheon-server/src/main/java/com/pantheon/server/processor/ClientManageProcessor.java:99
↓ 1 callers
Method
setCause
(Throwable cause)
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/ResponseFuture.java:106
↓ 1 callers
Method
setClientId
(String clientId)
pantheon-common/src/main/java/com/pantheon/common/protocol/header/GetConsumerRunningInfoRequestHeader.java:25
↓ 1 callers
Method
setEvictionTimestamp
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 callers
Method
setFlag
(int flag)
pantheon-remoting/src/main/java/com/pantheon/remoting/protocol/RemotingCommand.java:495
↓ 1 callers
Method
setId
(String id)
pantheon-spring-cloud-netflix-client/src/main/java/com/pantheon/netflix/client/ribbon/DomainExtractingServer.java:19
↓ 1 callers
Method
setInstancePort
(Integer port)
pantheon-client/src/main/java/com/pantheon/client/config/PantheonInstanceConfig.java:43
↓ 1 callers
Method
setInstanceStatus
(InstanceStatus instanceStatus)
pantheon-client/src/main/java/com/pantheon/client/appinfo/InstanceInfo.java:314
↓ 1 callers
Method
setLanguage
(LanguageCode language)
pantheon-remoting/src/main/java/com/pantheon/remoting/protocol/RemotingCommand.java:471
↓ 1 callers
Method
setLastUpdateTimestamp
(long lastUpdateTimestamp)
pantheon-server/src/main/java/com/pantheon/server/client/ClientChannelInfo.java:63
↓ 1 callers
Method
setLatestHeartbeatTime
(Long latestHeartbeatTime)
pantheon-server/src/main/java/com/pantheon/server/slot/registry/ServiceInstance.java:51
↓ 1 callers
Method
setListenPort
(int listenPort)
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/NettyServerConfig.java:45
↓ 1 callers
Method
setNonSecurePort
(int port)
pantheon-spring-cloud-netflix-client/src/main/java/com/pantheon/netflix/client/serviceregistry/PantheonRegistration.java:92
↓ 1 callers
Method
setRegistrationTimestamp
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 callers
Method
setRenewalTimestamp
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 callers
Method
setResponseCommand
(RemotingCommand responseCommand)
pantheon-remoting/src/main/java/com/pantheon/remoting/netty/ResponseFuture.java:114
↓ 1 callers
Method
setServerNodeId
(Integer serverNodeId)
pantheon-common/src/main/java/com/pantheon/common/protocol/header/GetServerNodeIdResponseHeader.java:40
↓ 1 callers
Method
setServerRole
(ServerNodeRole serverNodeRole)
pantheon-server/src/main/java/com/pantheon/server/ServerNode.java:228
↓ 1 callers
Method
setStatus
(PantheonRegistration registration, String status)
pantheon-spring-cloud-netflix-client/src/main/java/com/pantheon/netflix/client/serviceregistry/PantheonServiceRegistry.java:50
↓ 1 callers
Method
setStatus
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 callers
Method
shuffleAndStoreInstances
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 callers
Method
start
()
pantheon-spring-cloud-netflix-client/src/main/java/com/pantheon/netflix/client/serviceregistry/PantheonAutoServiceRegistration.java:38
↓ 1 callers
Method
startNettyClientServer
()
pantheon-server/src/main/java/com/pantheon/server/ServerNode.java:87
↓ 1 callers
Method
startScheduledTask
()
pantheon-client/src/main/java/com/pantheon/client/DiscoveryClientNode.java:160
↓ 1 callers
Method
startScheduledTask
()
pantheon-server/src/main/java/com/pantheon/server/ServerNode.java:165
↓ 1 callers
Method
startServerConnectionListener
connect server listener
pantheon-server/src/main/java/com/pantheon/server/network/ServerNetworkManager.java:104
↓ 1 callers
Method
startServerNode
()
pantheon-server/src/main/java/com/pantheon/server/ServerBootstrap.java:30
↓ 1 callers
Method
started
Returns {@code true} if the state is started.
pantheon-common/src/main/java/com/pantheon/common/lifecycle/Lifecycle.java:70
← previous
next →
501–600 of 1,226, ranked by callers