Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 36 for SubZone (0.31 sec)

  1. pilot/pkg/xds/eds_test.go

    	items := strings.SplitN(proxyLocality, "/", 3)
    	region, zone, subzone := items[0], items[1], items[2]
    	for _, ep := range eps {
    		if ep.GetLocality().Region == region {
    			if ep.GetLocality().Zone == zone {
    				if ep.GetLocality().SubZone == subzone {
    					if ep.GetPriority() != 0 {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Feb 02 20:58:47 UTC 2024
    - 39.6K bytes
    - Viewed (0)
  2. pkg/config/validation/agent/validation_test.go

    			localities: []string{"a/b", "a/b/c"},
    			valid:      false,
    		},
    		{
    			name:       "explicit wildcard subzone overlap",
    			localities: []string{"a/b/*", "a/b/c"},
    			valid:      false,
    		},
    		{
    			name:       "implicit wildcard subzone overlap",
    			localities: []string{"a/b", "a/b/c"},
    			valid:      false,
    		},
    		{
    			name:       "valid localities",
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 17 20:06:41 UTC 2024
    - 39.1K bytes
    - Viewed (0)
  3. pkg/bootstrap/config.go

    			runtimeFlags[k] = v
    		}
    	}
    	return runtimeFlags
    }
    
    func getLocalityOptions(l *core.Locality) []option.Instance {
    	return []option.Instance{option.Region(l.Region), option.Zone(l.Zone), option.SubZone(l.SubZone)}
    }
    
    func getServiceCluster(metadata *model.BootstrapNodeMetadata) string {
    	switch name := metadata.ProxyConfig.ClusterName.(type) {
    	case *meshAPI.ProxyConfig_ServiceCluster:
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 14 17:02:38 UTC 2024
    - 27.6K bytes
    - Viewed (0)
  4. pilot/pkg/networking/util/util.go

    func LocalityToString(l *core.Locality) string {
    	if l == nil {
    		return ""
    	}
    	resp := l.Region
    	if l.Zone == "" {
    		return resp
    	}
    	resp += "/" + l.Zone
    	if l.SubZone == "" {
    		return resp
    	}
    	resp += "/" + l.SubZone
    	return resp
    }
    
    // GetFailoverPriorityLabels returns a byte array which contains failover priorities of the proxy.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 28.5K bytes
    - Viewed (0)
  5. pilot/pkg/serviceregistry/kube/controller/controller.go

    	zone := getLabelValue(node.ObjectMeta, NodeZoneLabelGA, NodeZoneLabel)
    	subzone := getLabelValue(node.ObjectMeta, label.TopologySubzone.Name, "")
    
    	if region == "" && zone == "" && subzone == "" {
    		return ""
    	}
    
    	return region + "/" + zone + "/" + subzone // Format: "%s/%s/%s"
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 41.2K bytes
    - Viewed (0)
  6. pilot/pkg/serviceregistry/serviceentry/conversion_test.go

    					Labels: map[string]string{
    						"app":                           "wle",
    						"topology.kubernetes.io/region": "region1",
    						"topology.kubernetes.io/zone":   "zone1",
    						"topology.istio.io/subzone":     "subzone1",
    						"topology.istio.io/network":     "network1",
    						"topology.istio.io/cluster":     clusterID,
    					},
    					Address: "1.1.1.1",
    					Network: "network1",
    					Locality: model.Locality{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 39K bytes
    - Viewed (0)
  7. pkg/test/framework/components/echo/common/deployment/echos.go

    	a := echo.Config{
    		Service:                 ASvc,
    		ServiceAccount:          true,
    		Ports:                   ports.All(),
    		Subsets:                 []echo.SubsetConfig{{}},
    		Locality:                "region.zone.subzone",
    		IncludeExtAuthz:         c.IncludeExtAuthz,
    		DisableAutomountSAToken: disableAutomountSAToken,
    	}
    
    	b := echo.Config{
    		Service:         BSvc,
    		ServiceAccount:  true,
    		Ports:           ports.All(),
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon May 20 16:01:31 UTC 2024
    - 16K bytes
    - Viewed (0)
  8. pkg/bootstrap/option/instances_test.go

    		},
    		{
    			testName: "zone",
    			key:      "zone",
    			option:   option.Zone("fake"),
    			expected: "fake",
    		},
    		{
    			testName: "sub zone",
    			key:      "sub_zone",
    			option:   option.SubZone("fake"),
    			expected: "fake",
    		},
    		{
    			testName: "node metadata nil",
    			key:      "meta_json_str",
    			option:   option.NodeMetadata(nil, nil),
    			expected: nil,
    		},
    		{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Mar 28 20:38:02 UTC 2024
    - 22.4K bytes
    - Viewed (0)
  9. pilot/pkg/autoregistration/controller.go

    	// the workload entry.
    	if proxy.Metadata.Labels != nil {
    		entry.Labels = mergeLabels(entry.Labels, proxy.Metadata.Labels)
    		// the label has been converted to "istio-locality: region/zone/subzone"
    		// in pilot/pkg/xds/ads.go, and `/` is not allowed in k8s label value.
    		// Instead of converting again, we delete it since has set WorkloadEntry.Locality
    		delete(entry.Labels, model.LocalityLabel)
    	}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 16 00:00:36 UTC 2024
    - 26.4K bytes
    - Viewed (0)
  10. pilot/pkg/autoregistration/controller_test.go

    		},
    	}
    }
    
    func fakeNode(r, z, sz string) *core.Node {
    	return &core.Node{
    		Locality: &core.Locality{
    			Region:  r,
    			Zone:    z,
    			SubZone: sz,
    		},
    	}
    }
    
    // createOrFail wraps config creation with convenience for failing tests
    func createOrFail(t test.Failer, store model.ConfigStoreController, cfg config.Config) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 16 00:00:36 UTC 2024
    - 31.4K bytes
    - Viewed (0)
Back to top