Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 43 for sub_zone (0.17 sec)

  1. pkg/config/validation/agent/validation.go

    					}
    					if regionZoneSubZoneMap[region][zone][subZone] {
    						return fmt.Errorf("locality %s overlap with previous specified ones", locality)
    					}
    					regionZoneSubZoneMap[region][zone][subZone] = true
    				} else {
    					regionZoneSubZoneMap[region][zone] = map[string]bool{subZone: true}
    				}
    			} else {
    				regionZoneSubZoneMap[region] = map[string]map[string]bool{zone: {subZone: true}}
    			}
    		}
    	}
    
    	return nil
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 17 20:06:41 UTC 2024
    - 30.9K bytes
    - Viewed (0)
  2. pilot/pkg/model/service_test.go

    			ServicePortName: "service-port-name",
    			ServiceAccount:  "service-account",
    			Network:         "Network",
    			Locality: Locality{
    				ClusterID: "cluster-id",
    				Label:     "region1/zone1/subzone1",
    			},
    			EndpointPort: 22,
    			LbWeight:     100,
    			TLSMode:      "mutual",
    		},
    	}
    	differingAddr := exampleInstance.DeepCopy()
    	differingAddr.Endpoint.Address = "another-address"
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Mar 28 20:38:02 UTC 2024
    - 13.9K bytes
    - Viewed (0)
  3. pkg/bootstrap/config_test.go

    	defer os.Chdir(dir)
    	// prepare a pod label file
    	tempDir := t.TempDir()
    	os.Chdir(tempDir)
    	os.MkdirAll("./etc/istio/pod/", os.ModePerm)
    	os.WriteFile(constants.PodInfoLabelsPath, []byte(`istio-locality="region.zone.subzone"`), 0o600)
    
    	node, err := GetNodeMetaData(MetadataOptions{
    		ID:                          "test",
    		Envs:                        os.Environ(),
    		ExitOnZeroActiveConnections: true,
    	})
    
    	g := NewWithT(t)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Mar 28 20:38:02 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  4. tests/fuzz/autoregistration_controller_fuzzer.go

    		Template: &v1alpha3.WorkloadEntry{
    			Ports:          map[string]uint32{"http": 80},
    			Labels:         map[string]string{"app": "a"},
    			Network:        "nw0",
    			Locality:       "reg0/zone0/subzone0",
    			Weight:         1,
    			ServiceAccount: "sa-a",
    		},
    	}
    	// A valid Config.
    	// This can be modified to have pseudo-random
    	// values for more randomization.
    	wgA = config.Config{
    		Meta: config.Meta{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Sep 19 20:41:55 UTC 2023
    - 3.4K bytes
    - Viewed (0)
  5. 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)
  6. src/net/netip/uint128.go

    func (u uint128) or(m uint128) uint128 {
    	return uint128{u.hi | m.hi, u.lo | m.lo}
    }
    
    // not returns the bitwise NOT of u.
    func (u uint128) not() uint128 {
    	return uint128{^u.hi, ^u.lo}
    }
    
    // subOne returns u - 1.
    func (u uint128) subOne() uint128 {
    	lo, borrow := bits.Sub64(u.lo, 1, 0)
    	return uint128{u.hi - borrow, lo}
    }
    
    // addOne returns u + 1.
    func (u uint128) addOne() uint128 {
    	lo, carry := bits.Add64(u.lo, 1, 0)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Nov 07 21:28:44 UTC 2022
    - 2.2K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top