xds: generic xds client ads stream implementation

purnesh42H · Feb 20, 2025 · 081938f · 081938f
1 parent 0f2371c
commit 081938f
Show file tree

Hide file tree

Showing 4 changed files with 1,089 additions and 1 deletion.
diff --git a/xds/internal/clients/grpctransport/grpc_transport_test.go b/xds/internal/clients/grpctransport/grpc_transport_test.go
@@ -294,7 +294,7 @@ func (s) TestStream_SendAndRecv(t *testing.T) {
 	// server.
 	var gotRes v3discoverypb.DiscoveryResponse
 	if err := proto.Unmarshal(res, &gotRes); err != nil {
-		t.Fatalf("Failed to unmarshal response from ts.requestChan to DiscoveryRequest: %v", err)
+		t.Fatalf("Failed to unmarshal response from ts.requestChan to DiscoveryResponse: %v", err)
 	}
 	if !cmp.Equal(&gotRes, ts.response, protocmp.Transform()) {
 		t.Fatalf("proto.Unmarshal(res, &gotRes) = %v, want %v", &gotRes, ts.response)