From 3ed404633a7d8bd4869d81fe8b804b69ba36c308 Mon Sep 17 00:00:00 2001 From: Xiang Li Date: Tue, 2 Feb 2016 23:24:15 -0800 Subject: [PATCH] v3rpc: add compacted field from wresp --- etcdserver/api/v3rpc/watch.go | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/etcdserver/api/v3rpc/watch.go b/etcdserver/api/v3rpc/watch.go index 8f313919b..df70f556a 100644 --- a/etcdserver/api/v3rpc/watch.go +++ b/etcdserver/api/v3rpc/watch.go @@ -146,9 +146,10 @@ func (sws *serverWatchStream) sendLoop() { } err := sws.gRPCStream.Send(&pb.WatchResponse{ - Header: sws.newResponseHeader(wresp.Revision), - WatchId: int64(wresp.WatchID), - Events: events, + Header: sws.newResponseHeader(wresp.Revision), + WatchId: int64(wresp.WatchID), + Events: events, + Compacted: wresp.Compacted, }) storage.ReportEventReceived() if err != nil {