naming_grpc

package
v1.2.4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 27, 2023 License: MIT Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ConnectionEventListener 

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

func NewConnectionEventListener 

func NewConnectionEventListener(clientProxy naming_proxy2.INamingProxy) *ConnectionEventListener

func (*ConnectionEventListener) CacheInstanceForRedo 

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

func (*ConnectionEventListener) CacheSubscriberForRedo 

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

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 model2.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(clientCfg constant2.ClientConfig, nacosServer *nacos_server2.NacosServer,
	serviceInfoHolder *naming_cache2.ServiceInfoHolder) (*NamingGrpcProxy, error)

NewNamingGrpcProxy create naming grpc proxy

func (*NamingGrpcProxy) CloseClient 

func (proxy *NamingGrpcProxy) CloseClient()

func (*NamingGrpcProxy) DeregisterInstance 

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

DeregisterInstance ...

func (*NamingGrpcProxy) GetServiceList 

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

GetServiceList ...

func (*NamingGrpcProxy) QueryInstancesOfService 

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

QueryInstancesOfService ...

func (*NamingGrpcProxy) RegisterInstance 

func (proxy *NamingGrpcProxy) RegisterInstance(serviceName string, groupName string, instance model2.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) (model2.Service, error)

Subscribe ...

func (*NamingGrpcProxy) Unsubscribe 

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

Unsubscribe ...

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.