Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for WithMetadata (0.29 sec)

  1. 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)
  2. 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)
Back to top