Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for GetLocalityLbSetting (0.39 sec)

  1. pilot/pkg/xds/endpoints/endpoint_builder.go

    	enableFailover, lb := getOutlierDetectionAndLoadBalancerSettings(b.DestinationRule(), b.port, b.subsetName)
    	if enableFailover {
    		lbSetting := loadbalancer.GetLocalityLbSetting(b.push.Mesh.GetLocalityLbSetting(), lb.GetLocalityLbSetting())
    		if lbSetting != nil && lbSetting.Distribute == nil &&
    			len(lbSetting.FailoverPriority) > 0 && (lbSetting.Enabled == nil || lbSetting.Enabled.Value) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sun Apr 28 02:18:19 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  2. pilot/pkg/networking/core/cluster_traffic_policy.go

    	if features.SendUnhealthyEndpoints.Load() {
    		c.CommonLbConfig.HealthyPanicThreshold = &xdstype.Percent{Value: 0}
    	}
    	localityLbSetting := loadbalancer.GetLocalityLbSetting(meshConfig.GetLocalityLbSetting(), lb.GetLocalityLbSetting())
    	if localityLbSetting != nil {
    		c.CommonLbConfig.LocalityConfigSpecifier = &cluster.Cluster_CommonLbConfig_LocalityWeightedLbConfig_{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 23 05:38:57 UTC 2024
    - 20K bytes
    - Viewed (0)
  3. pilot/pkg/networking/core/loadbalancer/loadbalancer.go

    	"istio.io/istio/pilot/pkg/model"
    	"istio.io/istio/pilot/pkg/networking/util"
    	"istio.io/istio/pkg/util/sets"
    )
    
    const (
    	FailoverPriorityLabelDefaultSeparator = '='
    )
    
    func GetLocalityLbSetting(
    	mesh *v1alpha3.LocalityLoadBalancerSetting,
    	destrule *v1alpha3.LocalityLoadBalancerSetting,
    ) *v1alpha3.LocalityLoadBalancerSetting {
    	var enabled bool
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 23 05:38:57 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  4. pilot/pkg/networking/core/loadbalancer/loadbalancer_test.go

    			&networking.LocalityLoadBalancerSetting{Enabled: &wrappers.BoolValue{Value: true}},
    		},
    	}
    	for _, tt := range cases {
    		t.Run(tt.name, func(t *testing.T) {
    			got := GetLocalityLbSetting(tt.mesh, tt.dr)
    			if !reflect.DeepEqual(tt.expected, got) {
    				t.Fatalf("Expected: %v, got: %v", tt.expected, got)
    			}
    		})
    	}
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 23 05:38:57 UTC 2024
    - 39.1K bytes
    - Viewed (0)
Back to top