Version: v1.2.3 Latest Latest

This package is not in the latest version of its module.

Go to latest
Published: May 2, 2017 License: Apache-2.0 Imports: 15 Imported by: 0




View Source
const SELF_MAPPING_PATH = "/_metad/mapping"


View Source
var (
	MaxOpsPerTxn = 128


This section is empty.


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)

Source Files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
t or T : Toggle theme light dark auto
y or Y : Canonical URL