etcd

Documentation

Index

• type EtcdClient
  • func NewEtcdClient(config *EtcdClientConfig) (*EtcdClient, error)
  • func (e *EtcdClient) Acquire(key, node string) (string, error)
  • func (e *EtcdClient) Close() error
  • func (e *EtcdClient) Del(key string) error
  • func (e *EtcdClient) Get(key string) (string, error)
  • func (e *EtcdClient) Leader(key string) (string, error)
  • func (e *EtcdClient) Set(key string, val string) error
  • func (e *EtcdClient) SetIfNotExists(key string, val string) error
  • func (e *EtcdClient) TryAcquire(key, node string) (string, error)
  • func (e *EtcdClient) WatchFolder(folder string) (<-chan compdb.WatchEvent, shared.CancelFn, error)
• type EtcdClientConfig

Types

type EtcdClient

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

func NewEtcdClient

func NewEtcdClient(config *EtcdClientConfig) (*EtcdClient, error)

func (*EtcdClient) Acquire

func (e *EtcdClient) Acquire(key, node string) (string, error)

func (*EtcdClient) Close

func (e *EtcdClient) Close() error

func (*EtcdClient) Del

func (e *EtcdClient) Del(key string) error

func (*EtcdClient) Get

func (e *EtcdClient) Get(key string) (string, error)

func (*EtcdClient) Leader

func (e *EtcdClient) Leader(key string) (string, error)

func (*EtcdClient) Set

func (e *EtcdClient) Set(key string, val string) error

func (*EtcdClient) SetIfNotExists

func (e *EtcdClient) SetIfNotExists(key string, val string) error

func (*EtcdClient) TryAcquire

func (e *EtcdClient) TryAcquire(key, node string) (string, error)

func (*EtcdClient) WatchFolder

func (e *EtcdClient) WatchFolder(folder string) (<-chan compdb.WatchEvent, shared.CancelFn, error)

type EtcdClientConfig

type EtcdClientConfig struct {
	Endpoints []string
}