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 GetSchemaAddress(serverName string) string
- func Remove(s []resolver.Address, addr resolver.Address) ([]resolver.Address, bool)
- type Register
- type Resolver
- type Server
Constants ¶
View Source
const (
SCHEMA = "etcd:///"
)
Variables ¶
This section is empty.
Functions ¶
func BuildPrefix ¶
func BuildRegPath ¶
func BuildResolverUrl ¶
func GetSchemaAddress ¶ added in v0.0.6
Types ¶
type Register ¶
type Register struct { EtcdAddrs []string DialTimeout int // contains filtered or unexported fields }
Register for grpc server
func NewRegister ¶
NewRegister create a register base on etcd
func (*Register) GetServerInfo ¶
func (*Register) Register ¶
func (r *Register) Register(srvInfo Server, ttl int64, username, password string) (chan<- struct{}, error)
Register a service
func (*Register) UpdateHandler ¶
func (r *Register) UpdateHandler() http.HandlerFunc
UpdateHandler return http handler
type Resolver ¶
type Resolver struct { EtcdAddrs []string DialTimeout int // contains filtered or unexported fields }
Resolver for grpc client
func NewResolver ¶
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) ResolveNow ¶
func (r *Resolver) ResolveNow(o resolver.ResolveNowOptions)
ResolveNow resolver.Resolver interface
Click to show internal directories.
Click to hide internal directories.