commit
e55e5033b8
@ -10,8 +10,8 @@ import (
|
|||||||
|
|
||||||
type consulWatcher struct {
|
type consulWatcher struct {
|
||||||
r *consulRegistry
|
r *consulRegistry
|
||||||
wp *watch.WatchPlan
|
wp *watch.Plan
|
||||||
watchers map[string]*watch.WatchPlan
|
watchers map[string]*watch.Plan
|
||||||
|
|
||||||
next chan *Result
|
next chan *Result
|
||||||
exit chan bool
|
exit chan bool
|
||||||
@ -25,7 +25,7 @@ func newConsulWatcher(cr *consulRegistry) (Watcher, error) {
|
|||||||
r: cr,
|
r: cr,
|
||||||
exit: make(chan bool),
|
exit: make(chan bool),
|
||||||
next: make(chan *Result, 10),
|
next: make(chan *Result, 10),
|
||||||
watchers: make(map[string]*watch.WatchPlan),
|
watchers: make(map[string]*watch.Plan),
|
||||||
services: make(map[string][]*Service),
|
services: make(map[string][]*Service),
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user