- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 141 for GetOptions (0.89 sec)
-
tests/integration/pilot/mcs/autoexport/autoexport_test.go
retry.UntilSuccessOrFail(ctx, func() error { serviceExport, err := cluster.Dynamic().Resource(serviceExportGVR).Namespace(echos.Namespace.Name()).Get( context.TODO(), common.ServiceB, metav1.GetOptions{}) if err != nil { return err } if serviceExport == nil { return fmt.Errorf("serviceexport %s/%s not found in cluster %s",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 4.9K bytes - Viewed (0) -
istioctl/pkg/util/ambient/util.go
isZtunnel := strings.HasPrefix(podName, "ztunnel") if client == nil { return isZtunnel } pod, err := client.Kube().CoreV1().Pods(podNamespace).Get(context.Background(), podName, metav1.GetOptions{}) if err != nil { return isZtunnel } if v, ok := pod.Labels["app"]; ok { return v == "ztunnel" } return isZtunnel } // InAmbient returns true if a resource is in ambient data plane mode.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 02 21:29:40 UTC 2024 - 1.7K bytes - Viewed (0) -
pkg/controller/storageversiongc/gc_controller.go
return true } func (c *Controller) processDeletedLease(ctx context.Context, name string) error { _, err := c.kubeclientset.CoordinationV1().Leases(metav1.NamespaceSystem).Get(ctx, name, metav1.GetOptions{}) // the lease isn't deleted, nothing we need to do here if err == nil { return nil } if !apierrors.IsNotFound(err) { return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 10K bytes - Viewed (0) -
pkg/volume/csi/nodeinfomanager/nodeinfomanager.go
if kubeClient == nil { return fmt.Errorf("error getting kube client") } nodeClient := kubeClient.CoreV1().Nodes() originalNode, err := nodeClient.Get(context.TODO(), string(nim.nodeName), metav1.GetOptions{}) if err != nil { return err } node := originalNode.DeepCopy() needUpdate := false for _, update := range updateFuncs { newNode, updated, err := update(node) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 09:02:45 UTC 2024 - 20.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store_test.go
} }() } wg.Wait() if _, err := registry.Get(testContext, podA.Name, &metav1.GetOptions{}); !errors.IsNotFound(err) { t.Errorf("Unexpected error: %v", err) } if _, err := registry.Get(testContext, podB.Name, &metav1.GetOptions{}); !errors.IsNotFound(err) { t.Errorf("Unexpected error: %v", err) } } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 101.8K bytes - Viewed (0) -
operator/pkg/verifier/verifier.go
switch kind { case "Deployment": deployment := &appsv1.Deployment{} err = info.Client. Get(). Resource(kinds). Namespace(namespace). Name(name). VersionedParams(&metav1.GetOptions{}, scheme.ParameterCodec). Do(context.TODO()). Into(deployment) if err != nil { v.reportFailure(kind, name, namespace, err) return err }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 19:23:44 UTC 2024 - 15K bytes - Viewed (0) -
platforms/core-runtime/logging/src/main/java/org/gradle/internal/logging/events/SelectOptionPromptEvent.java
this.question = question; this.options = options; this.defaultOption = defaultOption; } public String getQuestion() { return question; } public List<String> getOptions() { return options; } public int getDefaultOption() { return defaultOption; } @Override public String getPrompt() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 12:11:05 UTC 2024 - 2.6K bytes - Viewed (0) -
pkg/registry/core/persistentvolume/storage/storage_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 7.4K bytes - Viewed (0) -
pkg/controller/serviceaccount/tokens_controller.go
// so add the token to a freshly retrieved copy of the secret secrets := e.client.CoreV1().Secrets(cachedSecret.Namespace) liveSecret, err := secrets.Get(context.TODO(), cachedSecret.Name, metav1.GetOptions{}) if err != nil { // Retry for any error other than a NotFound return !apierrors.IsNotFound(err), err } if liveSecret.ResourceVersion != cachedSecret.ResourceVersion {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 20.5K bytes - Viewed (0) -
platforms/extensibility/plugin-development/src/integTest/groovy/org/gradle/plugin/devel/tasks/AbstractPluginValidationIntegrationSpec.groovy
public long getGoodTime() { return 0; } // Valid because it is annotated @Nested public Options getOptions() { return new Options(); } // Valid because it is annotated @CompileClasspath public java.util.List<java.io.File> getClasspath() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 09:03:53 UTC 2024 - 40.7K bytes - Viewed (0)