- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 36 for SubZone (0.1 sec)
-
pilot/pkg/networking/core/cluster_test.go
locality := localityLbEndpoint.Locality if locality.Region == "region1" && locality.SubZone == "subzone1" { g.Expect(localityLbEndpoint.LoadBalancingWeight.GetValue()).To(Equal(uint32(34))) g.Expect(localityLbEndpoint.LbEndpoints[0].LoadBalancingWeight.GetValue()).To(Equal(uint32(40))) } else if locality.Region == "region1" && locality.SubZone == "subzone2" {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 108.8K bytes - Viewed (0) -
pkg/model/proxy.go
func ConvertLocality(locality string) *core.Locality { if locality == "" { return &core.Locality{} } region, zone, subzone := label.SplitLocalityLabel(locality) return &core.Locality{ Region: region, Zone: zone, SubZone: subzone, } } // ALPNH2Only advertises that Proxy is going to use HTTP/2 when talking to the cluster. var ALPNH2Only = []string{"h2"}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 25 17:18:17 UTC 2024 - 18.7K bytes - Viewed (0) -
pilot/pkg/networking/core/loadbalancer/loadbalancer.go
if loadAssignment.Endpoints[i] != nil { loadAssignment.Endpoints[i].LbEndpoints = nil } } break } } } // set locality loadbalancing priority - This is based on Region/Zone/SubZone matching. func applyLocalityFailover( locality *core.Locality, loadAssignment *endpoint.ClusterLoadAssignment, failover []*v1alpha3.LocalityLoadBalancerSetting_Failover, ) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 23 05:38:57 UTC 2024 - 11.8K bytes - Viewed (0) -
pkg/workloadapi/workload.proto
message LoadBalancing { enum Scope { UNSPECIFIED_SCOPE = 0; // Prefer traffic in the same region. REGION = 1; // Prefer traffic in the same zone. ZONE = 2; // Prefer traffic in the same subzone. SUBZONE = 3; // Prefer traffic on the same node. NODE = 4; // Prefer traffic in the same cluster. CLUSTER = 5; // Prefer traffic in the same network. NETWORK = 6; } enum Mode {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 18:02:35 UTC 2024 - 12.9K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster_builder_test.go
return true } if strings.Compare(endpoints[i].Locality.Zone, endpoints[j].Locality.Zone) < 0 { return true } return strings.Compare(endpoints[i].Locality.SubZone, endpoints[j].Locality.SubZone) < 0 }) } for _, tt := range cases { for _, resolution := range []model.Resolution{model.DNSLB, model.DNSRoundRobinLB} {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 110.4K bytes - Viewed (0) -
pilot/pkg/xds/ads.go
ls, f := proxy.Labels[model.LocalityLabel] if f { return util.ConvertLocality(ls) } return nil } return &core.Locality{ Region: region, Zone: zone, SubZone: subzone, } } // initializeProxy completes the initialization of a proxy. It is expected to be called only after // initProxyMetadata. func (s *DiscoveryServer) initializeProxy(con *Connection) error {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 08:29:05 UTC 2024 - 23.4K bytes - Viewed (0) -
pkg/bootstrap/platform/gcp.go
return &l } r, err := zoneToRegion(loc) if err != nil { log.Warnf("Error fetching GCP region: %v", err) return &l } return &core.Locality{ Region: r, Zone: loc, SubZone: "", // GCP has no subzone concept } } const ComputeReadonlyScope = "https://www.googleapis.com/auth/compute.readonly" // Labels attempts to retrieve the GCE instance labels within the timeout
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Dec 15 00:37:33 UTC 2023 - 11.1K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceregistry_test.go
p := basePod.DeepCopy() p.Labels[model.LocalityLabel] = "r.z.s" return p }(), node: baseNode, expected: &core.Locality{ Region: "r", Zone: "z", SubZone: "s", }, }, { name: "node specific label", pod: basePod, node: func() *v1.Node { p := baseNode.DeepCopy() p.Labels[kubecontroller.NodeRegionLabelGA] = "r"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 51.2K bytes - Viewed (0) -
pkg/bootstrap/option/instances.go
} func Region(value string) Instance { return newOptionOrSkipIfZero("region", value) } func Zone(value string) Instance { return newOptionOrSkipIfZero("zone", value) } func SubZone(value string) Instance { return newOptionOrSkipIfZero("sub_zone", value) } func NodeMetadata(meta *model.BootstrapNodeMetadata, rawMeta map[string]any) Instance {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 17:02:38 UTC 2024 - 9K bytes - Viewed (0) -
pkg/workloadapi/workload.pb.go
Region string `protobuf:"bytes,1,opt,name=region,proto3" json:"region,omitempty"` Zone string `protobuf:"bytes,2,opt,name=zone,proto3" json:"zone,omitempty"` Subzone string `protobuf:"bytes,3,opt,name=subzone,proto3" json:"subzone,omitempty"` } func (x *Locality) Reset() { *x = Locality{} if protoimpl.UnsafeEnabled { mi := &file_workloadapi_workload_proto_msgTypes[4]
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 18:02:35 UTC 2024 - 65.9K bytes - Viewed (0)