Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for ForProto (0.09 sec)

  1. pkg/test/util/structpath/instance_test.go

    )
    
    func TestContainSubstring(t *testing.T) {
    	testResponse := &discovery.DiscoveryResponse{
    		VersionInfo: "2019-07-16T10:54:41-07:00/1",
    		TypeUrl:     "some.Random.Type.URL",
    	}
    	validator := structpath.ForProto(testResponse)
    
    	tests := []struct {
    		name    string
    		substrs []string
    		err     bool
    	}{
    		{
    			name:    "Substring exist",
    			substrs: []string{"Random", "Type", "URL", "some"},
    			err:     false,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 11 16:19:15 UTC 2021
    - 1.7K bytes
    - Viewed (0)
  2. pkg/test/util/structpath/instance.go

    )
    
    type Instance struct {
    	structure     any
    	isJSON        bool
    	constraints   []constraint
    	creationError error
    }
    
    type constraint func() error
    
    // ForProto creates a structpath Instance by marshaling the proto to JSON and then evaluating over that
    // structure. This is the most generally useful form as serialization to JSON also automatically
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jul 25 19:30:47 UTC 2022
    - 9.4K bytes
    - Viewed (0)
  3. pilot/pkg/xds/xds_test.go

    		s := xds.NewFakeDiscoveryServer(t, xds.FakeOptions{})
    		proxy := s.SetupProxy(&model.Proxy{
    			IPAddresses: []string{"10.2.0.1"},
    			ID:          "app3.testns",
    		})
    		structpath.ForProto(xdstest.ToDiscoveryResponse(s.Listeners(proxy))).
    			Exists("{.resources[?(@.address.socketAddress.portValue==15001)]}").
    			Select("{.resources[?(@.address.socketAddress.portValue==15001)]}").
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Mar 27 16:59:05 UTC 2024
    - 13.8K bytes
    - Viewed (0)
  4. tests/integration/security/filebased_tls_origination/egress_gateway_origination_test.go

    // This essentially just waits for the Sidecar to be applied, without sleeping.
    func WaitUntilNotCallable(c echo.Instance, dest echo.Instance) error {
    	accept := func(cfg *admin.ConfigDump) (bool, error) {
    		validator := structpath.ForProto(cfg)
    		for _, port := range dest.Config().Ports {
    			clusterName := clusterName(dest, port)
    			// Ensure that we have an outbound configuration for the target port.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Apr 08 22:02:59 UTC 2024
    - 11.9K bytes
    - Viewed (0)
Back to top