Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 16 of 16 for FromMatch (0.21 sec)

  1. tests/integration/security/policy_attachment_only/jwt_gateway_test.go

    	var all []echo.Instance
    	for _, e := range echos {
    		all = append(all, e...)
    	}
    
    	return echotest.New(t, all).
    		WithDefaultFilters(1, 1).
    		FromMatch(match.And(
    			match.NotNaked,
    			match.NotProxylessGRPC)).
    		ToMatch(match.And(
    			match.NotNaked,
    			match.NotProxylessGRPC)).
    		ConditionallyTo(echotest.NoSelfCalls)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Apr 08 22:02:59 UTC 2024
    - 9.7K bytes
    - Viewed (0)
  2. pkg/test/framework/components/echo/echotest/filters_test.go

    					},
    				},
    			},
    			"RunToN": {
    				run: func(t framework.TestContext, testTopology map[string]map[string]int) {
    					echotest.New(t, all).
    						WithDefaultFilters(1, 1).
    						FromMatch(match.And(match.NotNaked, match.NotHeadless)).
    						ToMatch(match.NotHeadless).
    						RunToN(3, func(ctx framework.TestContext, from echo.Instance, dsts echo.Services) {
    							srcKey := from.Config().ClusterLocalFQDN()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 22:12:34 UTC 2024
    - 13.1K bytes
    - Viewed (0)
  3. tests/integration/pilot/common/traffic.go

    				// we only apply to config clusters
    				scope := t.ConfigIstio()
    				if c.globalConfig {
    					scope = t.ConfigKube()
    				}
    				return scope.YAML("", cfg).Apply()
    			}).
    			FromMatch(match.And(c.sourceMatchers...)).
    			// TODO mainly testing proxyless features as a client for now
    			ToMatch(match.And(append(c.targetMatchers, match.NotProxylessGRPC)...)).
    			WithDefaultFilters(1, c.toN).
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jan 03 19:10:01 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  4. tests/integration/security/egress_gateway_origination_test.go

    				}
    				return nil
    			})),
    	}
    }
    
    func newTLSGatewayTest(t framework.TestContext) *echotest.T {
    	return echotest.New(t, apps.All.Instances()).
    		WithDefaultFilters(1, 1).
    		FromMatch(match.And(
    			match.Namespace(apps.Ns1.Namespace),
    			match.NotNaked,
    			match.NotProxylessGRPC)).
    		ToMatch(match.ServiceName(apps.External.All.NamespacedName()))
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Apr 08 22:02:59 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  5. tests/integration/pilot/mcs/discoverability/discoverability_test.go

    func runForAllClusterCombinations(
    	t framework.TestContext,
    	fn func(t framework.TestContext, from echo.Instance, to echo.Target),
    ) {
    	t.Helper()
    	echotest.New(t, echos.Instances).
    		WithDefaultFilters(1, 1).
    		FromMatch(serviceA).
    		ToMatch(serviceB).
    		Run(fn)
    }
    
    func newServiceExport(service string, serviceExportGVR schema.GroupVersionResource) *mcsapi.ServiceExport {
    	return &mcsapi.ServiceExport{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Apr 08 22:02:59 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  6. tests/integration/ambient/baseline_test.go

    					t.NewSubTestf("%s %s %s", tc.location, tc.resolution, ip).Run(func(t framework.TestContext) {
    						echotest.
    							New(t, apps.All).
    							// TODO eventually we can do this for uncaptured -> l7
    							FromMatch(match.Not(match.ServiceName(echo.NamespacedName{
    								Name:      "uncaptured",
    								Namespace: apps.Namespace,
    							}))).
    							Config(cfg.WithParams(param.Params{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 12 00:07:28 UTC 2024
    - 78.4K bytes
    - Viewed (0)
Back to top