local

Documentation

Index

• type Client
  • func NewLocalClient() (*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(s store.Store, stopChan chan bool)
  • func (c *Client) SyncMapping(mapping store.Store, stopChan chan bool)

Types

type Client

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

a backend just for test.

func NewLocalClient

func NewLocalClient() (*Client, error)

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(s store.Store, stopChan chan bool)

func (*Client) SyncMapping

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