discovery

Documentation

Index

• Constants
• type ETCDDiscovery
  • func (discovery *ETCDDiscovery) BuildTarget(serviceName string) string
  • func (discovery *ETCDDiscovery) Discovery(serviceName string) (infos []ServiceInfo, err error)
  • func (discovery *ETCDDiscovery) Register(stopCh <-chan struct{}, info ServiceInfo) error
  • func (discovery *ETCDDiscovery) Resolver(serviceName string)
• type Instance
  • func NewETCDDiscovery(endpoints []string, namespace string, ttl time.Duration) Instance
• type ServiceInfo

Constants

const (
	ETCDSchema = "etcd"
)

Types

type ETCDDiscovery

type ETCDDiscovery struct {
	// contains filtered or unexported fields
}

func (*ETCDDiscovery) BuildTarget

func (discovery *ETCDDiscovery) BuildTarget(serviceName string) string

func (*ETCDDiscovery) Discovery

func (discovery *ETCDDiscovery) Discovery(serviceName string) (infos []ServiceInfo, err error)

func (*ETCDDiscovery) Register

func (discovery *ETCDDiscovery) Register(stopCh <-chan struct{}, info ServiceInfo) error

func (*ETCDDiscovery) Resolver

func (discovery *ETCDDiscovery) Resolver(serviceName string)

type Instance

type Instance interface {
	// Register a new service
	Register(stopCh <-chan struct{}, info ServiceInfo) error
	Discovery(serviceName string) (infos []ServiceInfo, err error)

	Resolver(serviceName string)
	BuildTarget(serviceName string) string
}

func NewETCDDiscovery

func NewETCDDiscovery(endpoints []string, namespace string, ttl time.Duration) Instance

type ServiceInfo

type ServiceInfo struct {
	Name   string
	Addr   string
	Weight int
}