@author Anthony @create 2021/11/17 @desc An abstract instance info configuration with some DEFAULT VALUE to get the users started quickly.The users ha

This rule matches always and returns the current status of the instance.

@author Anthony @create 2021/11/28 @desc The Application class holds the list of instances for a particular application.

@author Anthony @create 2021/11/28 @desc The class that wraps all the registry information returned by Pantheon server. <p> Note that the registry in

This is an INTERNAL class not for public use.

@author Anthony @create 2021/11/17 @desc A default implementation of Pantheon Server configuration as required by {@link PantheonServerConfig}. <p> Th

@author Anthony @create 2021/11/17 @desc add async support with {@link RemotingResponseCallback}on {@link NettyRequestProcessor}

@author Anthony @create 2021/12/17 @desc

The task that fetches the registry information at specified intervals.

@author Anthony @create 2021/12/20 @desc

@author Anthony @create 2021/11/20 @desc

@author Anthony @create 2021/11/17 @desc subscribe to this listener to get notified when channel event triggered

@author Anthony @create 2021/11/27 @desc wrapper class for netty request and response

@author Anthony @create 2021/11/17 @desc

对于每一个客户端，会根据clientID和连接对象Channel关联到一个ClientChannelInfo，用于标识该客户端实例。

@author Anthony @create 2021/11/19 @desc process the connection between client and server

@author Anthony @create 2021/12/5 @desc singleton to manage all clients

@author Anthony @create 2021/11/27 @desc

@author Anthony @create 2021/11/17 @desc

Controller node

Controller candidate node

Add reset feature for @see java.util.concurrent.CountDownLatch

@author Anthony @create 2021/11/17 @desc

@author Anthony @create 2021/12/20 @desc The Default NIWS Filter - deals with filtering out servers based on the Zone affinity and other related prope

@author Anthony @create 2021/11/19 @desc todo load specific instances not all todo throw PantheonException

@author Anthony @create 2021/12/20 @desc The server list class that fetches the server information from Pantheon client. ServerList is used by {@link

@author Anthony @create 2021/12/20 @desc Servers that were obtained via Discovery and hence contain meta data in the form of InstanceInfo

@author Anthony @create 2021/12/20 @desc

@author Anthony @create 2021/12/20 @desc {@link #getInitialListOfServers()} and {@link #getUpdatedListOfServers()} use {@link DiscoveryEnabledNIWSSer

This rule matches if the instance is DOWN or STARTING.

extends from MessageToByteEncoder <p> By default, file region are directly transferred to socket channel which is known as zero copy. In case we n

This rule takes an ordered list of rules and returns the result of the first match or the result of the {@link AlwaysMatchInstanceStatusRule}.

@author Anthony @create 2021/12/17 @desc

locate a instance with a appName and instanceId

@author Anthony @create 2022/1/5 @desc The heartbeat sender which is responsible for sending heartbeat to remote server periodically per interval.

heartbeat check

io thread running signal

@author Anthony @create 2021/11/28 @desc The class that holds information required for registration

@author Anthony @create 2021/12/16 @desc

@author Anthony @create 2021/11/28 @desc the class that load and update data from Server Side cache

@author Anthony @create 2021/11/28 @desc the class that load and update data from Server Side cache

A single rule that if matched it returns an instance status. The idea is to use an ordered list of such rules and pick the first result that matches.

@author Anthony @create 2021/11/17 @desc used for async message

@author Anthony @create 2021/11/30 @desc

Describes a time-based availability of a {@link T}. If a lease elapses without renewals, it will eventually expire consequently marking the associate

This rule matches if we have an existing lease for the instance that is UP or OUT_OF_SERVICE.

@author Anthony @create 2021/11/28 @desc Represents the <em>lease</em> information with <em>Pantheon</em>.

This class is responsible for creating/renewing and evicting a <em>lease</em> for a particular instance. <p> Leases determine what instances receive

@author Anthony @create 2021/12/20 @desc

Lifecycle state. Allows the following transitions: <ul> <li>INITIALIZED -&gt; STARTED, STOPPED, CLOSED</li> <li>STARTED -&gt; STOPPED</li> <li>STO

基础消息接口

@author Anthony @create 2021/12/20 @desc "Ping" Discovery Client i.e. we dont do a real "ping". We just assume that the server is up if Discovery Clie

put netty event in a LinkedBlockingQueue and invoke correspondent listener

use {@link ChannelEventListener} listen to Netty event({@link NettyEventType}) ,{@link NettyEventExecutor#putNettyEvent(NettyEvent)} is required for t