etcdx

Documentation

Index

• func NewWatcher(ctx context.Context, client *clientv3.Client, key string) (*watcher, error)
• type Conf
  • func (c *Conf) Empty() bool
• type Option
• type Options
• type Registry
  • func New(conf Conf, fns ...Option) (*Registry, error)
  • func (r *Registry) DeRegister(ctx context.Context, instance *registry.Instance) error
  • func (r *Registry) Register(ctx context.Context, instance *registry.Instance) error
  • func (r *Registry) Watch(ctx context.Context, serviceName string) (registry.Watcher, error)

Functions

func NewWatcher

func NewWatcher(ctx context.Context, client *clientv3.Client, key string) (*watcher, error)

Types

type Conf

type Conf struct {
	Hosts []string `yaml:"hosts"`
	User  string   `yaml:"user"`
	Pass  string   `yaml:"pass"`
	//CertFile           string `json:",optional"`
	//CertKeyFile        string `json:",optional=CertFile"`
	//CACertFile         string `json:",optional=CertFile"`
	InsecureSkipVerify bool `json:""`
}

Conf is the config item with the given key on etcd.

func (*Conf) Empty

func (c *Conf) Empty() bool

type Option

type Option func(options *Options)

type Options

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

type Registry

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

func New

func New(conf Conf, fns ...Option) (*Registry, error)

func (*Registry) DeRegister

func (r *Registry) DeRegister(ctx context.Context, instance *registry.Instance) error

func (*Registry) Register

func (r *Registry) Register(ctx context.Context, instance *registry.Instance) error

func (*Registry) Watch

func (r *Registry) Watch(ctx context.Context, serviceName string) (registry.Watcher, error)