etcdv3

May 24, 2018

Changes in this version

type ClientConfig

+ func ConfigToClient(yc *Config) (*ClientConfig, error)

type Config

+ ReconnectResync bool

type Deps

+ Resync *resync.Plugin

type Plugin

+ func (plugin *Plugin) NewBroker(keyPrefix string) keyval.ProtoBroker

+ func (plugin *Plugin) NewWatcher(keyPrefix string) keyval.ProtoWatcher

Mar 22, 2018

Changes in this version

type BytesConnectionEtcd

+ func (db *BytesConnectionEtcd) Compact(rev ...int64) (int64, error)

+ func (db *BytesConnectionEtcd) GetRevision() (revision int64, err error)

+ func (db *BytesConnectionEtcd) GetValueRev(key string, rev int64) (data []byte, found bool, revision int64, err error)

type Config

+ AutoCompact time.Duration

type Plugin

+ func (p *Plugin) Compact(rev ...int64) (toRev int64, err error)

Oct 30, 2017

Changes in this version

type BytesConnectionEtcd

+ func (db *BytesConnectionEtcd) PutIfNotExists(key string, binData []byte) (succeeded bool, err error)

type BytesWatchDelResp

+ func (resp *BytesWatchDelResp) GetPrevValue() []byte

type BytesWatchPutResp

+ func (resp *BytesWatchPutResp) GetPrevValue() []byte

type Plugin

+ func (p *Plugin) PutIfNotExists(key string, value []byte) (succeeded bool, err error)

Aug 28, 2017

Changes in this version

+ type BytesBrokerWatcherEtcd struct

+ 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) ListValuesRange(fromPrefix string, toPrefix 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) Watch(resp func(keyval.BytesWatchResp), 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) Close() error

+ func (db *BytesConnectionEtcd) Delete(key string, opts ...datasync.DelOption) (existed bool, err error)

+ func (db *BytesConnectionEtcd) GetValue(key string) (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) Watch(resp func(keyval.BytesWatchResp), keys ...string) error

+ type BytesWatchDelResp struct

+ func NewBytesWatchDelResp(key string, revision int64) *BytesWatchDelResp

+ func (resp *BytesWatchDelResp) GetChangeType() datasync.PutDel

+ func (resp *BytesWatchDelResp) GetKey() string

+ func (resp *BytesWatchDelResp) GetRevision() int64

+ func (resp *BytesWatchDelResp) GetValue() []byte

+ type BytesWatchPutResp struct

+ func NewBytesWatchPutResp(key string, value []byte, revision int64) *BytesWatchPutResp

+ func (resp *BytesWatchPutResp) GetChangeType() datasync.PutDel

+ func (resp *BytesWatchPutResp) GetKey() string

+ func (resp *BytesWatchPutResp) GetRevision() int64

+ func (resp *BytesWatchPutResp) GetValue() []byte

+ type ClientConfig struct

+ OpTimeout time.Duration

+ func ConfigToClientv3(yc *Config) (*ClientConfig, error)

+ type Config struct

+ CAfile string

+ Certfile string

+ DialTimeout time.Duration

+ Endpoints []string

+ InsecureSkipTLSVerify bool

+ InsecureTransport bool

+ Keyfile string

+ OpTimeout time.Duration

+ type Deps struct

+ type Plugin struct

+ func FromExistingConnection(connection keyval.CoreBrokerWatcher, sl servicelabel.ReaderAPI) *Plugin

+ func (p *Plugin) AfterInit() error

+ func (p *Plugin) Close() error

+ func (p *Plugin) Disabled() (disabled bool)

+ func (p *Plugin) Init() (err error)

+ func (p *Plugin) String() string