diff options
| author | FUJITA Tomonori <fujita.tomonori@lab.ntt.co.jp> | 2018-10-29 18:59:09 +0900 |
|---|---|---|
| committer | FUJITA Tomonori <fujita.tomonori@lab.ntt.co.jp> | 2018-11-07 20:19:23 +0900 |
| commit | df8ad76b5ca5316ae2a9ca88c5aa6af5f2dc9b4e (patch) | |
| tree | f811d7694ca0cf98613e6e09684356ad98322774 /pkg/server/zclient.go | |
| parent | 96c129e5d0cc91a2b291527898e70093545e54b6 (diff) | |
server: unexported Watcher stuff
Replace it with the new API using api/.
Signed-off-by: FUJITA Tomonori <fujita.tomonori@lab.ntt.co.jp>
Diffstat (limited to 'pkg/server/zclient.go')
| -rw-r--r-- | pkg/server/zclient.go | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/pkg/server/zclient.go b/pkg/server/zclient.go index c4abd12b..33190591 100644 --- a/pkg/server/zclient.go +++ b/pkg/server/zclient.go @@ -331,9 +331,9 @@ func (z *zebraClient) updatePathByNexthopCache(paths []*table.Path) { } func (z *zebraClient) loop() { - w := z.server.Watch([]WatchOption{ - WatchBestPath(true), - WatchPostUpdate(true), + w := z.server.watch([]watchOption{ + watchBestPath(true), + watchPostUpdate(true), }...) defer w.Stop() @@ -368,7 +368,7 @@ func (z *zebraClient) loop() { } case ev := <-w.Event(): switch msg := ev.(type) { - case *WatchEventBestPath: + case *watchEventBestPath: if table.UseMultiplePaths.Enabled { for _, paths := range msg.MultiPathList { z.updatePathByNexthopCache(paths) @@ -398,7 +398,7 @@ func (z *zebraClient) loop() { } } } - case *WatchEventUpdate: + case *watchEventUpdate: if body := newNexthopRegisterBody(msg.PathList, z.nexthopCache); body != nil { vrfID := uint32(0) for _, vrf := range z.server.listVrf() { |