Versions in this module Expand all Collapse all v1 v1.99.1 Mar 16, 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 constant.ClientConfig, nacosServer *nacos_server.NacosServer) BeatReactor + func (br *BeatReactor) AddBeatInfo(serviceName string, beatInfo *model.BeatInfo) + func (br *BeatReactor) RemoveBeatInfo(serviceName string, ip string, port uint64) + func (br *BeatReactor) SendBeat(info *model.BeatInfo) (int64, error) + type NamingHttpProxy struct + func NewNamingHttpProxy(clientCfg constant.ClientConfig, nacosServer *nacos_server.NacosServer, ...) (*NamingHttpProxy, error) + func (proxy *NamingHttpProxy) CloseClient() + func (proxy *NamingHttpProxy) DeregisterInstance(serviceName string, groupName string, instance model.Instance) (bool, error) + func (proxy *NamingHttpProxy) GetServiceList(pageNo uint32, pageSize uint32, groupName string, ...) (model.ServiceList, error) + func (proxy *NamingHttpProxy) QueryInstancesOfService(serviceName, groupName, clusters string, udpPort int, healthyOnly bool) (*model.Service, error) + func (proxy *NamingHttpProxy) RegisterInstance(serviceName string, groupName string, instance model.Instance) (bool, error) + func (proxy *NamingHttpProxy) ServerHealthy() bool + func (proxy *NamingHttpProxy) Subscribe(serviceName, groupName, clusters string) (model.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_cache.ServiceInfoHolder) *PushReceiver Other modules containing this package github.com/EricLi404/nacos-sdk-go/v2
Go to main page