- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 48 for ingr (0.04 sec)
-
pilot/pkg/config/kube/ingress/controller.go
jn := ingr[j].Name + "." + ingr[j].Namespace return in < jn } return ingr[i].CreationTimestamp.Before(&ingr[j].CreationTimestamp) }) return ingr } func (c *controller) List(typ config.GroupVersionKind, namespace string) []config.Config { if typ != gvk.Gateway && typ != gvk.VirtualService { return nil } out := make([]config.Config, 0)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 06 03:53:05 UTC 2024 - 11.9K bytes - Viewed (0) -
pkg/test/framework/components/echo/echotest/run.go
doTest := func(ctx framework.TestContext, fromCluster cluster.Cluster, dst echo.Instances) { ingr := istioInstance.IngressFor(fromCluster) if ingr == nil { ctx.Skipf("no ingress for %s", fromCluster.StableName()) } testFn(ctx, ingr, dst) } if len(ctx.Clusters()) == 1 { doTest(ctx, ctx.Clusters()[0], dstInstances) } else {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Sep 27 22:08:42 UTC 2023 - 13K bytes - Viewed (0) -
tests/integration/pilot/gateway_test.go
kind: Secret `, apps.Namespace.Name())). ApplyOrFail(t) for _, ingr := range istio.IngressesOrFail(t, t) { t.NewSubTest(ingr.Cluster().StableName()).Run(func(t framework.TestContext) { t.NewSubTest("http").Run(func(t framework.TestContext) { paths := []string{"/get", "/get/", "/get/prefix"} for _, path := range paths { _ = ingr.CallOrFail(t, echo.CallOptions{ Port: echo.Port{
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
}, Check: successChecker, Count: count, }, path: "/test", prefixPath: "/prefix", }, } for _, ingr := range istio.IngressesOrFail(t, t) { ingr := ingr t.NewSubTestf("from %s", ingr.Cluster().StableName()).Run(func(t framework.TestContext) { for _, c := range cases { c := c t.NewSubTest(c.name).Run(func(t framework.TestContext) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 19.5K bytes - Viewed (0) -
pilot/test/xds/fake.go
} defaultKubeController = k8s } else { client.RunAndWait(stop) } registries = append(registries, k8s) mc.Add(k8sCluster, client, stop) } stop := test.NewStop(t) ingr := ingress.NewController(defaultKubeClient, mesh.NewFixedWatcher(m), kube.Options{ DomainSuffix: "cluster.local", }) defaultKubeClient.RunAndWait(stop) var gwc *gateway.Controller
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 16:08:52 UTC 2024 - 18.4K bytes - Viewed (0) -
tests/integration/telemetry/api/dashboard_test.go
times := 0 for { select { case <-ticker.C: times++ scopes.Framework.Infof("sending traffic %v", times) for _, ing := range ingr { hosts, ports := ing.TCPAddresses() host := hosts[0] port := ports[0] _, err := ing.Call(echo.CallOptions{ Port: echo.Port{ Protocol: protocol.HTTP, }, Count: 10, HTTP: echo.HTTP{
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/istio/kube.go
} if _, ok := i.ingress[c.Name()][labelSelector]; !ok { ingr := newIngress(i.ctx, ingressConfig{ Cluster: c, Service: service, LabelSelector: labelSelector, }) if closer, ok := ingr.(io.Closer); ok { i.ctx.Cleanup(func() { _ = closer.Close() }) } i.ingress[c.Name()][labelSelector] = ingr } return i.ingress[c.Name()][labelSelector] }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 31.1K bytes - Viewed (0) -
pkg/kubelet/cm/topologymanager/topology_manager_test.go
&mockHintProvider{}, &mockHintProvider{}, &mockHintProvider{}, }, }, } mngr := manager{} mngr.scope = NewContainerScope(NewNonePolicy()) for _, tc := range tcases { for _, hp := range tc.hp { mngr.AddHintProvider(hp) } if len(tc.hp) != len(mngr.scope.(*containerScope).hintProviders) { t.Errorf("error") } } } func TestAdmit(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 11 13:04:32 UTC 2023 - 13.8K bytes - Viewed (0) -
tests/integration/security/sds_ingress/ingress_test.go
ingressutil.IngressCredentialA, false) ing := inst.IngressFor(t.Clusters().Default()) if ing == nil { t.Skip() } tlsContextA := ingressutil.TLSContext{CaCert: ingressutil.CaCertA} tlsContextB := ingressutil.TLSContext{CaCert: ingressutil.CaCertB} // Verify the call works ingressutil.SendRequestOrFail(t, ing, host, credName, ingressutil.TLS, tlsContextA,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 32.7K bytes - Viewed (0) -
tests/integration/security/sds_ingress/util/util.go
func SendRequestOrFail(ctx framework.TestContext, ing ingress.Instance, host string, path string, callType CallType, tlsCtx TLSContext, exRsp ExpectedResponse, ) { doSendRequestsOrFail(ctx, ing, host, path, callType, tlsCtx, exRsp, false /* useHTTP3 */) } func SendQUICRequestsOrFail(ctx framework.TestContext, ing ingress.Instance, host string, path string,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jul 25 05:12:36 UTC 2023 - 20.2K bytes - Viewed (0)