naming_http

Jul 27, 2022

Changes in this version

+ const DefaultBeatThreadNum

+ var GZIP_MAGIC = []byte("\x1F\x8B")

+ func IsGzipFile(data []byte) bool

+ func TryDecompressData(data []byte) string

+ type BeatReactor struct

+ func NewBeatReactor(clientCfg constant2.ClientConfig, nacosServer *nacos_server2.NacosServer) BeatReactor

+ func (br *BeatReactor) AddBeatInfo(serviceName string, beatInfo *model2.BeatInfo)

+ func (br *BeatReactor) RemoveBeatInfo(serviceName string, ip string, port uint64)

+ func (br *BeatReactor) SendBeat(info *model2.BeatInfo) (int64, error)

+ type NamingHttpProxy struct

+ func NewNamingHttpProxy(clientCfg constant2.ClientConfig, nacosServer *nacos_server2.NacosServer, ...) (*NamingHttpProxy, error)

+ func (proxy *NamingHttpProxy) CloseClient()

+ func (proxy *NamingHttpProxy) DeregisterInstance(serviceName string, groupName string, instance model2.Instance) (bool, error)

+ func (proxy *NamingHttpProxy) GetServiceList(pageNo uint32, pageSize uint32, groupName string, ...) (model2.ServiceList, error)

+ func (proxy *NamingHttpProxy) QueryInstancesOfService(serviceName, groupName, clusters string, udpPort int, healthyOnly bool) (*model2.Service, error)

+ func (proxy *NamingHttpProxy) RegisterInstance(serviceName string, groupName string, instance model2.Instance) (bool, error)

+ func (proxy *NamingHttpProxy) ServerHealthy() bool

+ func (proxy *NamingHttpProxy) Subscribe(serviceName, groupName, clusters string) (model2.Service, error)

+ func (proxy *NamingHttpProxy) Unsubscribe(serviceName, groupName, clusters string) error

+ type PushData struct

+ Data string

+ LastRefTime int64

+ PushType string

+ type PushReceiver struct

+ func NewPushReceiver(serviceInfoHolder *naming_cache2.ServiceInfoHolder) *PushReceiver