- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 369 for GetOptions (0.24 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/apiserver/pkg/registry/generic/registry/dryrun.go
return s.Storage.Versioner() } func (s *DryRunnableStorage) Create(ctx context.Context, key string, obj, out runtime.Object, ttl uint64, dryRun bool) error { if dryRun { if err := s.Storage.Get(ctx, key, storage.GetOptions{}, out); err == nil { return storage.NewKeyExistsError(key, 0) } return s.copyInto(obj, out) } return s.Storage.Create(ctx, key, obj, out, ttl) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 02 20:40:48 UTC 2023 - 3.8K bytes - Viewed (0) -
pkg/controller/serviceaccount/tokengetter.go
} return c.client.CoreV1().ServiceAccounts(namespace).Get(context.TODO(), name, metav1.GetOptions{}) } func (c clientGetter) GetPod(namespace, name string) (*v1.Pod, error) { if pod, err := c.podLister.Pods(namespace).Get(name); err == nil { return pod, nil } return c.client.CoreV1().Pods(namespace).Get(context.TODO(), name, metav1.GetOptions{}) } func (c clientGetter) GetSecret(namespace, name string) (*v1.Secret, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 21:15:10 UTC 2023 - 3K bytes - Viewed (0) -
pkg/wasm/options.go
Always PullPolicy = 2 ) var PullPolicyValues = map[string]PullPolicy{ "UNSPECIFIED_POLICY": 0, "IfNotPresent": 1, "Always": 2, } // GetOptions is a struct for providing options to Get method of Cache. type GetOptions struct { Checksum string ResourceName string ResourceVersion string RequestTimeout time.Duration PullSecret []byte PullPolicy PullPolicy
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 20:06:41 UTC 2024 - 1.9K bytes - Viewed (0) -
cni/pkg/nodeagent/server_test.go
kubeClient: fakeClientSet, netServer: server, } err := m.AddPodToMesh(fakeCtx, pod, podIPs, "") assert.NoError(t, err) pod, err = fakeClientSet.CoreV1().Pods("test").Get(fakeCtx, "test", metav1.GetOptions{}) assert.NoError(t, err) assert.Equal(t, len(pod.Annotations), 1) assert.Equal(t, pod.Annotations[constants.AmbientRedirection], constants.AmbientRedirectionEnabled) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 26 20:34:28 UTC 2024 - 7.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) -
platforms/jvm/language-java/src/test/groovy/org/gradle/external/javadoc/internal/JavadocOptionFileTest.groovy
def optionFileOptionMock = Mock(JavadocOptionFileOptionInternal.class) def optionFile = new JavadocOptionFile() def "test defaults"() { expect: optionFile.getOptions() != null optionFile.getOptions().isEmpty() optionFile.getSourceNames() != null optionFile.getSourceNames().getValue() != null optionFile.getSourceNames().getValue().isEmpty() }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Aug 28 11:40:18 UTC 2023 - 1.3K bytes - Viewed (0) -
maven-embedder/src/test/java/org/apache/maven/cli/CLIManagerDocumentationTest.java
return s1.compareToIgnoreCase(s2); } } private static class CLIManagerExtension extends CLIManager { public Collection<Option> getOptions() { List<Option> optList = new ArrayList<>(options.getOptions()); optList.sort(new OptionComparator()); return optList; } } String getOptionsAsHtml() {
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Jun 11 09:06:12 UTC 2024 - 4K bytes - Viewed (0)