Versions in this module Expand all Collapse all v1 v1.7.0 Dec 12, 2018 Changes in this version + var DefaultPlugin = *NewPlugin() + 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(cfgPaths []string, statusPath string, dcs []decoder.API, fsh filesystem.API, ...) (*Client, error) + func (c *Client) Close() error + func (c *Client) Delete(key string, opts ...datasync.DelOption) (existed bool, err error) + func (c *Client) GetDataForFile(path string) []*decoder.FileDataEntry + func (c *Client) GetDataForKey(key string) (*decoder.FileDataEntry, bool) + func (c *Client) GetPaths() []string + 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(prefix 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(response keyval.BytesWatchResp), closeChan chan string, ...) error + type Config struct + ConfigPaths []string + StatusPath string + type Deps struct + type Option func(*Plugin) + func UseDeps(cb func(*Deps)) Option + type Plugin struct + func NewPlugin(opts ...Option) *Plugin + func (p *Plugin) AfterInit() error + func (p *Plugin) Close() error + func (p *Plugin) Disabled() bool + func (p *Plugin) Init() error + func (p *Plugin) NewBroker(keyPrefix string) keyval.ProtoBroker + func (p *Plugin) NewWatcher(keyPrefix string) keyval.ProtoWatcher + func (p *Plugin) OnConnect(callback func() error) + func (p *Plugin) String() string Incompatible versions in this module v2.2.0+incompatible Aug 23, 2019 v2.1.0+incompatible May 9, 2019 v2.0.0+incompatible Apr 2, 2019 Other modules containing this package go.ligato.io/cn-infra/v2
Go to main page