- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 28 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) -
tests/integration/telemetry/api/setup_test.go
return err } if err != nil { return err } for _, c := range ctx.Clusters() { ingr = append(ingr, ist.IngressFor(c)) } mockProm = match.ServiceName(echo.NamespacedName{Name: "mock-prom", Namespace: apps.Namespace}).GetMatches(apps.Echos().All.Instances()) promInst, err = prometheus.New(ctx, prometheus.Config{})
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 02 21:29:40 UTC 2024 - 4.7K 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) -
src/cmd/vendor/golang.org/x/telemetry/internal/counter/file.go
// paranoia to make sure the value is legal dayofweek %= 7 if dayofweek < 0 { dayofweek += 7 } today := now.Weekday() incr := dayofweek - today if incr <= 0 { incr += 7 } return int(incr), nil } // rotate checks to see whether the file f needs to be rotated, // meaning to start a new counter file with a different date in the name.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 18.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/services.go
if svc.Spec.ClusterIP != "" && svc.Spec.ClusterIP != v1.ClusterIPNone { res = append(res, svc.Spec.ClusterIP) } for _, ing := range svc.Status.LoadBalancer.Ingress { // IPs are strictly optional for loadbalancers - they may just have a hostname. if ing.IP != "" { res = append(res, ing.IP) } } return res
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 05 12:29:55 UTC 2024 - 7.6K bytes - Viewed (0) -
pkg/proxy/util/utils.go
return service.Spec.ClusterIPs[idx] } } } return "" } func IsVIPMode(ing v1.LoadBalancerIngress) bool { if !utilfeature.DefaultFeatureGate.Enabled(features.LoadBalancerIPMode) { return true // backwards compat } if ing.IPMode == nil { return true } return *ing.IPMode == v1.LoadBalancerIPModeVIP
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 20 11:57:43 UTC 2024 - 7.4K bytes - Viewed (0)