etcd

Documentation

Index

• type EtcdClient
  • func New(config clientv3.Config) (*EtcdClient, error)
  • func (c *EtcdClient) Close() error
  • func (c *EtcdClient) Get(ctx context.Context, key string) ([]byte, error)
  • func (c *EtcdClient) Watch(ctx context.Context, key string, stop chan bool) <-chan *backends.Response

Types

type EtcdClient

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

func New

func New(config clientv3.Config) (*EtcdClient, error)

func (*EtcdClient) Close

func (c *EtcdClient) Close() error

func (*EtcdClient) Get

func (c *EtcdClient) Get(ctx context.Context, key string) ([]byte, error)

Get retrieves a value from a K/V store for the provided key.

func (*EtcdClient) Watch

func (c *EtcdClient) Watch(ctx context.Context, key string, stop chan bool) <-chan *backends.Response

Watch a K/V store for changes to key.