Explorar o código

grpcproxy: forward Canceled field when broadcasting watch responses

Anthony Romano %!s(int64=8) %!d(string=hai) anos
pai
achega
9581f7676c
Modificáronse 1 ficheiros con 1 adicións e 0 borrados
  1. 1 0
      proxy/grpcproxy/watcher.go

+ 1 - 0
proxy/grpcproxy/watcher.go

@@ -111,6 +111,7 @@ func (w *watcher) send(wr clientv3.WatchResponse) {
 		Header:          &wr.Header,
 		Created:         wr.Created,
 		CompactRevision: wr.CompactRevision,
+		Canceled:        wr.Canceled,
 		WatchId:         w.id,
 		Events:          events,
 	})