Versions in this module Expand all Collapse all v2 v2.5.0 Jan 15, 2020 Changes in this version + func NewWatchResp(serializer keyval.Serializer, resp keyval.BytesWatchResp) datasync.ProtoWatchResp + type ProtoWrapper struct + func NewProtoWrapper(db keyval.CoreBrokerWatcher, serializer ...keyval.Serializer) *ProtoWrapper + func NewProtoWrapperWithSerializer(db keyval.CoreBrokerWatcher, serializer keyval.Serializer) *ProtoWrapper + func (db *ProtoWrapper) Close() error + func (db *ProtoWrapper) Delete(key string, opts ...datasync.DelOption) (existed bool, err error) + func (db *ProtoWrapper) GetValue(key string, reqObj proto.Message) (found bool, revision int64, err error) + func (db *ProtoWrapper) ListKeys(prefix string) (keyval.ProtoKeyIterator, error) + func (db *ProtoWrapper) ListValues(key string) (keyval.ProtoKeyValIterator, error) + func (db *ProtoWrapper) NewBroker(prefix string) keyval.ProtoBroker + func (db *ProtoWrapper) NewTxn() keyval.ProtoTxn + func (db *ProtoWrapper) NewWatcher(prefix string) keyval.ProtoWatcher + func (db *ProtoWrapper) Put(key string, value proto.Message, opts ...datasync.PutOption) error + func (db *ProtoWrapper) Watch(resp func(datasync.ProtoWatchResp), closeChan chan string, keys ...string) error v2.5.0-alpha Dec 13, 2019 Other modules containing this package go.ligato.io/cn-infra