- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for ingr (0.07 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/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) -
cluster/gce/windows/smoke-test.sh
local service_port service_port=$($kubectl get service --namespace kube-system $service \ -o jsonpath='{.spec.ports[?(@.protocol=="TCP")].port}') echo "curl-ing $service address from Linux pod: $service_ip:$service_port" # curl-ing the metrics-server service downloads 14 bytes of unprintable binary # data and sets a return code of success (0). if ! $kubectl exec "$linux_command_pod" -- \
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 24 07:02:51 UTC 2024 - 20.6K bytes - Viewed (0) -
pkg/apis/core/v1/defaults.go
} if obj.Spec.Type == v1.ServiceTypeLoadBalancer { if utilfeature.DefaultFeatureGate.Enabled(features.LoadBalancerIPMode) { ipMode := v1.LoadBalancerIPModeVIP for i, ing := range obj.Status.LoadBalancer.Ingress { if ing.IP != "" && ing.IPMode == nil { obj.Status.LoadBalancer.Ingress[i].IPMode = &ipMode } } } } } func SetDefaults_Pod(obj *v1.Pod) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 19 22:24:15 UTC 2024 - 14.8K bytes - Viewed (0) -
src/internal/trace/gc.go
if g := r.Scope.Goroutine(); g != NoGoroutine { inGC[g] = true } } case EventRangeEnd: r := ev.Range() if handleSTW(r) { stw-- } else if handleSweep(r) { ps[ev.Proc()].gc-- } else if handleMarkAssist(r) { ps[ev.Proc()].gc-- if g := r.Scope.Goroutine(); g != NoGoroutine { delete(inGC, g) } } case EventStateTransition:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 26K bytes - Viewed (0)