etcdHelper

Documentation

Index

• Variables
• func BuildPrefix(info Server) string
• func BuildRegPath(info Server) string
• func BuildResolverUrl(app string) string
• func Conn(endpoints []string, timeout time.Duration) (*clientv3.Client, error)
• func Exist(l []resolver.Address, addr resolver.Address) bool
• func Get(c *clientv3.Client, k string) (*clientv3.GetResponse, error)
• func Put(c *clientv3.Client, k, v string) error
• func Remove(s []resolver.Address, addr resolver.Address) ([]resolver.Address, bool)
• type Discovery
  • func NewDiscovery(cli *clientv3.Client) *Discovery
  • func NewServiceDiscovery(etcdAddr []string) *Discovery
  • func (r *Discovery) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOptions) (resolver.Resolver, error)
  • func (r *Discovery) Close()
  • func (r *Discovery) ResolveNow(o resolver.ResolveNowOptions)
  • func (r *Discovery) Scheme() string
• type Register
  • func NewRegister(cli *clientv3.Client) *Register
  • func NewServiceRegister(etcdAddr []string) *Register
  • func (r *Register) GetServerInfo() (Server, error)
  • func (r *Register) Register(srvInfo Server, ttl int64) (chan<- struct{}, error)
  • func (r *Register) Stop()
• type Server
  • func ParseValue(value []byte) (Server, error)
  • func SplitPath(path string) (Server, error)

Variables

var DialTimeout = 3

Functions

func BuildPrefix

func BuildPrefix(info Server) string

func BuildRegPath

func BuildRegPath(info Server) string

func BuildResolverUrl

func BuildResolverUrl(app string) string

func Conn

func Conn(endpoints []string, timeout time.Duration) (*clientv3.Client, error)

func Exist

func Exist(l []resolver.Address, addr resolver.Address) bool

func Get

func Get(c *clientv3.Client, k string) (*clientv3.GetResponse, error)

func Put

func Put(c *clientv3.Client, k, v string) error

func Remove

func Remove(s []resolver.Address, addr resolver.Address) ([]resolver.Address, bool)

Types

type Discovery

type Discovery struct {
	EtcdAddrs   []string
	DialTimeout int
	// contains filtered or unexported fields
}

Discovery 客户端发现服务

func NewDiscovery

func NewDiscovery(cli *clientv3.Client) *Discovery

NewDiscovery 新建发现服务

func NewServiceDiscovery

func NewServiceDiscovery(etcdAddr []string) *Discovery

NewServiceDiscovery 新建发现服务

func (*Discovery) Build

func (r *Discovery) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOptions) (resolver.Resolver, error)

Build 实现 resolver.Builder Build接口

func (*Discovery) Close

func (r *Discovery) Close()

Close 实现 resolver.Resolver Close接口

func (*Discovery) ResolveNow

func (r *Discovery) ResolveNow(o resolver.ResolveNowOptions)

ResolveNow 实现 resolver.Resolver ResolveNow接口

func (*Discovery) Scheme

func (r *Discovery) Scheme() string

Scheme 实现 resolver.Builder Scheme接口

type Register

type Register struct {
	EtcdAddr    []string
	DialTimeout int
	// contains filtered or unexported fields
}

Register 注册服务信息

func NewRegister

func NewRegister(cli *clientv3.Client) *Register

NewRegister 新建注册服务

func NewServiceRegister

func NewServiceRegister(etcdAddr []string) *Register

NewServiceRegister 新建注册服务

func (*Register) GetServerInfo

func (r *Register) GetServerInfo() (Server, error)

GetServerInfo 获取现有的服务信息

func (*Register) Register

func (r *Register) Register(srvInfo Server, ttl int64) (chan<- struct{}, error)

Register 注册服务

func (*Register) Stop

func (r *Register) Stop()

Stop 停止注册服务

type Server

type Server struct {
	Name     string      `json:"name"`     // 服务名称
	Addr     string      `json:"addr"`     // 服务地址
	Version  string      `json:"version"`  // 服务版本
	Metadata interface{} `json:"metadata"` // 服务元数据
}

func ParseValue

func ParseValue(value []byte) (Server, error)

func SplitPath

func SplitPath(path string) (Server, error)