etcd

package

v0.0.0-...-1dd3e1b Latest Latest Go to latest Published: Mar 4, 2021 License: Apache-2.0 Imports: 14 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

View Source

const (
	// 上锁超时时间
	TIMEOUT = 10
	TTL     = 5
)

This section is empty.

func NewResolver(client *Client, scheme string) re.Builder

func RegisterMethod(client *Client, version, service, method string, auth bool) error

func UnRegisterMethod(client *Client, version, service, method string) error

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

var (
	EtcdClient *Client
)

func NewClient(cfg conf.EtcdConfig) (*Client, error)

func (cl *Client) Cli() *v3.Client

func (cl *Client) Close() error

关闭客户端

func (cl *Client) GetPattern(key string) (result map[string]string)

func (cl *Client) GetSingle(key string) string

func (cl *Client) Kv() v3.KV

func (cl *Client) RegisterApi(name string, data interface{}, config conf.YamlConfig) error

传入yaml配置

func (cl *Client) RegisterService(name, addr string, ttl int64) error

func (cl *Client) Set(key, value string) bool

func (cl *Client) UnRegister(name, addr string) error

func (cl *Client) UnRegisterApi(name string, data interface{}, config conf.YamlConfig) error

注销方法

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

func NewLock(client *Client, prefix string, timeout ...int) (*DistributeLock, error)

func (l *DistributeLock) Close() error

func (l *DistributeLock) Lock() error

func (l *DistributeLock) UnLock() error

type Method struct {
	NoAuth bool   `json:"no_auth"` // 是否需要登录
	Path   string `json:"path"`
}

func (m *Method) Marshal() string