- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 89 for GW (0.04 sec)
-
pilot/pkg/config/kube/gateway/deploymentcontroller_test.go
util.CompareContent(t, resp, filepath.Join("testdata", "deployment", tt.name+".yaml")) } // ensure we didn't mutate the object if !tt.ignore { assert.Equal(t, d.gateways.Get(tt.gw.Name, tt.gw.Namespace), &tt.gw) } }) } } func buildFilter(allowedNamespace string) kubetypes.DynamicObjectFilter { return kubetypes.NewStaticObjectFilter(func(obj any) bool { if ns, ok := obj.(string); ok {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 21:43:20 UTC 2024 - 16.5K bytes - Viewed (0) -
pilot/pkg/xds/endpoints/ep_filters.go
gateways = model.SortGateways(gateways) // Create endpoints for the gateways. for _, gw := range gateways { epWeight := gatewayWeights[gw] if epWeight == 0 { log.Warnf("gateway weight must be greater than 0, scaleFactor is %d", scaleFactor) epWeight = 1 } epAddr := util.BuildAddress(gw.Addr, gw.Port) // Generate a fake IstioEndpoint to carry network and cluster information.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 01:17:58 UTC 2024 - 9.1K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/network.go
for _, gw := range gateways { // what we now have is a service port. If there is a mapping for cluster external ports, // look it up and get the node port for the remote port if nodePort, exists := nodePortMap[gw.Port]; exists { gw.Port = nodePort } gw.Cluster = n.clusterID gw.Addr = addr newGateways.Insert(gw) } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 22:23:22 UTC 2024 - 15.4K bytes - Viewed (0) -
pkg/config/analysis/analyzers/gateway/secret.go
gw := r.Message.(*v1alpha3.Gateway) gwNs := getGatewayNamespace(ctx, gw) // If we can't find a namespace for the gateway, it's because there's no matching selector. Exit early with a different message. if gwNs == "" { gwSelector := labels.SelectorFromSet(gw.Selector) m := msg.NewReferencedResourceNotFound(r, "selector", labels.SelectorFromSet(gw.Selector).String())
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 04 18:29:24 UTC 2023 - 3.9K bytes - Viewed (0) -
pkg/config/analysis/analyzers/gateway/conflictinggateway.go
gwCMap map[string]map[string][]string, ) { gw := r.Message.(*v1alpha3.Gateway) gwName := r.Metadata.FullName.String() // For pods selected by gw.Selector, find Services that select them and remember those ports gwSelector := klabels.SelectorFromSet(gw.Selector) sGWSelector := gwSelector.String() // Check non-exist gateway with particular selector isExists := false
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun May 05 03:44:57 UTC 2024 - 4.7K bytes - Viewed (0) -
pilot/pkg/model/network.go
byNetwork := make(map[network.ID][]NetworkGateway) byNetworkAndCluster := make(map[networkAndCluster][]NetworkGateway) for gw := range gatewaySet { byNetwork[gw.Network] = append(byNetwork[gw.Network], gw) nc := networkAndClusterForGateway(&gw) byNetworkAndCluster[nc] = append(byNetworkAndCluster[nc], gw) } var gwNum []int // Sort the gateways in byNetwork, and also calculate the max number // of gateways per network.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 24 03:31:28 UTC 2023 - 16.9K bytes - Viewed (0) -
internal/logger/logrotate.go
return err } defer r.Close() gw, err := os.Create(oldLgFile + ".gz") if err != nil { return err } defer gw.Close() var wc io.WriteCloser wc = gzip.NewWriter(gw) if _, err = io.Copy(wc, r); err != nil { return err } if err = wc.Close(); err != nil { return err } // Persist to disk any caches. if err = gw.Sync(); err != nil { return err }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5.8K bytes - Viewed (0) -
tests/integration/security/testdata/authz/not-host.yaml.tmpl
apiVersion: networking.istio.io/v1beta1 kind: Gateway metadata: name: gw-{{ .To.ServiceName }} spec: selector: istio: {{.GatewayIstioLabel | default "ingressgateway"}} servers: - port: number: 80 name: http protocol: HTTP hosts: - "*.{{ .To.ServiceName }}.com" --- apiVersion: networking.istio.io/v1beta1 kind: VirtualService metadata: name: vw-{{ .To.ServiceName }} spec:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 08 07:03:01 UTC 2023 - 1K bytes - Viewed (0) -
tests/integration/pilot/testdata/tunneling/gateway/tls/istio-mutual/virtual-service.tmpl.yaml
apiVersion: networking.istio.io/v1alpha3 kind: VirtualService metadata: name: mesh-route-outbound-traffic-to-external-svc-via-egress-gw spec: hosts: - external.{{ .externalNamespace }}.svc.cluster.local gateways: - mesh tcp: - match: - port: {{ .externalSvcTcpPort }} route: - destination:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jul 05 17:19:27 UTC 2023 - 1.6K bytes - Viewed (0) -
tests/integration/pilot/testdata/tunneling/gateway/tls/passthrough/virtual-service.tmpl.yaml
apiVersion: networking.istio.io/v1alpha3 kind: VirtualService metadata: name: mesh-route-outbound-traffic-to-external-svc-via-egress-gw spec: hosts: - external.{{ .externalNamespace }}.svc.cluster.local gateways: - mesh tcp: - match: - port: {{ .externalSvcTcpPort }} route: - destination:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jul 05 17:19:27 UTC 2023 - 1.6K bytes - Viewed (0)