etcdutil

Documentation

Index

• Variables
• func CleanConfig(cfg *embed.Config)
• func Get(ctx context.Context, client *clientv3.Client, key string) (string, error)
• func List(ctx context.Context, client *clientv3.Client, prefix string) ([]string, error)
• func NewTestSingleConfig() *embed.Config
• func Scan(ctx context.Context, client *clientv3.Client, startKey, endKey string, ...) error
• type CloseFn
  • func PrepareEtcdServerAndClient(t *testing.T) (*embed.Etcd, *clientv3.Client, CloseFn)
• type EtcdLeaderGetter
• type LeaderGetterWrapper
  • func (w *LeaderGetterWrapper) EtcdLeaderID() (uint64, error)

Variables

var (
	ErrEtcdKVGet         = coderr.NewCodeError(coderr.Internal, "etcd KV get failed")
	ErrEtcdKVGetResponse = coderr.NewCodeError(coderr.Internal, "etcd invalid get value response must only one")
	ErrEtcdKVGetNotFound = coderr.NewCodeError(coderr.Internal, "etcd KV get value not found")
)

Functions

func CleanConfig

func CleanConfig(cfg *embed.Config)

CleanConfig is used to clean the etcd data for the unit test purpose.

func Get

func Get(ctx context.Context, client *clientv3.Client, key string) (string, error)

func List

func List(ctx context.Context, client *clientv3.Client, prefix string) ([]string, error)

func NewTestSingleConfig

func NewTestSingleConfig() *embed.Config

NewTestSingleConfig is used to create an etcd config for the unit test purpose.

func Scan

func Scan(ctx context.Context, client *clientv3.Client, startKey, endKey string, batchSize int, do func(key string, val []byte) error) error

Types

type CloseFn

type CloseFn = func()

func PrepareEtcdServerAndClient

func PrepareEtcdServerAndClient(t *testing.T) (*embed.Etcd, *clientv3.Client, CloseFn)

PrepareEtcdServerAndClient makes the server and client for testing.

Caller should take responsibilities to close the server and client.

type EtcdLeaderGetter

type EtcdLeaderGetter interface {
	EtcdLeaderID() (uint64, error)
}

type LeaderGetterWrapper

type LeaderGetterWrapper struct {
	Server *etcdserver.EtcdServer
}

func (*LeaderGetterWrapper) EtcdLeaderID

func (w *LeaderGetterWrapper) EtcdLeaderID() (uint64, error)