etcd

Documentation

Index

• func DiscoverService(ctx context.Context, serviceName string) (string, error)
• func GetInstance() *clientv3.Client
• func Init(conf Conf)
• func New(conf Conf) (*clientv3.Client, error)
• func RegisterService(ctx context.Context, serviceName, serviceEndpoint string, ttlSeconds int64) error
• func Watch(ctx context.Context, key string, fn func(k, v []byte))
• func WatchService(ctx context.Context, serviceName string, fn func(k, v []byte))
• func WatchWith(ctx context.Context, key string, fn func(k, v []byte), ...)
• func WatchWithPrefix(ctx context.Context, key string, fn func(k, v []byte))
• type Conf

Functions

func DiscoverService

func DiscoverService(ctx context.Context, serviceName string) (string, error)

DiscoverService 发现服务

Note:

该方法使用 rand.Intn 随机算法获取可用服务节点

func GetInstance

func GetInstance() *clientv3.Client

GetInstance 获取连接实例

func Init

func Init(conf Conf)

Init 初始化连接实例

func New

func New(conf Conf) (*clientv3.Client, error)

New 新建连接实例

func RegisterService

func RegisterService(ctx context.Context, serviceName, serviceEndpoint string, ttlSeconds int64) error

RegisterService 注册服务

func Watch

func Watch(ctx context.Context, key string, fn func(k, v []byte))

Watch 监听key

func WatchService

func WatchService(ctx context.Context, serviceName string, fn func(k, v []byte))

WatchService 动态感知服务

Note:

该方法会阻塞进程

func WatchWith

func WatchWith(ctx context.Context, key string, fn func(k, v []byte), opts ...clientv3.OpOption)

WatchWith 监听key，带选项

func WatchWithPrefix

func WatchWithPrefix(ctx context.Context, key string, fn func(k, v []byte))

WatchWithPrefix 监听key，带前缀

Types

type Conf

type Conf struct {
	Enable    bool        `yaml:"enable" toml:"enable" json:"enable" default:"false"` //是否启用
	Endpoints []string    `yaml:"endpoints" toml:"endpoints" json:"endpoints"`        //地址列表,如: localhost:2379
	Username  string      `yaml:"username" toml:"username" json:"username"`           //账号
	Password  string      `yaml:"password" toml:"password" json:"password"`           //密码
	Timeout   int         `yaml:"timeout" toml:"timeout" json:"timeout"`              //连接超时时间（毫秒）默认10000ms
	Tls       *tls.Config `yaml:"-" toml:"-" json:"-"`                                //tls配置
}