Versions in this module Expand all Collapse all v0 v0.1.4 Jul 31, 2024 Changes in this version + var DialTimeout = 3 + 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 struct + DialTimeout int + EtcdAddrs []string + 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 struct + DialTimeout int + EtcdAddr []string + 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 struct + Addr string + Metadata interface{} + Name string + Version string + func ParseValue(value []byte) (Server, error) + func SplitPath(path string) (Server, error)
Go to main page