discover

Documentation

Overview

discover 包，该包包含了服务发现注册接口定义，与基于go-kit(gRPC协议)框架的consul服务注册发现客户端结构体

Index

• type DiscoveryClient
  • func NewKitConsulDiscoveryClient(consulHost string, consulPort uint16) (DiscoveryClient, error)
• 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
  • func NewKitConsulRegistryClient(consulHost string, consulPort uint16) (RegistryClient, error)

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 (consulClient *KitConsulClient) DiscoverServices(serviceName string, logger log.Logger) sd.Instancer

func (*KitConsulClient) DiscoverServicesClient

func (consulClient *KitConsulClient) DiscoverServicesClient(serviceName string, logger log.Logger, clientFactory func(instance string) (client interface{}, err error)) (client interface{}, err error)

func (*KitConsulClient) Register

func (consulClient *KitConsulClient) Register(serviceName, instanceId, instanceHost string, instancePort uint16, meta map[string]string, logger log.Logger) bool

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)