etcdv3

Documentation

Index

• Constants
• Variables
• type Client
  • func NewEtcdClient(group string, prefix string, machines []string, cert, key, caCert string, ...) (*Client, error)
  • func (c *Client) Delete(nodePath string, dir bool) error
  • func (c *Client) DeleteMapping(nodePath string, dir bool) error
  • func (c *Client) Get(nodePath string, dir bool) (interface{}, error)
  • func (c *Client) GetMapping(nodePath string, dir bool) (interface{}, error)
  • func (c *Client) Put(nodePath string, value interface{}, replace bool) error
  • func (c *Client) PutMapping(nodePath string, mapping interface{}, replace bool) error
  • func (c *Client) Sync(store store.Store, stopChan chan bool)
  • func (c *Client) SyncMapping(mapping store.Store, stopChan chan bool)

Constants

const SELF_MAPPING_PATH = "/_metad/mapping"

Variables

var (
	//see github.com/coreos/etcd/etcdserver/api/v3rpc/key.go
	MaxOpsPerTxn = 128
)

Types

type Client

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

Client is a wrapper around the etcd client

func NewEtcdClient

func NewEtcdClient(group string, prefix string, machines []string, cert, key, caCert string, basicAuth bool, username string, password string) (*Client, error)

NewEtcdClient returns an *etcd.Client with a connection to named machines.

func (*Client) Delete

func (c *Client) Delete(nodePath string, dir bool) error

func (*Client) DeleteMapping

func (c *Client) DeleteMapping(nodePath string, dir bool) error

func (*Client) Get

func (c *Client) Get(nodePath string, dir bool) (interface{}, error)

Get queries etcd for nodePath.

func (*Client) GetMapping

func (c *Client) GetMapping(nodePath string, dir bool) (interface{}, error)

func (*Client) Put

func (c *Client) Put(nodePath string, value interface{}, replace bool) error

func (*Client) PutMapping

func (c *Client) PutMapping(nodePath string, mapping interface{}, replace bool) error

func (*Client) Sync

func (c *Client) Sync(store store.Store, stopChan chan bool)

func (*Client) SyncMapping

func (c *Client) SyncMapping(mapping store.Store, stopChan chan bool)