streaming: disable streaming when requesting connect events

Until the correct events are created for terminating gateways.

agent/agent.go

@@ -363,7 +363,13 @@ func New(bd BaseDeps) (*Agent, error) {
 	if bd.RuntimeConfig.UseStreamingBackend {
 		cacheName = cachetype.StreamingHealthServicesName
 	}
-	a.rpcClientHealth = &health.Client{Cache: bd.Cache, NetRPC: &a, CacheName: cacheName}
+	a.rpcClientHealth = &health.Client{
+		Cache:     bd.Cache,
+		NetRPC:    &a,
+		CacheName: cacheName,
+		// Temporarily until streaming supports all connect events
+		CacheNameConnect: cachetype.HealthServicesName,
+	}
 
 	a.serviceManager = NewServiceManager(&a)
 

agent/rpcclient/health/health.go

@@ -10,7 +10,10 @@ import (
 type Client struct {
 	NetRPC NetRPC
 	Cache  CacheGetter
+	// CacheName to use for service health.
 	CacheName string
+	// CacheNameConnect is the name of the cache to use for connect service health.
+	CacheNameConnect string
 }
 
 type NetRPC interface {
@@ -51,7 +54,12 @@ func (c *Client) getServiceNodes(
 		return out, cache.ResultMeta{}, err
 	}
 
-	raw, md, err := c.Cache.Get(ctx, c.CacheName, &req)
+	cacheName := c.CacheName
+	if req.Connect {
+		cacheName = c.CacheNameConnect
+	}
+
+	raw, md, err := c.Cache.Get(ctx, cacheName, &req)
 	if err != nil {
 		return out, md, err
 	}