- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for WithMetadata (0.29 sec)
-
pilot/pkg/xds/workload_test.go
expect := buildExpect(t) s := xds.NewFakeDiscoveryServer(t, xds.FakeOptions{ KubernetesObjects: []runtime.Object{mkPod("pod", "sa", "127.0.0.1", "not-node")}, }) ads := s.ConnectDeltaADS().WithType(v3.AddressType).WithMetadata(model.NodeMetadata{NodeName: "node"}) ads.Request(&discovery.DeltaDiscoveryRequest{ ResourceNamesSubscribe: []string{"*"}, ResourceNamesUnsubscribe: []string{"*"}, }) ads.ExpectEmptyResponse()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 18 19:09:43 UTC 2024 - 15.9K bytes - Viewed (0) -
pkg/istio-agent/agent_test.go
return a }) meta := proxyConfigToMetadata(t, a.ProxyConfig) if err := test.Wrap(func(t test.Failer) { conn := setupDownstreamConnectionUDS(t, a.AgentConfig.XdsUdsPath) xdsc := xds.NewAdsTest(t, conn).WithMetadata(meta) _ = xdsc.RequestResponseAck(t, nil) }); err == nil { t.Fatalf("connect success with wrong CA") } // change ROOT CA, XDS will success
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 22:12:28 UTC 2024 - 33.4K bytes - Viewed (0)