Versions in this module Expand all Collapse all v2 v2.5.0 Jan 15, 2020 Changes in this version + var DefaultPlugin = *NewPlugin() + type BytesBrokerWatcherEtcd struct + func (pdb *BytesBrokerWatcherEtcd) CompareAndDelete(key string, data []byte) (succeeded bool, err error) + func (pdb *BytesBrokerWatcherEtcd) CompareAndSwap(key string, oldData, newData []byte) (swapped bool, err error) + func (pdb *BytesBrokerWatcherEtcd) Delete(key string, opts ...datasync.DelOption) (existed bool, err error) + func (pdb *BytesBrokerWatcherEtcd) GetValue(key string) (data []byte, found bool, revision int64, err error) + func (pdb *BytesBrokerWatcherEtcd) ListKeys(prefix string) (keyval.BytesKeyIterator, error) + func (pdb *BytesBrokerWatcherEtcd) ListValues(key string) (keyval.BytesKeyValIterator, error) + func (pdb *BytesBrokerWatcherEtcd) NewTxn() keyval.BytesTxn + func (pdb *BytesBrokerWatcherEtcd) Put(key string, data []byte, opts ...datasync.PutOption) error + func (pdb *BytesBrokerWatcherEtcd) PutIfNotExists(key string, data []byte) (succeeded bool, err error) + func (pdb *BytesBrokerWatcherEtcd) Watch(resp func(keyval.BytesWatchResp), closeChan chan string, keys ...string) error + type BytesConnectionEtcd struct + func NewEtcdConnectionUsingClient(etcdClient *clientv3.Client, log logging.Logger) (*BytesConnectionEtcd, error) + func NewEtcdConnectionWithBytes(config ClientConfig, log logging.Logger) (*BytesConnectionEtcd, error) + func (db *BytesConnectionEtcd) CampaignInElection(ctx context.Context, prefix string) (func(c context.Context), error) + func (db *BytesConnectionEtcd) Close() error + func (db *BytesConnectionEtcd) Compact(rev ...int64) (int64, error) + func (db *BytesConnectionEtcd) CompareAndDelete(key string, data []byte) (succeeded bool, err error) + func (db *BytesConnectionEtcd) CompareAndSwap(key string, oldData, newData []byte) (succeeded bool, err error) + func (db *BytesConnectionEtcd) Delete(key string, opts ...datasync.DelOption) (existed bool, err error) + func (db *BytesConnectionEtcd) GetRevision() (revision int64, err error) + func (db *BytesConnectionEtcd) GetValue(key string) (data []byte, found bool, revision int64, err error) + func (db *BytesConnectionEtcd) GetValueRev(key string, rev int64) (data []byte, found bool, revision int64, err error) + func (db *BytesConnectionEtcd) ListKeys(prefix string) (keyval.BytesKeyIterator, error) + func (db *BytesConnectionEtcd) ListValues(key string) (keyval.BytesKeyValIterator, error) + func (db *BytesConnectionEtcd) ListValuesRange(fromPrefix string, toPrefix string) (keyval.BytesKeyValIterator, error) + func (db *BytesConnectionEtcd) NewBroker(prefix string) keyval.BytesBroker + func (db *BytesConnectionEtcd) NewTxn() keyval.BytesTxn + func (db *BytesConnectionEtcd) NewWatcher(prefix string) keyval.BytesWatcher + func (db *BytesConnectionEtcd) Put(key string, binData []byte, opts ...datasync.PutOption) error + func (db *BytesConnectionEtcd) PutIfNotExists(key string, data []byte) (succeeded bool, err error) + func (db *BytesConnectionEtcd) Watch(resp func(keyval.BytesWatchResp), closeChan chan string, keys ...string) error + type BytesWatchDelResp struct + func NewBytesWatchDelResp(key string, prevValue []byte, revision int64) *BytesWatchDelResp + func (resp *BytesWatchDelResp) GetChangeType() datasync.Op + func (resp *BytesWatchDelResp) GetKey() string + func (resp *BytesWatchDelResp) GetPrevValue() []byte + func (resp *BytesWatchDelResp) GetRevision() int64 + func (resp *BytesWatchDelResp) GetValue() []byte + type BytesWatchPutResp struct + func NewBytesWatchPutResp(key string, value []byte, prevValue []byte, revision int64) *BytesWatchPutResp + func (resp *BytesWatchPutResp) GetChangeType() datasync.Op + func (resp *BytesWatchPutResp) GetKey() string + func (resp *BytesWatchPutResp) GetPrevValue() []byte + func (resp *BytesWatchPutResp) GetRevision() int64 + func (resp *BytesWatchPutResp) GetValue() []byte + type ClientConfig struct + ExpandEnvVars bool + OpTimeout time.Duration + SessionTTL int + func ConfigToClient(yc *Config) (*ClientConfig, error) + type Config struct + AllowDelayedStart bool + AutoCompact time.Duration + CAfile string + Certfile string + DialTimeout time.Duration + Endpoints []string + ExpandEnvVars bool + InsecureSkipTLSVerify bool + InsecureTransport bool + Keyfile string + OpTimeout time.Duration + ReconnectInterval time.Duration + ReconnectResync bool + SessionTTL int + type Deps struct + Resync *resync.Plugin + Serializer keyval.Serializer + StatusCheck statuscheck.PluginStatusWriter + 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) CampaignInElection(ctx context.Context, prefix string) (func(context.Context), error) + func (p *Plugin) Close() error + func (p *Plugin) Compact(rev ...int64) (toRev int64, err error) + func (p *Plugin) Disabled() (disabled bool) + func (p *Plugin) GetPluginName() infra.PluginName + func (p *Plugin) Init() (err error) + func (p *Plugin) NewBroker(keyPrefix string) keyval.ProtoBroker + func (p *Plugin) NewBrokerWithAtomic(keyPrefix string) keyval.BytesBrokerWithAtomic + func (p *Plugin) NewWatcher(keyPrefix string) keyval.ProtoWatcher + func (p *Plugin) OnConnect(callback func() error) + func (p *Plugin) RawAccess() keyval.KvBytesPlugin v2.5.0-alpha Dec 13, 2019 Other modules containing this package go.ligato.io/cn-infra
Go to main page