Documentation
¶
Index ¶
- Constants
- Variables
- type Client
- 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 ¶
View Source
const SELF_MAPPING_PATH = "/_metad/mapping"
Variables ¶
View Source
var (
//see github.com/coreos/etcd/etcdserver/api/v3rpc/key.go
MaxOpsPerTxn = 128
)
Functions ¶
This section is empty.
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) GetMapping ¶
func (*Client) PutMapping ¶
Source Files
Click to show internal directories.
Click to hide internal directories.