resolver

Documentation

Index

• type Discovery
• type EtcdDiscovery
  • func NewEtcdDiscovery(etcdClient *clientv3.Client, domain string) *EtcdDiscovery
  • func (e *EtcdDiscovery) Address() (addr string)
  • func (e *EtcdDiscovery) Close() (err error)
  • func (e *EtcdDiscovery) Discover(service string) (builder gresolver.Builder, err error)
• type EtcdRegistry
  • func NewEtcdRegistry(ctx context.Context, etcdClient *clientv3.Client, domain string) *EtcdRegistry
  • func (e *EtcdRegistry) Close() (err error)
  • func (e *EtcdRegistry) Register(serviceInfo *ServiceInfo) (err error)
• type Registry
• type ServiceInfo
  • func NewServiceInfo() *ServiceInfo

Types

type Discovery

type Discovery interface {
	Discover(domain string) (builder gresolver.Builder, err error)
	Close() (err error)
	Address() (addr string)
}

type EtcdDiscovery

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

func NewEtcdDiscovery

func NewEtcdDiscovery(etcdClient *clientv3.Client, domain string) *EtcdDiscovery

func (*EtcdDiscovery) Address

func (e *EtcdDiscovery) Address() (addr string)

func (*EtcdDiscovery) Close

func (e *EtcdDiscovery) Close() (err error)

func (*EtcdDiscovery) Discover

func (e *EtcdDiscovery) Discover(service string) (builder gresolver.Builder, err error)

type EtcdRegistry

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

func NewEtcdRegistry

func NewEtcdRegistry(ctx context.Context, etcdClient *clientv3.Client, domain string) *EtcdRegistry

func (*EtcdRegistry) Close

func (e *EtcdRegistry) Close() (err error)

func (*EtcdRegistry) Register

func (e *EtcdRegistry) Register(serviceInfo *ServiceInfo) (err error)

type Registry

type Registry interface {
	Register(serviceInfo *ServiceInfo) (err error)
	Close() (err error)
}

type ServiceInfo

type ServiceInfo struct {
	Name     string
	Address  string
	Tags     []string
	Interval time.Duration
}

func NewServiceInfo

func NewServiceInfo() *ServiceInfo