etcdKit

Documentation

Index

• Variables
• func Exist(kv clientv3.KV, ctx context.Context, key string) (bool, error)
• func GetClient() (*clientv3.Client, error)
• func MustSetUp(config *Config)
• type Config
  • func (config *Config) Check() error

Variables

var (
	NotSetupError = errorKit.Newf("haven’t been set up correctly")
)

Functions

func Exist

func Exist(kv clientv3.KV, ctx context.Context, key string) (bool, error)

Exist key是否存在？

func GetClient

func GetClient() (*clientv3.Client, error)

GetClient

PS: (1) 要使用 KV 的情况下，建议调用 clientv3.NewKV() 以实例化一个用于操作etcd的KV（内置错误重试机制）. (2) 租约相关需要用到 *clientv3.Client实例.

func MustSetUp

func MustSetUp(config *Config)

Types

type Config

type Config struct {
	Endpoints []string `json:"endpoints" yaml:"endpoints"`
	// LogPath etcd客户端的日志输出（默认: 输出到控制台）
	LogPath string `json:"logPath,optional" yaml:"logPath"`
}

func (*Config) Check

func (config *Config) Check() error