etcd

Documentation

Index

• Constants
• func BuildPrefix(info Server) string
• func BuildRegPath(info Server) string
• func BuildResolverUrl(app string) string
• func Exist(l []resolver.Address, addr resolver.Address) bool
• func InitEtcd()
• func Remove(s []resolver.Address, addr resolver.Address) ([]resolver.Address, bool)
• type Register
  • func NewRegister(logger *zap.Logger) *Register
  • func (r *Register) Register(srvInfo Server, ttl int64) (chan<- struct{}, error)
  • func (r *Register) Stop()
• type Resolver
  • func NewResolver(logger *zap.Logger) *Resolver
  • func (r *Resolver) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOptions) (resolver.Resolver, error)
  • func (r *Resolver) Close()
  • func (r *Resolver) ResolveNow(o resolver.ResolveNowOptions)
  • func (r *Resolver) Scheme() string
• type Server
  • func ParseValue(value []byte) (Server, error)
  • func SplitPath(path string) (Server, error)

Constants

const FmtEtcdPre = "etcd-service://%s"

Functions

func BuildPrefix

func BuildPrefix(info Server) string

func BuildRegPath

func BuildRegPath(info Server) string

func BuildResolverUrl

func BuildResolverUrl(app string) string

func Exist

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

Exist helper function

func InitEtcd

func InitEtcd()

func Remove

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

Remove helper function

Types

type Register

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

func NewRegister

func NewRegister(logger *zap.Logger) *Register

NewRegister create a register base on etcd

func (*Register) Register

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

Register a service

func (*Register) Stop

func (r *Register) Stop()

Stop register

type Resolver

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

Resolver for grpc client

func NewResolver

func NewResolver(logger *zap.Logger) *Resolver

NewResolver create a new resolver.Builder base on etcd

func (*Resolver) Build

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

Build creates a new resolver.Resolver for the given target

func (*Resolver) Close

func (r *Resolver) Close()

Close resolver.Resolver interface

func (*Resolver) ResolveNow

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

ResolveNow resolver.Resolver interface

func (*Resolver) Scheme

func (r *Resolver) Scheme() string

Scheme returns the scheme supported by this resolver.

type Server

type Server struct {
	Name    string `json:"name"`
	Addr    string `json:"addr"`    //服务地址
	Version string `json:"version"` //服务版本
	Weight  int64  `json:"weight"`  //服务权重
}

func ParseValue

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

func SplitPath

func SplitPath(path string) (Server, error)