- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for NewTest (0.59 sec)
-
tests/integration/ambient/waypoint_test.go
kubetest "istio.io/istio/pkg/test/kube" "istio.io/istio/pkg/test/scopes" "istio.io/istio/pkg/test/util/retry" ) func TestWaypointStatus(t *testing.T) { framework. NewTest(t). Run(func(t framework.TestContext) { client := t.Clusters().Default().GatewayAPI().GatewayV1beta1().GatewayClasses() check := func() error {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 11.4K bytes - Viewed (0) -
pkg/test/framework/test.go
minIstioVersion string minKubernetesMinorVersion uint topLevel bool ctx *testContext tc context2.Context ts traceapi.Span } // NewTest returns a new test wrapper for running a single test. func NewTest(t *testing.T) Test { rtMu.Lock() defer rtMu.Unlock() if rt == nil { panic("call to scope without running the test framework") }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 10.3K bytes - Viewed (0) -
tests/integration/pilot/gateway_test.go
"istio.io/istio/pkg/test/util/assert" "istio.io/istio/pkg/test/util/retry" ingressutil "istio.io/istio/tests/integration/security/sds_ingress/util" ) func TestGateway(t *testing.T) { framework. NewTest(t). Run(func(t framework.TestContext) { crd.DeployGatewayAPIOrSkip(t) t.NewSubTest("unmanaged").Run(UnmanagedGatewayTest) t.NewSubTest("managed").Run(ManagedGatewayTest)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 17.7K bytes - Viewed (0) -
tests/integration/pilot/ingress_test.go
t.Skip("IngressClass not supported") } } // TestIngress tests that we can route using standard Kubernetes Ingress objects. func TestIngress(t *testing.T) { framework. NewTest(t). Run(func(t framework.TestContext) { skipIfIngressClassUnsupported(t) // Set up secret contain some TLS certs for *.example.com
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 19.5K bytes - Viewed (0) -
tests/integration/telemetry/api/dashboard_test.go
"container_cpu_usage_seconds_total", }, false, }, */ } func TestDashboard(t *testing.T) { c, cancel := context.WithCancel(context.Background()) defer cancel() framework.NewTest(t). Run(func(t framework.TestContext) { p := promInst t.ConfigIstio().YAML(apps.Namespace.Name(), fmt.Sprintf(gatewayConfig, apps.Namespace.Name())). ApplyOrFail(t)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 20:46:28 UTC 2024 - 11.4K bytes - Viewed (0) -
pkg/test/framework/components/echo/echotest/filters_test.go
} if len(expected) > 0 { t.Errorf("did not include %v", expected) } } func TestRun(t *testing.T) { // source svc/cluster -> dest services -> number of subtests (should == num clusters) framework.NewTest(t).Run(func(t framework.TestContext) { tests := map[string]struct { run func(t framework.TestContext, testTopology map[string]map[string]int) expect map[string]map[string]int }{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 13.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache.go
removedEventSinceRelist bool // store will effectively support LIST operation from the "end of cache // history" i.e. from the moment just after the newest cached watched event. // It is necessary to effectively allow clients to start watching at now. // NOTE: We assume that <store> is thread-safe. store cache.Indexer
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 10:20:57 UTC 2024 - 26.2K bytes - Viewed (0)