Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

keyval

package

Go to main page

Versions in this module

v1

v1.7.0

Dec 12, 2018

v1.6.0

Oct 4, 2018

v1.5.0

Aug 24, 2018

Changes in this version

type KvProtoPlugin

+ OnConnect func(func() error)

+ String func() string

v1.4.1

Jul 23, 2018

v1.4.0

Jul 16, 2018

v1.3.0

May 24, 2018

v1.2.0

Mar 22, 2018

v1.1.0

Feb 7, 2018

v1.0.8

Jan 22, 2018

v1.0.7

Nov 21, 2017

v1.0.6

Oct 30, 2017

Changes in this version

type BytesKvPair

+ GetPrevValue func() []byte

v1.0.5

Oct 17, 2017

v1.0.4

Sep 26, 2017

v1.0.3

Sep 8, 2017

v1.0.2

Aug 28, 2017

Changes in this version

+ const Root

+ func ToChan(ch chan BytesWatchResp, opts ...interface{}) func(dto BytesWatchResp)

+ func ToChanProto(ch chan ProtoWatchResp, opts ...interface{}) func(dto 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 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

+ GetValue func() []byte

+ type BytesTxn interface

+ Commit func() error

+ Delete func(key string) BytesTxn

+ Put func(key string, data []byte) BytesTxn

+ type BytesWatchResp interface

+ type BytesWatcher interface

+ Watch func(respChan func(BytesWatchResp), 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

+ 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() error

+ Delete func(key string) ProtoTxn

+ Put func(key string, data proto.Message) ProtoTxn

+ type ProtoWatchResp interface

+ type ProtoWatcher interface

+ Watch func(respChan func(ProtoWatchResp), key ...string) error

+ type Serializer interface

+ Marshal func(message proto.Message) ([]byte, error)

+ Unmarshal func(data []byte, protoData proto.Message) error

+ type SerializerJSON struct

+ 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

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