etcdv3

Documentation

Index

• Constants
• Variables
• func NewClient(cfg *model.Config) (client model.EtcdSdk, err error)
• type EtcdV3Sdk
  • func (sdk *EtcdV3Sdk) Add(path string, data []byte) (err error)
  • func (sdk *EtcdV3Sdk) Close() error
  • func (sdk *EtcdV3Sdk) ConvertToPath(path string, keys []*mvccpb.KeyValue) (list []*model.Node, err error)
  • func (sdk *EtcdV3Sdk) Del(path string) (err error)
  • func (sdk *EtcdV3Sdk) List(path string) (list []*model.Node, err error)
  • func (sdk *EtcdV3Sdk) Members() (members []*model.Member, err error)
  • func (sdk *EtcdV3Sdk) Put(path string, data []byte) (err error)
  • func (sdk *EtcdV3Sdk) Restore() (err error)
  • func (sdk *EtcdV3Sdk) Val(path string) (data *model.Node, err error)

Constants

const (
	DEFAULT_DIR_VALUE = "etcdv3_dir_$2H#%gRe3*t"
)

Variables

var (
	// DefaultTimeout 默认查询超时
	DefaultTimeout = 5 * time.Second
)

Functions

func NewClient

func NewClient(cfg *model.Config) (client model.EtcdSdk, err error)

NewClient 创建etcd连接

Types

type EtcdV3Sdk

type EtcdV3Sdk struct {
	// contains filtered or unexported fields
}

EtcdV3Sdk etcd v3版

func (*EtcdV3Sdk) Add

func (sdk *EtcdV3Sdk) Add(path string, data []byte) (err error)

Add 添加key

func (*EtcdV3Sdk) Close

func (sdk *EtcdV3Sdk) Close() error

Close 关闭连接

func (*EtcdV3Sdk) ConvertToPath

func (sdk *EtcdV3Sdk) ConvertToPath(path string, keys []*mvccpb.KeyValue) (list []*model.Node, err error)

ConvertToPath 处理etcd3 的key为目录形式 - path只能是/结尾或为空

func (*EtcdV3Sdk) Del

func (sdk *EtcdV3Sdk) Del(path string) (err error)

Del 删除key - 虚拟目录不允许删除

func (*EtcdV3Sdk) List

func (sdk *EtcdV3Sdk) List(path string) (list []*model.Node, err error)

List 显示当前path下所有key

func (*EtcdV3Sdk) Members

func (sdk *EtcdV3Sdk) Members() (members []*model.Member, err error)

Members 获取节点列表

func (*EtcdV3Sdk) Put

func (sdk *EtcdV3Sdk) Put(path string, data []byte) (err error)

Put 修改key

func (*EtcdV3Sdk) Restore

func (sdk *EtcdV3Sdk) Restore() (err error)

Restore 修复v1版本和e3w标记目录用的特殊key

func (*EtcdV3Sdk) Val

func (sdk *EtcdV3Sdk) Val(path string) (data *model.Node, err error)

Val 获取path的值