etcd

Documentation

Index

• func ConfigForEtcdTest(endpoint string) *config.Config
• func CreateEtcdServer(addr, dir string, lg *zap.Logger) (*embed.Etcd, error)
• func GetKVs(ctx context.Context, etcdCli *clientv3.Client, key string, ...) ([]*mvccpb.KeyValue, error)
• func InitEtcdClient(logger *zap.Logger, cfg *config.Config, certMgr *cert.CertManager) (*clientv3.Client, error)

Functions

func ConfigForEtcdTest

func ConfigForEtcdTest(endpoint string) *config.Config

func CreateEtcdServer

func CreateEtcdServer(addr, dir string, lg *zap.Logger) (*embed.Etcd, error)

CreateEtcdServer creates an etcd server and is only used for testing.

func GetKVs

func GetKVs(ctx context.Context, etcdCli *clientv3.Client, key string, opts []clientv3.OpOption, timeout, retryIntvl time.Duration, retryCnt uint64) ([]*mvccpb.KeyValue, error)

func InitEtcdClient

func InitEtcdClient(logger *zap.Logger, cfg *config.Config, certMgr *cert.CertManager) (*clientv3.Client, error)

InitEtcdClient initializes an etcd client that connects to PD ETCD server.