etcdserver/api/v3rpc/watch.go
func NewWatchServer(s *etcdserver.EtcdServer) pb.WatchServer {
	return &watchServer{
		lg: s.Cfg.Logger,

		clusterID: int64(s.Cluster().ID()),
		memberID:  int64(s.ID()),

		maxRequestBytes: int(s.Cfg.MaxRequestBytes + grpcOverheadBytes),

		sg:        s,
		watchable: s.Watchable(),
		ag:        s,
	}
}
func NewWatchServer(s *etcdserver.EtcdServer) pb.WatchServer {
	return &watchServer{
		lg: s.Cfg.Logger,

		clusterID: int64(s.Cluster().ID()),
		memberID:  int64(s.ID()),

		maxRequestBytes: int(s.Cfg.MaxRequestBytes + grpcOverheadBytes),

		sg:        s,
		watchable: s.Watchable(),
		ag:        s,
	}
}
func NewWatchServer ( s * etcdserver . EtcdServer ) pb . WatchServer { return & watchServer { lg : s . Cfg . Logger , clusterID : int64 ( s . Cluster ( ) . ID ( ) ) , memberID : int64 ( s . ID ( ) ) , maxRequestBytes : int ( s . Cfg . MaxRequestBytes + grpcOverheadBytes ) , sg : s , watchable : s . Watchable ( ) , ag : s , } }
// NewWatchServer returns a new watch server.
NewWatchServer returns a new watch server .