- Sort Score
- Result 10 results
- Languages All
Results 111 - 120 of 395 for GetOptions (0.13 sec)
-
pkg/kube/kclient/clienttest/direct.go
client kube.Client } func (d *directClient[T, PT, TL]) Get(name, namespace string) T { api := kubeclient.GetClient[T, TL](d.client, namespace) res, err := api.Get(context.Background(), name, metav1.GetOptions{}) if err != nil && !kerrors.IsNotFound(err) { d.t.Fatalf("get: %v", err) } return res } func (d *directClient[T, PT, TL]) List(namespace string, selector klabels.Selector) []T {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Aug 08 16:43:05 UTC 2023 - 3K bytes - Viewed (0) -
pkg/registry/resource/resourceclaim/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 10:11:16 UTC 2022 - 3.8K 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) -
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/kubelet/util/nodelease.go
// owner reference every time when renewing the lease, until successful. if len(lease.OwnerReferences) == 0 { if node, err := c.CoreV1().Nodes().Get(context.TODO(), nodeName, metav1.GetOptions{}); err == nil { lease.OwnerReferences = []metav1.OwnerReference{ { APIVersion: corev1.SchemeGroupVersion.WithKind("Node").Version, Kind: corev1.SchemeGroupVersion.WithKind("Node").Kind,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Mar 07 15:47:46 UTC 2021 - 1.9K bytes - Viewed (0) -
istioctl/pkg/describe/describe.go
client, err := ctx.CLIClient() if err != nil { return err } pod, err := client.Kube().CoreV1().Pods(ns).Get(context.TODO(), podName, metav1.GetOptions{}) if err != nil { return err } writer := cmd.OutOrStdout() podLabels := klabels.Set(pod.ObjectMeta.Labels) annotations := klabels.Set(pod.ObjectMeta.Annotations)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Apr 13 05:23:38 UTC 2024 - 50.4K bytes - Viewed (0) -
pkg/registry/registrytest/service.go
defer r.mu.Unlock() r.Service = svc.DeepCopy() r.List.Items = append(r.List.Items, *svc) return svc, r.Err } func (r *ServiceRegistry) GetService(ctx context.Context, id string, options *metav1.GetOptions) (*api.Service, error) { r.mu.Lock() defer r.mu.Unlock() r.GottenID = id return r.Service, r.Err } func (r *ServiceRegistry) DeleteService(ctx context.Context, id string) error { r.mu.Lock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jan 16 13:43:36 UTC 2023 - 2.9K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/apis/meta/internalversion/register.go
// as selectors for convenience). The other types have only a single representation today. scheme.AddKnownTypes(SchemeGroupVersion, &ListOptions{}, &metav1.GetOptions{}, &metav1.DeleteOptions{}, &metav1.CreateOptions{}, &metav1.UpdateOptions{}, ) scheme.AddKnownTypes(SchemeGroupVersion, &metav1.Table{}, &metav1.TableOptions{},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 22 18:47:31 UTC 2021 - 2.9K bytes - Viewed (0) -
tests/integration/pilot/mcs/common/common.go
} } } return nil } func isCRDInstalled(c cluster.Cluster, crdName string, version string) bool { crd, err := c.Ext().ApiextensionsV1().CustomResourceDefinitions().Get(context.TODO(), crdName, metav1.GetOptions{}) if err == nil { // Found the CRD, now check against the version. for _, v := range crd.Spec.Versions { if v.Name == version { // The CRD is already installed on this cluster. return true }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 27 17:09:00 UTC 2022 - 3.7K bytes - Viewed (0) -
pkg/registry/storage/volumeattachment/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 - 4.3K bytes - Viewed (0)