add nameresolver interface
This commit is contained in:
@ -63,6 +63,13 @@ func (b *recvBuffer) stop() {
|
|||||||
b.mu.Unlock()
|
b.mu.Unlock()
|
||||||
}
|
}
|
||||||
|
|
||||||
|
type NameResolver interface {
|
||||||
|
Get(target string) map[string]string
|
||||||
|
Watch(target string)
|
||||||
|
GetUpdate() *namePair
|
||||||
|
Stop()
|
||||||
|
}
|
||||||
|
|
||||||
type etcdNR struct {
|
type etcdNR struct {
|
||||||
cfg etcdcl.Config
|
cfg etcdcl.Config
|
||||||
recv *recvBuffer
|
recv *recvBuffer
|
||||||
|
Reference in New Issue
Block a user