Versions in this module Expand all Collapse all v1 v1.3.0 May 24, 2018 Changes in this version + func ConfigToClient(cfg *Config) (*api.Config, error) + type BrokerWatcher struct + func (pdb *BrokerWatcher) Delete(key string, opts ...datasync.DelOption) (existed bool, err error) + func (pdb *BrokerWatcher) GetValue(key string) (data []byte, found bool, revision int64, err error) + func (pdb *BrokerWatcher) ListKeys(prefix string) (keyval.BytesKeyIterator, error) + func (pdb *BrokerWatcher) ListValues(key string) (keyval.BytesKeyValIterator, error) + func (pdb *BrokerWatcher) NewTxn() keyval.BytesTxn + func (pdb *BrokerWatcher) Put(key string, data []byte, opts ...datasync.PutOption) error + func (pdb *BrokerWatcher) Watch(resp func(keyval.BytesWatchResp), closeChan chan string, keys ...string) error + type Client struct + func NewClient(cfg *api.Config) (store *Client, err error) + func (c *Client) Close() error + func (c *Client) Delete(key string, opts ...datasync.DelOption) (existed bool, err error) + func (c *Client) GetValue(key string) (data []byte, found bool, revision int64, err error) + func (c *Client) ListKeys(prefix string) (keyval.BytesKeyIterator, error) + func (c *Client) ListValues(key string) (keyval.BytesKeyValIterator, error) + func (c *Client) NewBroker(prefix string) keyval.BytesBroker + func (c *Client) NewTxn() keyval.BytesTxn + func (c *Client) NewWatcher(prefix string) keyval.BytesWatcher + func (c *Client) Put(key string, data []byte, opts ...datasync.PutOption) error + func (c *Client) Watch(resp func(keyval.BytesWatchResp), closeChan chan string, keys ...string) error + type Config struct + Address string + ReconnectResync bool + type Deps struct + Resync *resync.Plugin + type Plugin struct + func (plugin *Plugin) Close() error + func (plugin *Plugin) Disabled() bool + func (plugin *Plugin) Init() (err error) + func (plugin *Plugin) NewBroker(keyPrefix string) keyval.ProtoBroker + func (plugin *Plugin) NewWatcher(keyPrefix string) keyval.ProtoWatcher
Go to main page