etcd

Documentation

Index

• func NewClient(sn server.Node, eps server.EndPoints) (service.Client, error)
• func NewClient3(eps *server.EndPoints, timeout int) (*clientv3.Client, error)
• func NewClientWith(cli *clientv3.Client, sn server.Node) (service.Client, error)
• func NewService(cfg config.Config, points server.EndPoints) (service.Service, error)
• func NewServiceWith(cli *clientV3.Client, cfg config.Config) (service.Service, error)
• type Base
  • func (base *Base) AttachWatcher(watcher *Watcher)
  • func (base *Base) Get(key kv.Key) ([]*kv.Data, error)
  • func (base *Base) Set(data kv.Data) error
• type Watcher
  • func NewWatcher(client *clientv3.Client, sizeChan int) *Watcher
  • func (watcher *Watcher) Changed(cmd watch.Changed)
  • func (watcher *Watcher) Stop() error
  • func (watcher *Watcher) Watch(key watch.Key) (watch.Chan, error)

Functions

func NewClient

func NewClient(sn server.Node, eps server.EndPoints) (service.Client, error)

func NewClient3

func NewClient3(eps *server.EndPoints, timeout int) (*clientv3.Client, error)

func NewClientWith

func NewClientWith(cli *clientv3.Client, sn server.Node) (service.Client, error)

func NewService

func NewService(cfg config.Config, points server.EndPoints) (service.Service, error)

NewService 注册一个服务

func NewServiceWith

func NewServiceWith(cli *clientV3.Client, cfg config.Config) (service.Service, error)

Types

type Base

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

func (*Base) AttachWatcher

func (base *Base) AttachWatcher(watcher *Watcher)

func (*Base) Get

func (base *Base) Get(key kv.Key) ([]*kv.Data, error)

Get Config interface

func (*Base) Set

func (base *Base) Set(data kv.Data) error

Set Config interface

type Watcher

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

func NewWatcher

func NewWatcher(client *clientv3.Client, sizeChan int) *Watcher

func (*Watcher) Changed

func (watcher *Watcher) Changed(cmd watch.Changed)

func (*Watcher) Stop

func (watcher *Watcher) Stop() error

func (*Watcher) Watch

func (watcher *Watcher) Watch(key watch.Key) (watch.Chan, error)