naming_grpc

Documentation

Index

• type ConnectionEventListener
  • func NewConnectionEventListener(clientProxy naming_proxy.INamingProxy) *ConnectionEventListener
  • func (c *ConnectionEventListener) CacheInstanceForRedo(serviceName, groupName string, instance model.Instance)
  • func (c *ConnectionEventListener) CacheInstancesForRedo(serviceName, groupName string, instances []model.Instance)
  • func (c *ConnectionEventListener) CacheSubscriberForRedo(fullServiceName, clusters string)
  • func (c *ConnectionEventListener) IsSubscriberCached(key string) bool
  • func (c *ConnectionEventListener) OnConnected()
  • func (c *ConnectionEventListener) OnDisConnect()
  • func (c *ConnectionEventListener) RemoveInstanceForRedo(serviceName, groupName string, instance model.Instance)
  • func (c *ConnectionEventListener) RemoveSubscriberForRedo(fullServiceName, clusters string)
• type NamingGrpcProxy
  • func NewNamingGrpcProxy(ctx context.Context, clientCfg constant.ClientConfig, ...) (*NamingGrpcProxy, error)
  • func (proxy *NamingGrpcProxy) BatchRegisterInstance(serviceName string, groupName string, instances []model.Instance) (bool, error)
  • func (proxy *NamingGrpcProxy) CloseClient()
  • func (proxy *NamingGrpcProxy) DeregisterInstance(serviceName string, groupName string, instance model.Instance) (bool, error)
  • func (proxy *NamingGrpcProxy) GetServiceList(pageNo uint32, pageSize uint32, groupName, namespaceId string, ...) (model.ServiceList, error)
  • func (proxy *NamingGrpcProxy) IsSubscribed(serviceName, groupName string, clusters string) bool
  • func (proxy *NamingGrpcProxy) QueryInstancesOfService(serviceName, groupName, cluster string, udpPort int, healthyOnly bool) (*model.Service, error)
  • func (proxy *NamingGrpcProxy) RegisterInstance(serviceName string, groupName string, instance model.Instance) (bool, error)
  • func (proxy *NamingGrpcProxy) ServerHealthy() bool
  • func (proxy *NamingGrpcProxy) Subscribe(serviceName, groupName string, clusters string) (model.Service, error)
  • func (proxy *NamingGrpcProxy) Unsubscribe(serviceName, groupName, clusters string) error

Types

type ConnectionEventListener

type ConnectionEventListener struct {
	// contains filtered or unexported fields
}

func NewConnectionEventListener

func NewConnectionEventListener(clientProxy naming_proxy.INamingProxy) *ConnectionEventListener

func (*ConnectionEventListener) CacheInstanceForRedo

func (c *ConnectionEventListener) CacheInstanceForRedo(serviceName, groupName string, instance model.Instance)

func (*ConnectionEventListener) CacheInstancesForRedo

func (c *ConnectionEventListener) CacheInstancesForRedo(serviceName, groupName string, instances []model.Instance)

func (*ConnectionEventListener) CacheSubscriberForRedo

func (c *ConnectionEventListener) CacheSubscriberForRedo(fullServiceName, clusters string)

func (*ConnectionEventListener) IsSubscriberCached

func (c *ConnectionEventListener) IsSubscriberCached(key string) bool

func (*ConnectionEventListener) OnConnected

func (c *ConnectionEventListener) OnConnected()

func (*ConnectionEventListener) OnDisConnect

func (c *ConnectionEventListener) OnDisConnect()

func (*ConnectionEventListener) RemoveInstanceForRedo

func (c *ConnectionEventListener) RemoveInstanceForRedo(serviceName, groupName string, instance model.Instance)

func (*ConnectionEventListener) RemoveSubscriberForRedo

func (c *ConnectionEventListener) RemoveSubscriberForRedo(fullServiceName, clusters string)

type NamingGrpcProxy

type NamingGrpcProxy struct {
	// contains filtered or unexported fields
}

NamingGrpcProxy ...

func NewNamingGrpcProxy

func NewNamingGrpcProxy(ctx context.Context, clientCfg constant.ClientConfig, nacosServer *nacos_server.NacosServer,
	serviceInfoHolder *naming_cache.ServiceInfoHolder) (*NamingGrpcProxy, error)

NewNamingGrpcProxy create naming grpc proxy

func (*NamingGrpcProxy) BatchRegisterInstance

func (proxy *NamingGrpcProxy) BatchRegisterInstance(serviceName string, groupName string, instances []model.Instance) (bool, error)

BatchRegisterInstance ...

func (*NamingGrpcProxy) CloseClient

func (proxy *NamingGrpcProxy) CloseClient()

func (*NamingGrpcProxy) DeregisterInstance

func (proxy *NamingGrpcProxy) DeregisterInstance(serviceName string, groupName string, instance model.Instance) (bool, error)

DeregisterInstance ...

func (*NamingGrpcProxy) GetServiceList

func (proxy *NamingGrpcProxy) GetServiceList(pageNo uint32, pageSize uint32, groupName, namespaceId string, selector *model.ExpressionSelector) (model.ServiceList, error)

GetServiceList ...

func (*NamingGrpcProxy) IsSubscribed

func (proxy *NamingGrpcProxy) IsSubscribed(serviceName, groupName string, clusters string) bool

func (*NamingGrpcProxy) QueryInstancesOfService

func (proxy *NamingGrpcProxy) QueryInstancesOfService(serviceName, groupName, cluster string, udpPort int, healthyOnly bool) (*model.Service, error)

QueryInstancesOfService ...

func (*NamingGrpcProxy) RegisterInstance

func (proxy *NamingGrpcProxy) RegisterInstance(serviceName string, groupName string, instance model.Instance) (bool, error)

RegisterInstance ...

func (*NamingGrpcProxy) ServerHealthy

func (proxy *NamingGrpcProxy) ServerHealthy() bool

ServerHealthy ...

func (*NamingGrpcProxy) Subscribe

func (proxy *NamingGrpcProxy) Subscribe(serviceName, groupName string, clusters string) (model.Service, error)

Subscribe ...

func (*NamingGrpcProxy) Unsubscribe

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

Unsubscribe ...