etcdclient

Documentation

Index

• Variables
• type EtcdClient
  • func New(addr string, timeout time.Duration, username, passwd string) (*EtcdClient, error)
  • func (c *EtcdClient) BasePrefix() string
  • func (c *EtcdClient) Close() error
  • func (c *EtcdClient) Create(path string, data []byte) error
  • func (c *EtcdClient) Delete(path string) error
  • func (c *EtcdClient) List(path string) ([]string, error)
  • func (c *EtcdClient) Mkdir(dir string) error
  • func (c *EtcdClient) Read(path string) ([]byte, error)
  • func (c *EtcdClient) Update(path string, data []byte) error
  • func (c *EtcdClient) UpdateWithTTL(path string, data []byte, ttl time.Duration) error
  • func (c *EtcdClient) Watch(path string, ch chan string) error

Variables

var ErrClosedEtcdClient = errors.New("use of closed etcd client")

ErrClosedEtcdClient means etcd client closed

Types

type EtcdClient

type EtcdClient struct {
	sync.Mutex

	Prefix string
	// contains filtered or unexported fields
}

EtcdClient etcd client

func New

func New(addr string, timeout time.Duration, username, passwd string) (*EtcdClient, error)

New constructor of EtcdClient

func (*EtcdClient) BasePrefix

func (c *EtcdClient) BasePrefix() string

BasePrefix return base prefix

func (*EtcdClient) Close

func (c *EtcdClient) Close() error

Close close etcd client

func (*EtcdClient) Create

func (c *EtcdClient) Create(path string, data []byte) error

Create create path with data

func (*EtcdClient) Delete

func (c *EtcdClient) Delete(path string) error

Delete delete path

func (*EtcdClient) List

func (c *EtcdClient) List(path string) ([]string, error)

List list path, return slice of all paths

func (*EtcdClient) Mkdir

func (c *EtcdClient) Mkdir(dir string) error

Mkdir create directory

func (*EtcdClient) Read

func (c *EtcdClient) Read(path string) ([]byte, error)

Read read path data

func (*EtcdClient) Update

func (c *EtcdClient) Update(path string, data []byte) error

Update update path with data

func (*EtcdClient) UpdateWithTTL

func (c *EtcdClient) UpdateWithTTL(path string, data []byte, ttl time.Duration) error

UpdateWithTTL update path with data and ttl

func (*EtcdClient) Watch

func (c *EtcdClient) Watch(path string, ch chan string) error

Watch watch path