Versions in this module Expand all Collapse all v2 v2.1.1 Oct 12, 2022 Changes in this version + type INamingProxy interface + CloseClient func() + DeregisterInstance func(serviceName string, groupName string, instance model.Instance) (bool, error) + GetServiceList func(pageNo uint32, pageSize uint32, groupName, namespaceId string, ...) (model.ServiceList, error) + QueryInstancesOfService func(serviceName, groupName, clusters string, udpPort int, healthyOnly bool) (*model.Service, error) + RegisterInstance func(serviceName string, groupName string, instance model.Instance) (bool, error) + ServerHealthy func() bool + Subscribe func(serviceName, groupName, clusters string) (model.Service, error) + Unsubscribe func(serviceName, groupName, clusters string) error + type MockINamingProxy struct + func NewMockINamingProxy(ctrl *gomock.Controller) *MockINamingProxy + func (m *MockINamingProxy) CloseClient() + func (m *MockINamingProxy) DeregisterInstance(serviceName, groupName string, instance model.Instance) (bool, error) + func (m *MockINamingProxy) EXPECT() *MockINamingProxyMockRecorder + func (m *MockINamingProxy) GetServiceList(pageNo, pageSize uint32, groupName, namespaceId string, ...) (model.ServiceList, error) + func (m *MockINamingProxy) QueryInstancesOfService(serviceName, groupName, clusters string, udpPort int, healthyOnly bool) (*model.Service, error) + func (m *MockINamingProxy) RegisterInstance(serviceName, groupName string, instance model.Instance) (bool, error) + func (m *MockINamingProxy) ServerHealthy() bool + func (m *MockINamingProxy) Subscribe(serviceName, groupName, clusters string) (model.Service, error) + func (m *MockINamingProxy) Unsubscribe(serviceName, groupName, clusters string) error + type MockINamingProxyMockRecorder struct + func (mr *MockINamingProxyMockRecorder) CloseClient() *gomock.Call + func (mr *MockINamingProxyMockRecorder) DeregisterInstance(serviceName, groupName, instance interface{}) *gomock.Call + func (mr *MockINamingProxyMockRecorder) GetServiceList(pageNo, pageSize, groupName, namespaceId, selector interface{}) *gomock.Call + func (mr *MockINamingProxyMockRecorder) QueryInstancesOfService(serviceName, groupName, clusters, udpPort, healthyOnly interface{}) *gomock.Call + func (mr *MockINamingProxyMockRecorder) RegisterInstance(serviceName, groupName, instance interface{}) *gomock.Call + func (mr *MockINamingProxyMockRecorder) ServerHealthy() *gomock.Call + func (mr *MockINamingProxyMockRecorder) Subscribe(serviceName, groupName, clusters interface{}) *gomock.Call + func (mr *MockINamingProxyMockRecorder) Unsubscribe(serviceName, groupName, clusters interface{}) *gomock.Call