- Sort Score
- Result 10 results
- Languages All
Results 161 - 170 of 395 for GetOptions (0.15 sec)
-
pkg/registry/scheduling/rest/storage_scheduling.go
return false, nil } for _, pc := range schedulingapiv1.SystemPriorityClasses() { _, err := schedClientSet.PriorityClasses().Get(context.TODO(), pc.Name, metav1.GetOptions{}) if err != nil { if apierrors.IsNotFound(err) { _, err := schedClientSet.PriorityClasses().Create(context.TODO(), pc, metav1.CreateOptions{}) if err == nil || apierrors.IsAlreadyExists(err) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 23 18:36:33 UTC 2022 - 4.7K bytes - Viewed (0) -
platforms/jvm/language-java/src/main/java/org/gradle/external/javadoc/internal/JavadocOptionFile.java
return duplicateOptions; } public OptionLessJavadocOptionFileOption<List<String>> getSourceNames() { return sourceNames; } public Map<String, JavadocOptionFileOptionInternal<?>> getOptions() { return Collections.unmodifiableMap(options); } public <T> JavadocOptionFileOption<T> addOption(JavadocOptionFileOptionInternal<T> option) { if (option == null) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Dec 11 13:37:56 UTC 2023 - 6K bytes - Viewed (0) -
pkg/wasm/cache.go
const ( // oci URL prefix ociURLPrefix = "oci://" // sha256 scheme prefix sha256SchemePrefix = "sha256:" ) // Cache models a Wasm module cache. type Cache interface { Get(url string, opts GetOptions) (string, error) Cleanup() } // LocalFileCache for downloaded Wasm modules. Currently it stores the Wasm module as local file. type LocalFileCache struct { // Map from Wasm module checksum to cache entry.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 20:06:41 UTC 2024 - 13.3K bytes - Viewed (0) -
pilot/pkg/bootstrap/sidecarinjector.go
} } else if s.kubeClient != nil { configMapName := getInjectorConfigMapName(args.Revision) cms := s.kubeClient.Kube().CoreV1().ConfigMaps(args.Namespace) if _, err := cms.Get(context.TODO(), configMapName, metav1.GetOptions{}); err != nil { if errors.IsNotFound(err) { log.Infof("Skipping sidecar injector, template not found") return nil, nil } return nil, err }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Mar 04 20:39:38 UTC 2024 - 4K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/test/integration/fieldselector_test.go
if err := wait.PollUntilContextTimeout(ctx, time.Millisecond*100, wait.ForeverTestTimeout, true, func(ctx context.Context) (bool, error) { _, err := shirtv1beta1Client.Get(ctx, shirtInstance1, metav1.GetOptions{}) select { case <-upCh: return true, nil default: t.Logf("Waiting for webhook to become effective, getting marker object: %v", err) return false, nil } }); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 06 15:53:03 UTC 2024 - 27K bytes - Viewed (0) -
pkg/registry/flowcontrol/flowschema/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: Sat May 13 15:11:04 UTC 2023 - 4.1K bytes - Viewed (0) -
istioctl/pkg/workload/workload.go
if err := readWorkloadGroup(filename, wg); err != nil { return err } } else { wg, err = kubeClient.Istio().NetworkingV1alpha3().WorkloadGroups(namespace).Get(context.Background(), name, metav1.GetOptions{}) // errors if the requested workload group does not exist in the given namespace if err != nil { return fmt.Errorf("workloadgroup %s not found in namespace %s: %v", name, namespace, err) } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 20:06:41 UTC 2024 - 25.5K bytes - Viewed (0) -
platforms/extensibility/plugin-development/src/integTest/groovy/org/gradle/plugin/devel/tasks/ValidatePluginsPart2IntegrationTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 09:03:53 UTC 2024 - 40K bytes - Viewed (0) -
pkg/controlplane/reconcilers/endpointsadapter_test.go
client := fake.NewSimpleClientset(testCase.initialState...) epAdapter := NewEndpointsAdapter(client.CoreV1(), client.DiscoveryV1()) endpoints, err := epAdapter.Get(testCase.namespaceParam, testCase.nameParam, metav1.GetOptions{}) if !apiequality.Semantic.DeepEqual(testCase.expectedError, err) { t.Errorf("Expected error: %v, got: %v", testCase.expectedError, err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 12:23:16 UTC 2024 - 15.4K bytes - Viewed (0) -
pkg/registry/apps/replicaset/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: Wed Mar 08 21:44:00 UTC 2023 - 12.9K bytes - Viewed (0)