- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for FromMatch (0.16 sec)
-
tests/integration/security/reachability_test.go
} t.NewSubTestf("%s%s", schemeStr, opts.HTTP.Path).Run(func(t framework.TestContext) { // Run the test cases. echotest.New(t, allServices.Instances()). FromMatch(match.And(c.fromMatch, match.NotProxylessGRPC)). ToMatch(match.And(c.toMatch, match.NotProxylessGRPC)). WithDefaultFilters(1, 1). ConditionallyTo(echotest.NoSelfCalls).
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 02 21:29:40 UTC 2024 - 20.6K bytes - Viewed (0) -
tests/integration/security/pass_through_filter_chain_test.go
trafficPolicy: tls: mode: ISTIO_MUTUAL ---`)). BuildAll(nil, apps.Ns1.All). Apply() echotest.New(t, apps.Ns1.All.Instances()). WithDefaultFilters(1, 1). FromMatch(match.NotProxylessGRPC). ToMatch(match.And( // TODO(nmittler): Why not headless/multiversion? match.NotHeadless, match.NotMultiVersion, match.NotNaked,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 11.9K bytes - Viewed (0) -
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) -
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) -
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) -
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)