- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 184 for GetOptions (0.24 sec)
-
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) -
pkg/controller/volume/attachdetach/statusupdater/node_status_updater_test.go
if len(needToReport) != 0 { t.Fatalf("len(asw.GetVolumesToReportAttached()) Expected: <0> Actual: <%v>", len(needToReport)) } node, err := fakeKubeClient.CoreV1().Nodes().Get(ctx, "testnode-1", metav1.GetOptions{}) if err != nil { t.Fatalf("Nodes().Get failed. Expected: <no error> Actual: <%v>", err) } if len(node.Status.VolumesAttached) != 1 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 00:37:30 UTC 2023 - 8.4K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/autoserviceexportcontroller_test.go
t.Helper() retry.UntilSuccessOrFail(t, func() error { got, err := client.Dynamic().Resource(mcs.ServiceExportGVR).Namespace(ns).Get(context.TODO(), name, metav1.GetOptions{}) if err != nil && !strings.Contains(err.Error(), "not found") { return fmt.Errorf("unexpected error %v", err) } isPresent := got != nil if isPresent != shouldBePresent {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 06 16:02:24 UTC 2023 - 4.9K bytes - Viewed (0) -
platforms/jvm/scala/src/main/java/org/gradle/api/tasks/scala/internal/ScaladocParameters.java
public interface ScaladocParameters extends WorkParameters { RegularFileProperty getOptionsFile(); ConfigurableFileCollection getClasspath(); DirectoryProperty getOutputDirectory(); ListProperty<String> getOptions(); ConfigurableFileCollection getSources(); Property<Boolean> getIsScala3();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Sep 18 15:43:33 UTC 2023 - 1.2K bytes - Viewed (0) -
pkg/test/framework/components/istio/util.go
if ip == "" { return nil, false, fmt.Errorf("no Host IP available on the remote service node yet") } svc, err := cluster.Kube().CoreV1().Services(ns).Get(context.TODO(), svcName, metav1.GetOptions{}) if err != nil { return nil, false, err } if len(svc.Spec.Ports) == 0 { return nil, false, fmt.Errorf("no ports found in service: %s/%s", ns, svcName) } var nodePort int32
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 29 17:13:34 UTC 2024 - 4.7K bytes - Viewed (0) -
pkg/test/kube/util.go
var endpoints *corev1.Endpoints err := retry.UntilSuccess(func() error { s, err := a.CoreV1().Services(ns).Get(context.TODO(), name, metav1.GetOptions{}) if err != nil { return err } eps, err := a.CoreV1().Endpoints(ns).Get(context.TODO(), name, metav1.GetOptions{}) if err != nil { return err } if len(eps.Subsets) == 0 { return fmt.Errorf("%s/%v endpoint not ready: no subsets", ns, name)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Dec 04 22:47:52 UTC 2023 - 9.4K bytes - Viewed (0) -
pkg/registry/certificates/certificates/storage/storage.go
// we don't destroy it here explicitly. } // Get retrieves the object from the storage. It is required to support Patch. func (r *StatusREST) Get(ctx context.Context, name string, options *metav1.GetOptions) (runtime.Object, error) { return r.store.Get(ctx, name, options) } // Update alters the status subset of an object.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 18 09:21:19 UTC 2022 - 6.3K bytes - Viewed (0)