etcd

package

v1.0.0 Latest Latest Go to latest Published: Sep 26, 2022 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 the value of the specified key or directory.

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

Incr invokes an atomic value increase for the specified key.

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

KeepAlive sets value and updates the ttl for the specified key.

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

Set value for the specified key with a specified ttl.

func (p *Etcd) Type() string

Type returns the provider type.

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

Watch for changes of the specified key or directory.