- Sort Score
- Result 10 results
- Languages All
Results 221 - 230 of 395 for GetOptions (0.12 sec)
-
security/pkg/pki/ca/ca_test.go
if len(certChainBytes) != 0 { t.Errorf("Cert chain should be empty") } // Check the signing cert stored in K8s secret. caSecret, err := client.CoreV1().Secrets("default").Get(context.TODO(), CASecret, metav1.GetOptions{}) if err != nil { t.Errorf("Failed to get secret (error: %s)", err) } signingCertFromSecret, err := util.ParsePemEncodedCertificate(caSecret.Data[CACertFile]) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 31 08:51:27 UTC 2023 - 29.1K bytes - Viewed (0) -
cmd/kubeadm/app/util/apiclient/wait.go
constants.KubernetesAPICallRetryInterval, w.timeout, true, func(_ context.Context) (bool, error) { _, err := w.client.CoreV1().Pods(metav1.NamespaceSystem).Get(context.TODO(), podName, metav1.GetOptions{}) if err != nil && apierrors.IsNotFound(err) { fmt.Printf("[apiclient] The old Pod %q is now removed (which is desired)\n", podName) return true, nil } return false, nil }) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 01 07:10:31 UTC 2024 - 13.3K bytes - Viewed (0) -
pkg/registry/flowcontrol/ensurer/flowschema_test.go
if err != nil { t.Fatalf("Expected no error, but got: %v", err) } fsGot, err := client.Get(context.TODO(), test.bootstrap.Name, metav1.GetOptions{}) switch { case test.expected == nil: if !apierrors.IsNotFound(err) { t.Fatalf("Expected GET to return an %q error, but got: %v", metav1.StatusReasonNotFound, err) } case err != nil:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:35 UTC 2023 - 15.2K bytes - Viewed (0) -
pkg/webhooks/webhookpatch_test.go
t.Fatalf("Got %q, want %q", err, tc.err) } } else { obj, err := client.Kube().AdmissionregistrationV1().MutatingWebhookConfigurations().Get(context.Background(), tc.configName, metav1.GetOptions{}) if err != nil { t.Fatal(err) } for _, w := range obj.Webhooks { if strings.HasSuffix(w.Name, tc.webhookName) { if !bytes.Equal(w.ClientConfig.CABundle, tc.pemData) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Aug 02 09:53:38 UTC 2023 - 8.6K bytes - Viewed (0) -
pkg/util/node/node.go
Duration: 1 * time.Second, Factor: 2.0, Jitter: 0.2, } err := wait.ExponentialBackoff(backoff, func() (bool, error) { node, err := client.CoreV1().Nodes().Get(context.TODO(), name, metav1.GetOptions{}) if err != nil { klog.Errorf("Failed to retrieve node info: %v", err) return false, nil } nodeIP, err = GetNodeHostIP(node) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 27 23:24:38 UTC 2023 - 4.8K bytes - Viewed (0) -
pkg/registry/core/componentstatus/rest.go
return pred.MatchesObjectAttributes( status.ObjectMeta.Labels, fieldsSet, ) } func (rs *REST) Get(ctx context.Context, name string, options *metav1.GetOptions) (runtime.Object, error) { servers := rs.GetServersToValidate() if server, ok := servers[name]; !ok { return nil, fmt.Errorf("Component not found: %s", name) } else {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 13 08:10:29 UTC 2023 - 5.1K bytes - Viewed (0) -
pkg/registry/resource/resourceclaim/storage/storage_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:46:12 UTC 2023 - 5.4K bytes - Viewed (0) -
pkg/test/framework/components/prometheus/kube.go
if err != nil { return nil, err } pod := pods[0] svc, err := cls.Kube().CoreV1().Services(cfg.TelemetryNamespace).Get(context.TODO(), serviceName, metav1.GetOptions{}) if err != nil { return nil, err } port := uint16(svc.Spec.Ports[0].Port) forwarder, err := cls.NewPortForwarder(pod.Name, pod.Namespace, "", 0, int(port)) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 6.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/util_test.go
require.NoError(t, err) return out } getPod := func(name, ns string) *example.Pod { key := "pods/" + ns + "/" + name out := &example.Pod{} err := etcdStorage.Get(context.TODO(), key, storage.GetOptions{}, out) require.NoError(t, err) return out } makeReplicaSet := func(name string) *example2v1.ReplicaSet { return &example2v1.ReplicaSet{ ObjectMeta: metav1.ObjectMeta{Namespace: "ns", Name: name},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 11 12:07:39 UTC 2024 - 6.3K bytes - Viewed (0) -
pkg/registry/flowcontrol/ensurer/prioritylevelconfiguration_test.go
if err != nil { t.Fatalf("Expected no error, but got: %v", err) } plGot, err := client.Get(context.TODO(), test.bootstrap.Name, metav1.GetOptions{}) switch { case test.expected == nil: if !apierrors.IsNotFound(err) { t.Fatalf("Expected GET to return an %q error, but got: %v", metav1.StatusReasonNotFound, err) } case err != nil:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 15 14:34:53 UTC 2024 - 19.8K bytes - Viewed (0)