[Streaming] Set KnownLeader by default when streaming is activated

.changelog/9778.txt

@@ -0,0 +1,3 @@
+```release-note:bug
+streaming: return X-Consul-KnownLeader properly set when using streaming
+```

agent/cache-types/streaming_health_services.go

@@ -156,12 +156,14 @@ func newHealthView(filterExpr string) (*healthView, error) {
 // (IndexedCheckServiceNodes) and update it in place for each event - that
 // involves re-sorting each time etc. though.
 type healthView struct {
-	state  map[string]structs.CheckServiceNode
-	filter filterEvaluator
+	state       map[string]structs.CheckServiceNode
+	filter      filterEvaluator
+	knownLeader bool
 }
 
 // Update implements View
 func (s *healthView) Update(events []*pbsubscribe.Event) error {
+	s.knownLeader = true
 	for _, event := range events {
 		serviceHealth := event.GetServiceHealth()
 		if serviceHealth == nil {
@@ -227,6 +229,9 @@ func (s *healthView) Result(index uint64) (interface{}, error) {
 		Nodes: make(structs.CheckServiceNodes, 0, len(s.state)),
 		QueryMeta: structs.QueryMeta{
 			Index: index,
+			// TODO: fill properly those fields, see https://github.com/hashicorp/consul/issues/9776
+			KnownLeader: s.knownLeader,
+			LastContact: 0,
 		},
 	}
 	for _, node := range s.state {
@@ -238,5 +243,6 @@ func (s *healthView) Result(index uint64) (interface{}, error) {
 }
 
 func (s *healthView) Reset() {
+	s.knownLeader = false
 	s.state = make(map[string]structs.CheckServiceNode)
 }

agent/cache-types/streaming_health_services_test.go

@@ -48,7 +48,8 @@ func TestStreamingHealthServices_EmptySnapshot(t *testing.T) {
 	empty := &structs.IndexedCheckServiceNodes{
 		Nodes: structs.CheckServiceNodes{},
 		QueryMeta: structs.QueryMeta{
-			Index: 1,
+			Index:       1,
+			KnownLeader: true,
 		},
 	}