Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 217 for labelSelectors (0.18 sec)

  1. cni/pkg/config/config.go

    	b.WriteString("InitTerminationMsg: " + c.InitTerminationMsg + "\n")
    	b.WriteString("InitExitCode: " + fmt.Sprint(c.InitExitCode) + "\n")
    	b.WriteString("LabelSelectors: " + c.LabelSelectors + "\n")
    	b.WriteString("FieldSelectors: " + c.FieldSelectors + "\n")
    	return b.String()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 21 18:32:01 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  2. pilot/pkg/model/service.go

    			out.Labels[k] = v
    		}
    	}
    
    	if s.ExportTo != nil {
    		out.ExportTo = s.ExportTo.Copy()
    	}
    
    	if s.LabelSelectors != nil {
    		out.LabelSelectors = make(map[string]string, len(s.LabelSelectors))
    		for k, v := range s.LabelSelectors {
    			out.LabelSelectors[k] = v
    		}
    	}
    
    	out.ClusterExternalAddresses = s.ClusterExternalAddresses.DeepCopy()
    
    	if s.ClusterExternalPorts != nil {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 02:03:58 UTC 2024
    - 46.3K bytes
    - Viewed (0)
  3. pilot/pkg/serviceregistry/serviceentry/conversion.go

    		//  alpha.istio.io/kubernetes-serviceaccounts.
    		SubjectAltNames: svc.ServiceAccounts,
    	}
    
    	if len(svc.Attributes.LabelSelectors) > 0 {
    		se.WorkloadSelector = &networking.WorkloadSelector{Labels: svc.Attributes.LabelSelectors}
    	}
    
    	// Based on networking.istio.io/exportTo annotation
    	for k := range svc.Attributes.ExportTo {
    		// k is Private or Public
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 02:03:58 UTC 2024
    - 16.9K bytes
    - Viewed (0)
  4. pkg/kube/namespace/filter.go

    func (d *discoveryNamespacesFilter) selectorsChanged(
    	discoverySelectors []*meshapi.LabelSelector,
    	notify bool,
    ) {
    	d.lock.Lock()
    	defer d.lock.Unlock()
    	var selectors []labels.Selector
    	newDiscoveryNamespaces := sets.New[string]()
    
    	namespaceList := d.namespaces.List("", labels.Everything())
    
    	// convert LabelSelectors to Selectors
    	for _, selector := range discoverySelectors {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 10 17:12:52 UTC 2024
    - 9.3K bytes
    - Viewed (0)
  5. pilot/pkg/serviceregistry/kube/conversion_test.go

    		t.Fatalf("service IPs incorrect => %q, want %q", actualIPs, expectedIPs)
    	}
    
    	if !reflect.DeepEqual(service.Attributes.LabelSelectors, localSvc.Spec.Selector) {
    		t.Fatalf("service label selectors incorrect => %q, want %q", service.Attributes.LabelSelectors,
    			localSvc.Spec.Selector)
    	}
    
    	sa := service.ServiceAccounts
    	if sa == nil || len(sa) != 4 {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  6. pkg/kube/krt/internal.go

    	if ok {
    		return ac.Labels
    	}
    	panic(fmt.Sprintf("No Labels, got %T", a))
    }
    
    // getLabelSelector returns the labels for an object, if possible.
    // Warning: this will panic if the labelSelectors is not available.
    func getLabelSelector(a any) map[string]string {
    	ak, ok := a.(LabelSelectorer)
    	if ok {
    		return ak.GetLabelSelector()
    	}
    	val := reflect.ValueOf(a)
    
    	if val.Kind() == reflect.Ptr {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 10 23:33:56 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  7. pkg/kube/krt/core.go

    type Equaler[K any] interface {
    	Equals(k K) bool
    }
    
    // LabelSelectorer is an optional interface that can be implemented by collection types.
    // If implemented, this will be used to determine an objects' LabelSelectors
    type LabelSelectorer interface {
    	GetLabelSelector() map[string]string
    }
    
    // Labeler is an optional interface that can be implemented by collection types.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 10 23:33:56 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  8. pilot/pkg/serviceregistry/kube/conversion.go

    		Attributes: model.ServiceAttributes{
    			ServiceRegistry: provider.Kubernetes,
    			Name:            svc.Name,
    			Namespace:       svc.Namespace,
    			Labels:          svc.Labels,
    			ExportTo:        exportTo,
    			LabelSelectors:  svc.Spec.Selector,
    		},
    	}
    
    	switch svc.Spec.Type {
    	case corev1.ServiceTypeNodePort:
    		if _, ok := svc.Annotations[annotation.TrafficNodeSelector.Name]; !ok {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  9. pkg/kube/client.go

    }
    
    func (c *client) PodsForSelector(ctx context.Context, namespace string, labelSelectors ...string) (*v1.PodList, error) {
    	return c.kube.CoreV1().Pods(namespace).List(ctx, metav1.ListOptions{
    		LabelSelector: strings.Join(labelSelectors, ","),
    	})
    }
    
    func (c *client) ApplyYAMLFiles(namespace string, yamlFiles ...string) error {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Apr 25 14:44:17 UTC 2024
    - 39K bytes
    - Viewed (0)
  10. cni/pkg/cmd/root.go

    		InitContainerName:  viper.GetString(constants.RepairInitContainerName),
    		InitTerminationMsg: viper.GetString(constants.RepairInitTerminationMsg),
    		InitExitCode:       viper.GetInt(constants.RepairInitExitCode),
    		LabelSelectors:     viper.GetString(constants.RepairLabelSelectors),
    		FieldSelectors:     viper.GetString(constants.RepairFieldSelectors),
    	}
    
    	return &config.Config{InstallConfig: installCfg, RepairConfig: repairCfg}, nil
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 12 16:26:35 UTC 2024
    - 13K bytes
    - Viewed (0)
Back to top