etcdv3

package
v0.0.0-...-45fc0ec Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 6, 2019 License: MIT Imports: 13 Imported by: 1

Documentation

Index

Constants

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

Variables

View Source
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的值

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL