discover

Documentation

Index

• Variables
• func CheckHealth(writer http.ResponseWriter, reader *http.Request)
• func Deregister()
• func DiscoveryService(serviceName string) (*common.ServiceInstance, error)
• func Register()
• type DiscoveryClient
• type DiscoveryClientInstance
  • func New(consulHost string, consulPort string) *DiscoveryClientInstance
  • func (consulClient *DiscoveryClientInstance) DeRegister(instanceId string, logger *log.Logger) bool
  • func (consulClient *DiscoveryClientInstance) DiscoverServices(serviceName string, logger *log.Logger) []*common.ServiceInstance
  • func (consulClient *DiscoveryClientInstance) Register(instanceId, svcHost, healthCheckUrl, svcPort string, svcName string, ...) bool

Variables

var LoadBalance loadbalance.LoadBalance

var Logger *log.Logger

var NoInstanceExistedErr = errors.New("no available client")

Functions

func CheckHealth

func CheckHealth(writer http.ResponseWriter, reader *http.Request)

func Deregister

func Deregister()

func DiscoveryService

func DiscoveryService(serviceName string) (*common.ServiceInstance, error)

func Register

func Register()

Types

type DiscoveryClient

type DiscoveryClient interface {
	/**
	 * 服务注册接口
	 * @param serviceName 服务名
	 * @param instanceId 服务实例Id
	 * @param instancePort 服务实例端口
	 * @param healthCheckUrl 健康检查地址
	 * @param weight 权重
	 * @param meta 服务实例元数据
	 */
	Register(instanceId, svcHost, healthCheckUrl, svcPort string, svcName string, weight int, meta map[string]string, tags []string, logger *log.Logger) bool

	/**
	 * 服务注销接口
	 * @param instanceId 服务实例Id
	 */
	DeRegister(instanceId string, logger *log.Logger) bool

	/**
	 * 发现服务实例接口
	 * @param serviceName 服务名
	 */
	DiscoverServices(serviceName string, logger *log.Logger) []*common.ServiceInstance
}

var ConsulService DiscoveryClient

type DiscoveryClientInstance

type DiscoveryClientInstance struct {
	Host string //  Host
	Port int    //  Port
	// contains filtered or unexported fields
}

func New

func New(consulHost string, consulPort string) *DiscoveryClientInstance

func (*DiscoveryClientInstance) DeRegister

func (consulClient *DiscoveryClientInstance) DeRegister(instanceId string, logger *log.Logger) bool

func (*DiscoveryClientInstance) DiscoverServices

func (consulClient *DiscoveryClientInstance) DiscoverServices(serviceName string, logger *log.Logger) []*common.ServiceInstance

func (*DiscoveryClientInstance) Register

func (consulClient *DiscoveryClientInstance) Register(instanceId, svcHost, healthCheckUrl, svcPort string, svcName string, weight int, meta map[string]string, tags []string, logger *log.Logger) bool