discovery

Documentation

Index

• Constants
• func Init(consulAddress string) *consulapi.Client
• func NewDiscovery(name, serviceName string, meta map[string]string, localIp string, port int, ...) proto.IDiscovery
• func NewRegistration(name, serviceName string, tags []string, meta map[string]string, advt string, ...) proto.IRegister
• type Discovery
  • func (dc *Discovery) GetService(blocking bool) ([]proto.IService, error)
  • func (dc *Discovery) RegisterService(service proto.IService)
• type Registration
  • func (reg *Registration) GetAddr() string
  • func (reg *Registration) GetAddressWithPort() string
  • func (reg *Registration) GetHost() string
  • func (reg *Registration) GetMeta() map[string]string
  • func (reg *Registration) GetMetaValue(key string) string
  • func (reg *Registration) GetName() string
  • func (reg *Registration) GetPort() int
  • func (reg *Registration) GetService(blocking bool) ([]proto.IService, error)
  • func (reg *Registration) GetServiceName() string
  • func (reg *Registration) GetTags() []string
  • func (reg *Registration) Register(nodeName, serviceName string, tags []string, meta map[string]string, ...)
  • func (reg *Registration) Unregister()
• type Service
  • func (sv *Service) GetAddr() string
  • func (sv *Service) GetHost() string
  • func (sv *Service) GetMeta() map[string]string
  • func (sv *Service) GetMetaValue(key string) string
  • func (sv *Service) GetName() string
  • func (sv *Service) GetPort() int
  • func (sv *Service) GetServiceName() string
  • func (sv *Service) GetTags() []string

Constants

const (
	DEFAULT_CONSUL = "consul.rightpaddle.cn:8500"
)

Functions

func Init

func Init(consulAddress string) *consulapi.Client

func NewDiscovery

func NewDiscovery(name, serviceName string, meta map[string]string, localIp string, port int, consuleAddress string) proto.IDiscovery

func NewRegistration

func NewRegistration(name, serviceName string, tags []string, meta map[string]string, advt string, port int, consulAddress string) proto.IRegister

Types

type Discovery

type Discovery struct {
	proto.IService
	proto.IRegister
	LocalIp string
	Port    int
}

func (*Discovery) GetService

func (dc *Discovery) GetService(blocking bool) ([]proto.IService, error)

func (*Discovery) RegisterService

func (dc *Discovery) RegisterService(service proto.IService)

type Registration

type Registration struct {
	Id          string
	ServiceName string
	Advt        string
	Port        int

	Meta map[string]string
	Tags []string

	LastIndex uint64
	// contains filtered or unexported fields
}

func (*Registration) GetAddr

func (reg *Registration) GetAddr() string

func (*Registration) GetAddressWithPort

func (reg *Registration) GetAddressWithPort() string

func (*Registration) GetHost

func (reg *Registration) GetHost() string

func (*Registration) GetMeta

func (reg *Registration) GetMeta() map[string]string

func (*Registration) GetMetaValue

func (reg *Registration) GetMetaValue(key string) string

func (*Registration) GetName

func (reg *Registration) GetName() string

func (*Registration) GetPort

func (reg *Registration) GetPort() int

func (*Registration) GetService

func (reg *Registration) GetService(blocking bool) ([]proto.IService, error)

func (*Registration) GetServiceName

func (reg *Registration) GetServiceName() string

func (*Registration) GetTags

func (reg *Registration) GetTags() []string

func (*Registration) Register

func (reg *Registration) Register(nodeName, serviceName string, tags []string, meta map[string]string, advt string, port int)

func (*Registration) Unregister

func (reg *Registration) Unregister()

type Service

type Service struct {
	Name        string
	ServiceName string
	Meta        map[string]string
	Addr        string
	Host        string
	Port        int
}

func (*Service) GetAddr

func (sv *Service) GetAddr() string

func (*Service) GetHost

func (sv *Service) GetHost() string

func (*Service) GetMeta

func (sv *Service) GetMeta() map[string]string

func (*Service) GetMetaValue

func (sv *Service) GetMetaValue(key string) string

func (*Service) GetName

func (sv *Service) GetName() string

func (*Service) GetPort

func (sv *Service) GetPort() int

func (*Service) GetServiceName

func (sv *Service) GetServiceName() string

func (*Service) GetTags

func (sv *Service) GetTags() []string