Documentation
¶
Overview ¶
discover 包,该包包含了服务发现注册接口定义,与基于go-kit(gRPC协议)框架的consul服务注册发现客户端结构体
Index ¶
- type DiscoveryClient
- type KitConsulClient
- func (consulClient *KitConsulClient) DeRegister(instanceId string, logger log.Logger) bool
- func (consulClient *KitConsulClient) DiscoverServices(serviceName string, logger log.Logger) sd.Instancer
- func (consulClient *KitConsulClient) DiscoverServicesClient(serviceName string, logger log.Logger, ...) (client interface{}, err error)
- func (consulClient *KitConsulClient) Register(serviceName, instanceId, instanceHost string, instancePort uint16, ...) bool
- type RegistryClient
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DiscoveryClient ¶
type DiscoveryClient interface {
/*发现服务实例接口
@param serviceName 服务名
@param logger 日志对象*/
DiscoverServices(serviceName string, logger log.Logger) sd.Instancer
/*发现服务实例接口客户端
@param serviceName 服务名
@param logger 日志对象
@param clientFactory 实例接口客户端生成函数*/
DiscoverServicesClient(serviceName string, logger log.Logger, clientFactory func(instance string) (client interface{}, err error)) (client interface{}, err error)
}
func NewKitConsulDiscoveryClient ¶
func NewKitConsulDiscoveryClient(consulHost string, consulPort uint16) (DiscoveryClient, error)
type KitConsulClient ¶
type KitConsulClient struct {
Host string // Consul Host
Port uint16 // Consul Port
// contains filtered or unexported fields
}
func (*KitConsulClient) DeRegister ¶
func (consulClient *KitConsulClient) DeRegister(instanceId string, logger log.Logger) bool
func (*KitConsulClient) DiscoverServices ¶
func (*KitConsulClient) DiscoverServicesClient ¶
type RegistryClient ¶
type RegistryClient interface {
/*服务注册接口
@param serviceName 服务名
@param instanceId 服务实例Id
@param instancePort 服务实例端口
@param healthCheckUrl 健康检查地址
@param instanceHost 服务实例地址
@param meta 服务实例元数据
@param logger 日志对象*/
Register(serviceName, instanceId, instanceHost string, instancePort uint16, meta map[string]string, logger log.Logger) bool
/*服务注销接口
@param instanceId 服务实例Id
@param logger 日志对象*/
DeRegister(instanceId string, logger log.Logger) bool
}
func NewKitConsulRegistryClient ¶
func NewKitConsulRegistryClient(consulHost string, consulPort uint16) (RegistryClient, error)
Click to show internal directories.
Click to hide internal directories.