- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 166 for GetOptions (0.18 sec)
-
pkg/wasm/cache_test.go
} cache.mux.Unlock() atomic.StoreInt32(&tsNumRequest, 0) if c.getOptions.PullSecret == nil { c.getOptions.PullSecret = []byte{} } gotFilePath, gotErr := cache.Get(c.fetchURL, c.getOptions) serverVisited := atomic.LoadInt32(&tsNumRequest) > 0 if c.checkPurgeTimeout > 0 { moduleDeleted := false
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 20:06:41 UTC 2024 - 33.9K bytes - Viewed (0) -
tests/integration/operator/switch_cr_test.go
case "Service": _, err = cs.Kube().CoreV1().Services(ns).Get(context.TODO(), name, metav1.GetOptions{}) case "ServiceAccount": _, err = cs.Kube().CoreV1().ServiceAccounts(ns).Get(context.TODO(), name, metav1.GetOptions{}) case "Deployment": _, err = cs.Kube().AppsV1().Deployments(IstioNamespace).Get(context.TODO(), name, metav1.GetOptions{}) case "ConfigMap":
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 10 20:33:28 UTC 2024 - 17.5K bytes - Viewed (0) -
pkg/registry/core/namespace/storage/storage_test.go
_, err := storage.Create(ctx, namespace, rest.ValidateAllObjectFunc, &metav1.CreateOptions{}) if err != nil { t.Fatalf("unexpected error: %v", err) } object, err := storage.Get(ctx, "foo", &metav1.GetOptions{}) if err != nil { t.Errorf("unexpected error: %v", err) } actual := object.(*api.Namespace) if actual.Name != namespace.Name { t.Errorf("unexpected namespace: %#v", actual) } if len(actual.UID) == 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 17 05:13:34 UTC 2022 - 19.8K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/test/integration/registration_test.go
if err != nil { t.Fatal(err) } if e, a := createdCurletInstance, gottenCurletInstance; !reflect.DeepEqual(e, a) { t.Errorf("expected %v, got %v", e, a) } // now re-GET noxu gottenNoxuInstance2, err := noxuNamespacedResourceClient.Get(context.TODO(), sameInstanceName, metav1.GetOptions{}) if err != nil { t.Fatal(err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 14 11:58:05 UTC 2022 - 15.4K bytes - Viewed (0) -
pkg/registry/core/serviceaccount/storage/token.go
// set ResourceVersion=0 to allow this to be read/served from the apiservers watch cache nodeObj, err := r.nodes.Get(newCtx, nodeName, &metav1.GetOptions{ResourceVersion: "0"}) if err != nil { nodeObj, err = r.nodes.Get(newCtx, nodeName, &metav1.GetOptions{}) // fallback to a live lookup on any error } switch { case errors.IsNotFound(err):
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 05 10:24:31 UTC 2024 - 10K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/registry/customresource/etcd_test.go
parameterScheme := runtime.NewScheme() parameterScheme.AddUnversionedTypes(schema.GroupVersion{Group: "mygroup.example.com", Version: "v1beta1"}, &metav1.ListOptions{}, &metav1.GetOptions{}, &metav1.DeleteOptions{}, ) typer := apiserver.UnstructuredObjectTyper{ Delegate: parameterScheme, UnstructuredTyper: crdserverscheme.NewUnstructuredObjectTyper(), }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 28 19:06:46 UTC 2024 - 25.2K bytes - Viewed (0) -
operator/pkg/helmreconciler/wait.go
namespace, err := cs.CoreV1().Namespaces().Get(context.TODO(), o.Name, metav1.GetOptions{}) if err != nil { return false, nil, nil, err } namespaces = append(namespaces, *namespace) case name.DeploymentStr: currentDeployment, err := cs.AppsV1().Deployments(o.Namespace).Get(context.TODO(), o.Name, metav1.GetOptions{}) if err != nil { return false, nil, nil, err }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Dec 08 03:13:12 UTC 2023 - 13.1K bytes - Viewed (0) -
pkg/registry/apps/replicaset/storage/storage_test.go
rs, err := createReplicaSet(storage.ReplicaSet, modifiedSno, t) if err != nil { t.Errorf("unexpected error: %v", err) } etcdRS, err := storage.ReplicaSet.Get(ctx, rs.Name, &metav1.GetOptions{}) if err != nil { t.Errorf("unexpected error: %v", err) } storedRS, _ := etcdRS.(*apps.ReplicaSet) // Generation initialization
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:46:12 UTC 2023 - 17.7K bytes - Viewed (0) -
platforms/jvm/language-java/src/main/java/org/gradle/api/tasks/javadoc/Javadoc.java
@Nested public MinimalJavadocOptions getOptions() { return options; } /** * Convenience method for configuring Javadoc generation options. * * @param block The configuration block for Javadoc generation options. */ public void options(@DelegatesTo(MinimalJavadocOptions.class) Closure<?> block) { ConfigureUtil.configure(block, getOptions()); } /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Aug 28 11:40:18 UTC 2023 - 13.6K bytes - Viewed (0) -
pkg/controller/storageversiongc/gc_controller_test.go
// add a delay to ensure controller had a chance to reconcile time.Sleep(2 * time.Second) storageVersion, err := clientset.InternalV1alpha1().StorageVersions().Get(context.Background(), "k8s.test.resources", metav1.GetOptions{}) if err != nil { t.Fatalf("error getting StorageVersion: %v", err) } expectedServerStorageVersions := []apiserverinternalv1alpha1.ServerStorageVersion{ { APIServerID: "kube-apiserver-2",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 07 12:19:43 UTC 2023 - 12.1K bytes - Viewed (0)