Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for GetWorkloadSelector (0.24 sec)

  1. pilot/pkg/model/destination_rule.go

    			bothWithoutSelector := rule.GetWorkloadSelector() == nil && existingRule.GetWorkloadSelector() == nil
    			bothWithSelector := existingRule.GetWorkloadSelector() != nil && rule.GetWorkloadSelector() != nil
    			selectorsMatch := labels.Instance(existingRule.GetWorkloadSelector().GetMatchLabels()).Equals(rule.GetWorkloadSelector().GetMatchLabels())
    
    			if bothWithSelector && !selectorsMatch {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 07:22:29 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  2. pilot/pkg/serviceregistry/kube/controller/ambient/services.go

    		return a.serviceEntriesInfo(s, waypoint)
    	}
    }
    
    func (a *index) serviceEntriesInfo(s *networkingclient.ServiceEntry, w *Waypoint) []model.ServiceInfo {
    	sel := model.NewSelector(s.Spec.GetWorkloadSelector().GetLabels())
    	portNames := map[int32]model.ServicePortName{}
    	for _, p := range s.Spec.Ports {
    		portNames[int32(p.Number)] = model.ServicePortName{
    			PortName: p.Name,
    		}
    	}
    	waypointKey := ""
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 05 12:29:55 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  3. pilot/pkg/networking/core/cluster_builder.go

    	opts.policy = util.MergeSubsetTrafficPolicy(opts.policy, subset.TrafficPolicy, opts.port)
    
    	if destRule != nil {
    		destinationRule := CastDestinationRule(destRule)
    		opts.isDrWithSelector = destinationRule.GetWorkloadSelector() != nil
    	}
    	// Apply traffic policy for the subset cluster.
    	cb.applyTrafficPolicy(opts)
    
    	maybeApplyEdsConfig(subsetCluster.cluster)
    
    	cb.applyMetadataExchange(opts.mutable.cluster)
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 31.6K bytes
    - Viewed (0)
  4. pilot/pkg/model/push_context.go

    		jdr := configs[j].Spec.(*networking.DestinationRule)
    
    		// Check if one of the configs has priority set to true
    		if idr.GetWorkloadSelector() != nil && jdr.GetWorkloadSelector() == nil {
    			return true
    		} else if idr.GetWorkloadSelector() == nil && jdr.GetWorkloadSelector() != nil {
    			return false
    		}
    
    		// If priority is the same or neither has priority, fallback to creation time ordering
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 15 09:02:11 UTC 2024
    - 91.8K bytes
    - Viewed (0)
  5. pilot/pkg/model/sidecar.go

    		if sc.Namespace == destRule.rule.Namespace &&
    			destinationRule.GetWorkloadSelector() != nil && direction == TrafficDirectionOutbound {
    			workloadSelector := labels.Instance(destinationRule.GetWorkloadSelector().GetMatchLabels())
    			// return destination rule if workload selector matches
    			if workloadSelector.SubsetOf(proxy.Labels) {
    				return destRule
    			}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 05 20:32:23 UTC 2024
    - 38.4K bytes
    - Viewed (0)
  6. pkg/config/validation/validation.go

    			}
    			v = AppendValidation(v, validateSubset(subset))
    		}
    		v = AppendValidation(v,
    			validateExportTo(cfg.Namespace, rule.ExportTo, false, rule.GetWorkloadSelector() != nil))
    
    		v = AppendValidation(v, validateWorkloadSelector(rule.GetWorkloadSelector()))
    
    		return v.Unwrap()
    	})
    
    func validateExportTo(namespace string, exportTo []string, isServiceEntry bool, isDestinationRuleWithSelector bool) (errs error) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 12 04:03:33 UTC 2024
    - 107.2K bytes
    - Viewed (0)
Back to top