- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 16 for LastError (0.45 sec)
-
cmd/kubeadm/app/util/apiclient/idempotency.go
return false, *lastError } // Execute the mutating function patchFn(n) newData, err := json.Marshal(n) if err != nil { *lastError = errors.Wrapf(err, "failed to marshal modified node %q into JSON", n.Name) return false, *lastError } patchBytes, err := strategicpatch.CreateTwoWayMergePatch(oldData, newData, v1.Node{}) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Feb 18 11:14:32 UTC 2024 - 18.4K bytes - Viewed (0) -
cmd/kubeadm/app/util/etcd/etcd.go
// Syncs the list of endpoints var cli etcdClient var lastError error err := wait.PollUntilContextTimeout(context.Background(), constants.EtcdAPICallRetryInterval, constants.EtcdAPICallTimeout, true, func(_ context.Context) (bool, error) { var err error cli, err = c.newEtcdClient(c.Endpoints) if err != nil { lastError = err return false, nil } defer func() { _ = cli.Close() }()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 11:04:08 UTC 2024 - 21.2K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/classloader/TransformErrorHandler.java
ClassNotFoundException lastError = getLastErrorAndClear(); if (lastError != null) { throw new ClassNotFoundException( "A pending instrumentation exception prevented loading a class " + className + " in " + classLoaderName, lastError); } } /** * Call this when an error occurs during class loading.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 5.2K bytes - Viewed (0) -
pkg/util/goroutinemap/exponentialbackoff/exponential_backoff.go
maxDurationBeforeRetry = 2*time.Minute + 2*time.Second ) // ExponentialBackoff contains the last occurrence of an error and the duration // that retries are not permitted. type ExponentialBackoff struct { lastError error lastErrorTime time.Time durationBeforeRetry time.Duration } // SafeToRetry returns an error if the durationBeforeRetry period for the given
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 19 03:30:46 UTC 2022 - 4.2K bytes - Viewed (0) -
cmd/kubeadm/app/phases/upgrade/health.go
if err != nil { klog.V(2).Infof("Could not list Nodes with field selector %q: %v", fieldSelector, err) lastError = err return false, nil } return true, nil }) if err != nil { return errors.Wrap(lastError, "could not check if there is at least one Node that can schedule a test Pod") } if len(nodes.Items) == 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 26 09:18:02 UTC 2024 - 8.8K bytes - Viewed (0) -
cmd/kubeadm/app/util/apiclient/wait.go
if err != nil { lastError = formatError(fmt.Sprintf("error: %v", err)) return false, err } resp, err := client.Do(req) if err != nil { lastError = formatError(fmt.Sprintf("error: %v", err)) return false, nil } defer func() { _ = resp.Body.Close() }() if resp.StatusCode != http.StatusOK {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 01 07:10:31 UTC 2024 - 13.3K bytes - Viewed (0) -
cmd/kubeadm/app/discovery/token/token.go
return false, nil } // Even if the ConfigMap is available the JWS signature is patched-in a bit later. if _, ok := cm.Data[bootstrapapi.JWSSignatureKeyPrefix+token.ID]; !ok { lastError = errors.Errorf("could not find a JWS signature in the cluster-info ConfigMap"+ " for token ID %q", token.ID) klog.V(1).Infof("[discovery] Retrying due to error: %v", lastError) return false, nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 14 13:07:56 UTC 2024 - 10.1K bytes - Viewed (0) -
cmd/kubeadm/app/phases/bootstraptoken/node/token.go
var lastError error err = wait.PollUntilContextTimeout( context.Background(), kubeadmconstants.KubernetesAPICallRetryInterval, kubeadmapi.GetActiveTimeouts().KubernetesAPICall.Duration, true, func(_ context.Context) (bool, error) { if err := apiclient.CreateOrUpdateSecret(client, updatedOrNewSecret); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 14 13:07:56 UTC 2024 - 2.5K bytes - Viewed (0) -
pkg/wasm/httpfetcher.go
b := backoff.NewExponentialBackOff(o) var lastError error for attempts < f.requestMaxRetry { attempts++ req, err := http.NewRequestWithContext(ctx, http.MethodGet, url, nil) if err != nil { wasmLog.Debugf("wasm module download request failed: %v", err) return nil, err } resp, err := c.Do(req) if err != nil { lastError = err wasmLog.Debugf("wasm module download request failed: %v", err)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Nov 14 20:23:34 UTC 2022 - 5.5K bytes - Viewed (0) -
cmd/kubeadm/app/discovery/file/file.go
var clusterinfoCM *v1.ConfigMap var lastError error err = wait.PollUntilContextTimeout(context.Background(), constants.DiscoveryRetryInterval, discoveryTimeout, true, func(_ context.Context) (bool, error) { clusterinfoCM, lastError = client.CoreV1().ConfigMaps(metav1.NamespacePublic).Get(context.TODO(), bootstrapapi.ConfigMapClusterInfo, metav1.GetOptions{}) if lastError != nil { if apierrors.IsForbidden(lastError) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 14 13:07:55 UTC 2024 - 6.7K bytes - Viewed (0)