File tree 1 file changed +5
-3
lines changed
1 file changed +5
-3
lines changed Original file line number Diff line number Diff line change @@ -14,6 +14,7 @@ import (
14
14
15
15
"github.com/cenkalti/backoff/v4"
16
16
"github.com/ovn-org/libovsdb/client"
17
+ "github.com/ovn-org/libovsdb/ovsdb"
17
18
"k8s.io/klog/v2"
18
19
19
20
"github.com/kubeovn/kube-ovn/pkg/ovsdb/ovnnb"
@@ -92,15 +93,16 @@ func NewNbClient(addr string) (client.Client, error) {
92
93
return nil , err
93
94
}
94
95
95
- monitorOpts := []client. MonitorOption {
96
+ monitor := c . NewMonitor (
96
97
client .WithTable (& ovnnb.LogicalRouter {}),
97
98
client .WithTable (& ovnnb.LogicalRouterPort {}),
98
99
client .WithTable (& ovnnb.LogicalRouterPolicy {}),
99
100
client .WithTable (& ovnnb.LogicalRouterStaticRoute {}),
100
101
client .WithTable (& ovnnb.LogicalSwitchPort {}),
101
102
client .WithTable (& ovnnb.PortGroup {}),
102
- }
103
- if _ , err = c .Monitor (context .TODO (), c .NewMonitor (monitorOpts ... )); err != nil {
103
+ )
104
+ monitor .Method = ovsdb .ConditionalMonitorRPC
105
+ if _ , err = c .Monitor (context .TODO (), monitor ); err != nil {
104
106
klog .Errorf ("failed to monitor database on OVN NB server %s: %v" , addr , err )
105
107
return nil , err
106
108
}
You can’t perform that action at this time.
0 commit comments