Versions in this module Expand all Collapse all v2 v2.5.0 Jan 15, 2020 Changes in this version + const Root + var DefaultMarshaler = &jsonpb.Marshaler + func ToChan(respCh chan BytesWatchResp, opts ...interface{}) func(dto BytesWatchResp) + func ToChanProto(respCh chan datasync.ProtoWatchResp, opts ...interface{}) func(dto datasync.ProtoWatchResp) + type BytesBroker interface + Delete func(key string, opts ...datasync.DelOption) (existed bool, err error) + GetValue func(key string) (data []byte, found bool, revision int64, err error) + ListKeys func(prefix string) (BytesKeyIterator, error) + ListValues func(key string) (BytesKeyValIterator, error) + NewTxn func() BytesTxn + Put func(key string, data []byte, opts ...datasync.PutOption) error + type BytesBrokerWithAtomic interface + CompareAndDelete func(key string, data []byte) (deleted bool, err error) + CompareAndSwap func(key string, oldData, newData []byte) (swapped bool, err error) + PutIfNotExists func(key string, data []byte) (succeeded bool, err error) + type BytesKeyIterator interface + GetNext func() (key string, rev int64, stop bool) + type BytesKeyVal interface + type BytesKeyValIterator interface + GetNext func() (kv BytesKeyVal, stop bool) + type BytesKvPair interface + GetPrevValue func() []byte + GetValue func() []byte + type BytesTxn interface + Commit func(ctx context.Context) error + Delete func(key string) BytesTxn + Put func(key string, data []byte) BytesTxn + type BytesWatchResp interface + type BytesWatcher interface + Watch func(respChan func(BytesWatchResp), closeChan chan string, keys ...string) error + type CoreBrokerWatcher interface + Close func() error + NewBroker func(prefix string) BytesBroker + NewWatcher func(prefix string) BytesWatcher + type KvBytesPlugin interface + NewBroker func(keyPrefix string) BytesBroker + NewWatcher func(keyPrefix string) BytesWatcher + type KvProtoPlugin interface + Disabled func() bool + NewBroker func(keyPrefix string) ProtoBroker + NewWatcher func(keyPrefix string) ProtoWatcher + OnConnect func(func() error) + String func() string + type ProtoBroker interface + Delete func(key string, opts ...datasync.DelOption) (existed bool, err error) + GetValue func(key string, reqObj proto.Message) (found bool, revision int64, err error) + ListKeys func(prefix string) (ProtoKeyIterator, error) + ListValues func(key string) (ProtoKeyValIterator, error) + NewTxn func() ProtoTxn + type ProtoKeyIterator interface + GetNext func() (key string, rev int64, stop bool) + type ProtoKeyVal interface + type ProtoKeyValIterator interface + GetNext func() (kv ProtoKeyVal, stop bool) + type ProtoKvPair interface + type ProtoTxn interface + Commit func(ctx context.Context) error + Delete func(key string) ProtoTxn + Put func(key string, data proto.Message) ProtoTxn + type ProtoWatcher interface + Watch func(respChan func(datasync.ProtoWatchResp), closeChan chan string, key ...string) error + type Serializer interface + Marshal func(message proto.Message) ([]byte, error) + Unmarshal func(data []byte, protoData proto.Message) error + type SerializerJSON struct + ExpandEnvVars bool + func (sj *SerializerJSON) Marshal(message proto.Message) ([]byte, error) + func (sj *SerializerJSON) Unmarshal(data []byte, protoData proto.Message) error + type SerializerProto struct + func (sp *SerializerProto) Marshal(message proto.Message) ([]byte, error) + func (sp *SerializerProto) Unmarshal(data []byte, protoData proto.Message) error v2.5.0-alpha Dec 13, 2019 Other modules containing this package go.ligato.io/cn-infra
Go to main page