diff --git a/docs/operator/crd-api.md b/docs/operator/crd-api.md index 8e74d0a1c1..0bb41df8fa 100644 --- a/docs/operator/crd-api.md +++ b/docs/operator/crd-api.md @@ -4813,6 +4813,7 @@ This type is shared with the Kubernetes operator CRD (VirtualMCPServer.Status.Di | `circuitBreakerState` _string_ | CircuitBreakerState is the current circuit breaker state (closed, open, half-open).
Empty when circuit breaker is disabled or not configured. | | Enum: [closed open half-open]
Optional: \{\}
| | `circuitLastChanged` _[Time](https://kubernetes.io/docs/reference/generated/kubernetes-api/v1.27/#time-v1-meta)_ | CircuitLastChanged is the timestamp when the circuit breaker state last changed.
Empty when circuit breaker is disabled or has never changed state. | | Optional: \{\}
| | `consecutiveFailures` _integer_ | ConsecutiveFailures is the current count of consecutive health check failures.
Resets to 0 when the backend becomes healthy again. | | Optional: \{\}
| +| `mcpRevision` _string_ | MCPRevision is the backend's negotiated MCP protocol revision
("2026-07-28" or "2025-11-25"). Empty when the backend has not been probed. | | Optional: \{\}
| diff --git a/pkg/vmcp/client/schema_ingestion_regression_test.go b/pkg/vmcp/client/schema_ingestion_regression_test.go index 628245c3f2..e44f18d1c3 100644 --- a/pkg/vmcp/client/schema_ingestion_regression_test.go +++ b/pkg/vmcp/client/schema_ingestion_regression_test.go @@ -108,20 +108,19 @@ func TestRegression_ToolSchemaFidelity_PreservesCompositors(t *testing.T) { })) t.Cleanup(srv.Close) - h := &httpBackendClient{ - clientFactory: func(ctx context.Context, target *vmcp.BackendTarget, _ bool) (*client.Client, error) { - c, err := client.NewStreamableHttpClient( - target.BaseURL, - mcptransport.WithHTTPTimeout(30*time.Second), - ) - if err != nil { - return nil, err - } - if err := c.Start(ctx); err != nil { - return nil, err - } - return c, nil - }, + h := newProbeClient(t) + h.clientFactory = func(ctx context.Context, target *vmcp.BackendTarget, _ bool) (*client.Client, error) { + c, err := client.NewStreamableHttpClient( + target.BaseURL, + mcptransport.WithHTTPTimeout(30*time.Second), + ) + if err != nil { + return nil, err + } + if err := c.Start(ctx); err != nil { + return nil, err + } + return c, nil } target := &vmcp.BackendTarget{