etcd

package

v0.1.1 Latest Latest Go to latest Published: Apr 13, 2021 License: MIT Imports: 8 Imported by: 1

Details

This section is empty.

This section is empty.

func NewProvider(ctx context.Context, endPoints []string, username, password string) (backend.Provider, error)

type Etcd struct {
	*clientv3.Client
	// contains filtered or unexported fields
}

func (p *Etcd) Close() error

Close the provider connection

func (p *Etcd) Delete(key string, dir bool) error

Delete the specified key or directory

func (p *Etcd) Get(key string, dir bool) (backend.KVPairs, error)

Get value of the specified key or directory

func (p *Etcd) Incr(key string) (int64, error)

Atomic increase the specified key

func (p *Etcd) KeepAlive(key, value string, ttl time.Duration) error

Set and update ttl for the specified key

func (p *Etcd) Set(key, value string, ttl time.Duration) error

Set value with the specified key

func (p *Etcd) Type() string

Return provider type

func (p *Etcd) Watch(key string, dir bool) backend.EventChan

Watch for changes of the specified key or directory