- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for WithDefaultFilters (0.52 sec)
-
pkg/test/framework/components/echo/echotest/filters_test.go
expect map[string]map[string]int }{ "Run_WithDefaultFilters": { run: func(t framework.TestContext, testTopology map[string]map[string]int) { echotest.New(t, all). WithDefaultFilters(1, 1). Run(func(ctx framework.TestContext, from echo.Instance, to echo.Target) { // TODO if the destinations would change based on which cluster then add cluster to srCkey
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/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) -
tests/integration/pilot/common/traffic.go
}). 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). ConditionallyTo(c.comboFilters...) doTest := func(t framework.TestContext, from echo.Caller, to echo.Services) { buildOpts := func(options echo.CallOptions) echo.CallOptions {
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/security/reachability_test.go
// 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). Run(func(t framework.TestContext, from echo.Instance, to echo.Target) { opts := opts.DeepCopy() opts.To = to
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/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)