Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for SetName (0.34 sec)

  1. pilot/pkg/model/telemetry_test.go

    						res[f.GetName()] = string(cfgJSON)
    					} else {
    						w := &httpwasm.Wasm{}
    
    						if err := f.GetTypedConfig().UnmarshalTo(w); err != nil {
    							t.Fatal(err)
    						}
    						cfg := &wrappers.StringValue{}
    						if err := w.GetConfig().GetConfiguration().UnmarshalTo(cfg); err != nil {
    							t.Fatal(err)
    						}
    						if _, dupe := res[f.GetName()]; dupe {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:30 UTC 2024
    - 39.6K bytes
    - Viewed (0)
  2. pilot/pkg/xds/delta_test.go

    	assertResources := func(resp *discovery.DeltaDiscoveryResponse, names ...string) {
    		t.Helper()
    		got := slices.Map(resp.Resources, (*discovery.Resource).GetName)
    
    		assert.Equal(t, sets.New(got...), sets.New(names...).Merge(base))
    	}
    	s := xds.NewFakeDiscoveryServer(t, xds.FakeOptions{})
    	addTestClientEndpoints(s.MemRegistry)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 15.2K bytes
    - Viewed (0)
  3. pilot/pkg/simulation/traffic.go

    		}
    	}
    	if !anySet {
    		log.Debugf("%v: none set, skipping", desc)
    		return chains
    	}
    	for i, c := range chains {
    		if match(c.GetFilterChainMatch()) {
    			log.Debugf("%v: matched chain %v/%v", desc, i, c.GetName())
    			res = append(res, c)
    		}
    	}
    	// Return all matching filter chains
    	if len(res) > 0 {
    		return res
    	}
    	// Unless there were no matches - in which case we return all filter chains that did not have a
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 19.4K bytes
    - Viewed (0)
Back to top