etcd3

Documentation

Index

• func RegisterResolver(etcdConfig clientv3.Config)
• type Driver
  • func (drv Driver) CreateRegistry(config *conf.Configuration) (registry.Registry, error)
  • func (drv Driver) ResolverBuilder(config *conf.Configuration) (resolver.Builder, error)
• type Options
• type Registry
  • func BuildFromConfig(config *Options) (*Registry, error)
  • func New() *Registry
  • func (r *Registry) Apply(cfg *conf.Configuration)
  • func (r *Registry) Close()
  • func (r *Registry) Register(node *registry.ServiceInfo) error
  • func (r *Registry) TTL() time.Duration
  • func (r *Registry) Unregister(node *registry.ServiceInfo) error

Functions

func RegisterResolver

func RegisterResolver(etcdConfig clientv3.Config)

RegisterResolver register etcdBuilder as the global grpc resolver

Types

type Driver

type Driver struct {
}

Driver is an etcd3 registry driver.

func (Driver) CreateRegistry

func (drv Driver) CreateRegistry(config *conf.Configuration) (registry.Registry, error)

func (Driver) ResolverBuilder

func (drv Driver) ResolverBuilder(config *conf.Configuration) (resolver.Builder, error)

type Options

type Options struct {
	EtcdConfig clientv3.Config `json:"etcd" yaml:"etcd"`
	TTL        time.Duration   `json:"ttl" yaml:"ttl"`
}

type Registry

type Registry struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Registry is an etcd3 registry for service discovery.

func BuildFromConfig

func BuildFromConfig(config *Options) (*Registry, error)

func New

func New() *Registry

func (*Registry) Apply

func (r *Registry) Apply(cfg *conf.Configuration)

func (*Registry) Close

func (r *Registry) Close()

func (*Registry) Register

func (r *Registry) Register(node *registry.ServiceInfo) error

func (*Registry) TTL

func (r *Registry) TTL() time.Duration

func (*Registry) Unregister

func (r *Registry) Unregister(node *registry.ServiceInfo) error

Unregister remove service from etcd