- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for WithDefaultFilters (0.46 sec)
-
tests/integration/security/external_ca/reachability_test.go
namespace.ClaimOrFail(t, t, istioCfg.SystemNamespace) from := apps.EchoNamespace.A to := apps.EchoNamespace.B fromAndTo := from.Append(to) echotest.New(t, fromAndTo). WithDefaultFilters(1, 1). FromMatch(match.ServiceName(from.NamespacedName())). ToMatch(match.ServiceName(to.NamespacedName())). Run(func(t framework.TestContext, from echo.Instance, to echo.Target) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 2K bytes - Viewed (0) -
tests/integration/security/cacert_rotation/main_test.go
if err != nil { t.Errorf("failed to get workload cert last update time: %v", err) } // Verify traffic works between a and b echotest.New(t, fromAndTo). WithDefaultFilters(1, 1). FromMatch(match.ServiceName(from.NamespacedName())). ToMatch(match.ServiceName(to.NamespacedName())). Run(func(t framework.TestContext, from echo.Instance, to echo.Target) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 6.6K bytes - Viewed (0) -
pkg/test/framework/components/echo/echotest/filters.go
// ConditionallyTo(echotest.ReachableDestinations). // Run() func (t *T) ConditionallyTo(filters ...CombinationFilter) *T { t.destinationFilters = append(t.destinationFilters, filters...) return t } // WithDefaultFilters applies common filters that work for most tests. // Example: // - The full set of apps is a, b, c, d, e, headless, naked, and vm (one simple pod).
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 29 23:48:45 UTC 2024 - 8.9K bytes - Viewed (0) -
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/security/policy_attachment_only/jwt_gateway_test.go
func newTrafficTest(t framework.TestContext, echos ...echo.Instances) *echotest.T { 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) -
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)