Fix to check error of watch response

Signed-off-by: morimoto-cybozu <[email protected]>
cybozu-go · Jul 26, 2023 · 67b75a9 · 67b75a9
1 parent a37e5a9
commit 67b75a9
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/agent/agent.go b/agent/agent.go
@@ -37,6 +37,10 @@ func (a *Agent) StartWatching(ctx context.Context, updateCh chan<- struct{}) err
 		clientv3.WithProgressNotify(),
 	)
 	for wresp := range rch {
+		if err := wresp.Err(); err != nil {
+			return err
+		}
+
 		atomic.StoreInt64(&a.rev, wresp.Header.Revision)
 
 		// notify updater if possible