xdsclient: new Transport interface and ADS stream implementation (#7721)

grpc · Oct 17, 2024 · 830135e · 830135e
1 parent d2ded4b
commit 830135e
Show file tree

Hide file tree

Showing 4 changed files with 815 additions and 5 deletions.
diff --git a/xds/internal/xdsclient/internal/internal.go b/xds/internal/xdsclient/internal/internal.go
@@ -25,4 +25,10 @@ var (
 
 	// NewADSStream returns a new ADS stream.
 	NewADSStream any // func(context.Context, *grpc.ClientConn) (v3adsgrpc.AggregatedDiscoveryService_StreamAggregatedResourcesClient, error)
+
+	// ResourceWatchStateForTesting gets the watch state for the resource
+	// identified by the given resource type and resource name. Returns a
+	// non-nil error if there is no such resource being watched.
+	ResourceWatchStateForTesting any // func(xdsclient.XDSClient, xdsresource.Type, string) error
+
 )