Versions in this module Expand all Collapse all v2 v2.5.0 Jan 15, 2020 Changes in this version + var ErrNotReady = errors.New("transport adapter is not ready yet (probably called before AfterInit)") + var ResyncAcceptTimeout = time.Second * 1 + var ResyncDoneTimeout = time.Second * 5 + type ChangeWatchResp struct + func NewChangeWatchResp(ctx context.Context, delegate datasync.ProtoWatchResp, ...) *ChangeWatchResp + func (ev *ChangeWatchResp) GetChanges() []datasync.ProtoWatchResp + func (ev *ChangeWatchResp) GetContext() context.Context + type Deps struct + KvPlugin keyval.KvProtoPlugin + Log logging.PluginLogger + ResyncOrch resync.Subscriber + ServiceLabel servicelabel.ReaderAPI + type Iterator struct + func NewIterator(delegate keyval.ProtoKeyValIterator) *Iterator + func (it *Iterator) GetNext() (kv datasync.KeyVal, stop bool) + type Option func(*Plugin) + func UseDeps(cb func(*Deps)) Option + func UseKV(kv keyval.KvProtoPlugin) Option + type Plugin struct + func NewPlugin(opts ...Option) *Plugin + func (p *Plugin) AfterInit() error + func (p *Plugin) Close() error + func (p *Plugin) Delete(key string, opts ...datasync.DelOption) (existed bool, err error) + func (p *Plugin) Init() error + func (p *Plugin) Put(key string, data proto.Message, opts ...datasync.PutOption) error + func (p *Plugin) Watch(resyncName string, changeChan chan datasync.ChangeEvent, ...) (datasync.WatchRegistration, error) v2.5.0-alpha Dec 13, 2019 Other modules containing this package go.ligato.io/cn-infra
Go to main page