kv

Documentation

Index

• func NewEtcdKVBase(client *clientv3.Client, rootPath string) *etcdKVBase
• func NewSlowLogTxn(client *clientv3.Client) clientv3.Txn
• type Base
  • func NewMemoryKV() Base
• type SlowLogTxn
  • func (t *SlowLogTxn) Commit() (*clientv3.TxnResponse, error)
  • func (t *SlowLogTxn) If(cs ...clientv3.Cmp) clientv3.Txn
  • func (t *SlowLogTxn) Then(ops ...clientv3.Op) clientv3.Txn

Functions

func NewEtcdKVBase

func NewEtcdKVBase(client *clientv3.Client, rootPath string) *etcdKVBase

NewEtcdKVBase creates a new etcd kv.

func NewSlowLogTxn

func NewSlowLogTxn(client *clientv3.Client) clientv3.Txn

NewSlowLogTxn create a SlowLogTxn.

Types

type Base

type Base interface {
	Load(key string) (string, error)
	LoadRange(key, endKey string, limit int) (keys []string, values []string, err error)
	Save(key, value string) error
	Remove(key string) error
}

Base is an abstract interface for load/save pd cluster data.

func NewMemoryKV

func NewMemoryKV() Base

NewMemoryKV returns an in-memory kvBase for testing.

type SlowLogTxn

type SlowLogTxn struct {
	clientv3.Txn
	// contains filtered or unexported fields
}

SlowLogTxn wraps etcd transaction and log slow one.

func (*SlowLogTxn) Commit

func (t *SlowLogTxn) Commit() (*clientv3.TxnResponse, error)

Commit implements Txn Commit interface.

func (*SlowLogTxn) If

func (t *SlowLogTxn) If(cs ...clientv3.Cmp) clientv3.Txn

If takes a list of comparison. If all comparisons passed in succeed, the operations passed into Then() will be executed. Or the operations passed into Else() will be executed.

func (*SlowLogTxn) Then

func (t *SlowLogTxn) Then(ops ...clientv3.Op) clientv3.Txn

Then takes a list of operations. The Ops list will be executed, if the comparisons passed in If() succeed.