xdsclient: ADS stream implementation

easwars · Oct 9, 2024 · 2eae427 · 2eae427
1 parent 4115c21
commit 2eae427
Show file tree

Hide file tree

Showing 5 changed files with 1,088 additions and 1 deletion.
diff --git a/xds/internal/xdsclient/internal/internal.go b/xds/internal/xdsclient/internal/internal.go
@@ -20,6 +20,15 @@ package internal
 
 // The following vars can be overridden by tests.
 var (
-	// NewADSStream is a function that returns a new ADS stream.
+	// GRPCNewClient returns a new gRPC Client.
+	GRPCNewClient any // func(string, ...grpc.DialOption) (*grpc.ClientConn, error)
+
+	// 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
+
 )