- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 103 for labelSelectors (0.18 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/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) -
pilot/pkg/serviceregistry/serviceentry/conversion_test.go
}, }, } selectorSvc := makeService("selector.com", "selector", "0.0.0.0", map[string]int{"tcp-444": 444, "http-445": 445}, true, model.ClientSideLB) selectorSvc.Attributes.LabelSelectors = map[string]string{"app": "wle"} serviceTests = append(serviceTests, struct { externalSvc *config.Config services []*model.Service }{ externalSvc: selector,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 39K bytes - Viewed (0) -
istioctl/pkg/dashboard/dashboard.go
return fmt.Errorf("failed to create k8s client: %v", err) } var podName, ns string if labelSelector != "" { pl, err := kubeClient.PodsForSelector(context.TODO(), ctx.NamespaceOrDefault(ctx.Namespace()), labelSelector) if err != nil { return fmt.Errorf("not able to locate pod with selector %s: %v", labelSelector, err) } if len(pl.Items) < 1 { return errors.New("no pods found") }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 15 01:29:35 UTC 2024 - 20.5K bytes - Viewed (0)