etcdv3name

Documentation

Index

• func GetConn(schema, serviceName string, etcdCfg *EtcdCfg) (*grpc.ClientConn, error)
• func GetPrefix(schema, serviceName string) string
• func Int32ToString(i int32) string
• func OperationIDGenerator() string
• func RegisterEtcd(schema string, cfg *EtcdCfg, myHost string, myPort int, serviceName string, ...) (err error)
• func UnRegisterEtcd()
• type EtcdCfg
• type RegEtcd
• type Resolver
  • func NewResolver(schema, serviceName string, etcdCfg *EtcdCfg) (*Resolver, error)
  • func (r *Resolver) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOptions) (resolver.Resolver, error)
  • func (r1 *Resolver) Close()
  • func (r1 *Resolver) ResolveNow(rn resolver.ResolveNowOptions)
  • func (r *Resolver) Scheme() string

Functions

func GetConn

func GetConn(schema, serviceName string, etcdCfg *EtcdCfg) (*grpc.ClientConn, error)

func GetPrefix

func GetPrefix(schema, serviceName string) string

"%s:///%s/"

func Int32ToString

func Int32ToString(i int32) string

func OperationIDGenerator

func OperationIDGenerator() string

func RegisterEtcd

func RegisterEtcd(schema string, cfg *EtcdCfg, myHost string, myPort int, serviceName string, ttl int) (err error)

etcdAddr separated by commas ttl:单位秒

func UnRegisterEtcd

func UnRegisterEtcd()

Types

type EtcdCfg

type EtcdCfg struct {
	Endpoints []string `json:"endpoints"`
	Username  string   `json:"username"`
	Password  string   `json:"password"`
}

type RegEtcd

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

type Resolver

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

func NewResolver

func NewResolver(schema, serviceName string, etcdCfg *EtcdCfg) (*Resolver, error)

func (*Resolver) Build

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

func (*Resolver) Close

func (r1 *Resolver) Close()

func (*Resolver) ResolveNow

func (r1 *Resolver) ResolveNow(rn resolver.ResolveNowOptions)

func (*Resolver) Scheme

func (r *Resolver) Scheme() string