- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 141 for GetOptions (0.33 sec)
-
staging/src/k8s.io/apiextensions-apiserver/test/integration/change_test.go
updateCRD := func() { noxuDefinitionToUpdate, err := apiExtensionsClient.ApiextensionsV1().CustomResourceDefinitions().Get(context.TODO(), noxuDefinition.Name, metav1.GetOptions{}) if err != nil { t.Error(err) return } if len(noxuDefinitionToUpdate.Spec.Versions) == 1 { v2 := noxuDefinitionToUpdate.Spec.Versions[0] v2.Name = "v2" v2.Served = true
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 13:59:03 UTC 2024 - 5.2K bytes - Viewed (0) -
istioctl/pkg/checkinject/checkinject.go
if err != nil { return err } pod, err := kubeClient.Kube().CoreV1().Pods(podNs).Get(context.TODO(), podName, metav1.GetOptions{}) if err != nil { return err } ns, err := kubeClient.Kube().CoreV1().Namespaces().Get(context.TODO(), podNs, metav1.GetOptions{}) if err != nil { return err } podLabels = pod.GetLabels() nsLabels = ns.GetLabels() } else {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Apr 13 05:23:38 UTC 2024 - 9.3K bytes - Viewed (0) -
tests/integration/operator/uninstall_test.go
ObjectMeta: metav1.ObjectMeta{ Name: IstioNamespace, }, }, metav1.CreateOptions{}); err != nil { _, err := cs.Kube().CoreV1().Namespaces().Get(context.TODO(), IstioNamespace, metav1.GetOptions{}) if err == nil { log.Info("istio namespace already exist") } else { t.Errorf("failed to create istio namespace: %v", err) } } iopCRFile = filepath.Join(workDir, "iop_cr.yaml")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 10 20:33:28 UTC 2024 - 7.7K bytes - Viewed (0) -
pkg/test/framework/components/ambient/waypoint.go
if service == "" { return } cs := t.AllClusters() for _, c := range cs { oldSvc, err := c.Kube().CoreV1().Services(ns.Name()).Get(t.Context(), service, metav1.GetOptions{}) if err != nil { t.Fatalf("error getting svc %s, err %v", service, err) } oldLabels := oldSvc.ObjectMeta.GetLabels() if oldLabels == nil { oldLabels = make(map[string]string, 1) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 6.5K bytes - Viewed (0) -
platforms/enterprise/enterprise/src/main/java/org/gradle/internal/enterprise/test/impl/DefaultTestTaskPropertiesService.java
outputFileProperties.add(new DefaultOutputFileProperty(propertyName, files, type)); } }); return new DefaultTestTaskProperties( task.getOptions() instanceof JUnitPlatformOptions, task.getForkEvery(), task.getDryRun().get(), collectFilters(task), collectForkOptions(task),
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 23 05:16:16 UTC 2024 - 8.3K bytes - Viewed (0) -
tests/integration/pilot/mcs/discoverability/discoverability_test.go
} sort.Strings(info.TargetPod) } // Get the East-West Gateway IP svc, err := c.Kube().CoreV1().Services(istioNS).Get(context.TODO(), "istio-eastwestgateway", metav1.GetOptions{}) if err == nil { var ips []string for _, ingress := range svc.Status.LoadBalancer.Ingress { ips = append(ips, ingress.IP) } info.Gateway = append(info.Gateway, ips...) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 17.9K bytes - Viewed (0) -
pkg/kubelet/configmap/configmap_manager.go
} func (s *simpleConfigMapManager) GetConfigMap(namespace, name string) (*v1.ConfigMap, error) { return s.kubeClient.CoreV1().ConfigMaps(namespace).Get(context.TODO(), name, metav1.GetOptions{}) } func (s *simpleConfigMapManager) RegisterPod(pod *v1.Pod) { } func (s *simpleConfigMapManager) UnregisterPod(pod *v1.Pod) { } // configMapManager keeps a cache of all configmaps necessary
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 5.5K bytes - Viewed (0) -
pkg/kubelet/secret/secret_manager.go
return &simpleSecretManager{kubeClient: kubeClient} } func (s *simpleSecretManager) GetSecret(namespace, name string) (*v1.Secret, error) { return s.kubeClient.CoreV1().Secrets(namespace).Get(context.TODO(), name, metav1.GetOptions{}) } func (s *simpleSecretManager) RegisterPod(pod *v1.Pod) { } func (s *simpleSecretManager) UnregisterPod(pod *v1.Pod) { } // secretManager keeps a store with secrets necessary
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 5.3K bytes - Viewed (0) -
platforms/core-runtime/logging/src/main/java/org/gradle/internal/logging/serializer/SelectOptionPromptEventSerializer.java
encoder.writeLong(value.getTimestamp()); encoder.writeString(value.getQuestion()); optionsSerializer.write(encoder, value.getOptions()); encoder.writeSmallInt(value.getDefaultOption()); } @Override public SelectOptionPromptEvent read(Decoder decoder) throws Exception {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 30 05:02:18 UTC 2024 - 1.8K bytes - Viewed (0) -
tests/integration/pilot/gateway_test.go
Get(context.Background(), "managed-owner-istio", metav1.GetOptions{}) assert.NoError(t, err) assert.Equal(t, dep.Labels[constants.ManagedGatewayLabel], "") assert.Equal(t, dep.Spec.Template.Spec.Containers[0].Image, image) svc, err := t.Clusters().Default().Kube().CoreV1().Services(apps.Namespace.Name()). Get(context.Background(), "managed-owner-istio", metav1.GetOptions{}) assert.NoError(t, err)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 17.7K bytes - Viewed (0)