Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 262 for labelSelectors (0.16 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. cni/pkg/repair/repaircontroller.go

    	}
    	// filter out pod events from different nodes
    	fieldSelectors = append(fieldSelectors, fmt.Sprintf("spec.nodeName=%v", cfg.NodeName))
    	c.pods = kclient.NewFiltered[*corev1.Pod](client, kclient.Filter{
    		LabelSelector: cfg.LabelSelectors,
    		FieldSelector: strings.Join(fieldSelectors, ","),
    	})
    	c.queue = controllers.NewQueue("repair pods",
    		controllers.WithReconciler(c.Reconcile),
    		controllers.WithMaxAttempts(5))
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sat Feb 10 00:31:55 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  6. pkg/dns/server/name_table_test.go

    		}},
    		Resolution: model.Passthrough,
    		Attributes: model.ServiceAttributes{
    			Name:            "foo.bar.com",
    			Namespace:       "testns",
    			ServiceRegistry: provider.External,
    			LabelSelectors:  map[string]string{"wl": "headless-foobar"},
    		},
    	}
    
    	wildcardService := &model.Service{
    		Hostname:       host.Name("*.testns.svc.cluster.local"),
    		DefaultAddress: "172.10.10.10",
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jan 25 04:26:03 UTC 2024
    - 16K bytes
    - Viewed (0)
  7. 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)
  8. pilot/pkg/model/sidecar.go

    		return false
    	}
    
    	if !maps.Equal(s1.Attributes.Labels, s2.Attributes.Labels) {
    		return false
    	}
    
    	if !maps.Equal(s1.Attributes.LabelSelectors, s2.Attributes.LabelSelectors) {
    		return false
    	}
    
    	if !maps.Equal(s1.Attributes.ExportTo, s2.Attributes.ExportTo) {
    		return false
    	}
    
    	return true
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 05 20:32:23 UTC 2024
    - 38.4K bytes
    - Viewed (0)
  9. pilot/pkg/serviceregistry/kube/controller/controller.go

    	if !inRegistry || !workloadInstancesExist || svc.Attributes.ServiceRegistry != provider.Kubernetes ||
    		svc.MeshExternal || svc.Resolution != model.ClientSideLB || svc.Attributes.LabelSelectors == nil {
    		return nil
    	}
    
    	selector := labels.Instance(svc.Attributes.LabelSelectors)
    
    	// Get the service port name and target port so that we can construct the service instance
    	k8sService := c.services.Get(svc.Attributes.Name, svc.Attributes.Namespace)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 41.2K bytes
    - Viewed (0)
  10. pkg/kube/inject/inject.go

    	// Takes precedence over AlwaysInjectSelector.
    	NeverInjectSelector []metav1.LabelSelector `json:"neverInjectSelector"`
    
    	// AlwaysInjectSelector: Forces the injection on pods whose labels match this selector.
    	// It's an array of label selectors, that will be OR'ed, meaning we will iterate
    	// over it and stop at the first match
    	AlwaysInjectSelector []metav1.LabelSelector `json:"alwaysInjectSelector"`
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 31 20:35:11 UTC 2024
    - 28.8K bytes
    - Viewed (0)
Back to top