- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 262 for labelSelectors (0.16 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
pilot/pkg/model/sidecar.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 05 20:32:23 UTC 2024 - 38.4K bytes - Viewed (0) -
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) -
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)