- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 42 for lastErr (0.16 sec)
-
pkg/volume/iscsi/iscsi_util.go
lastErr = fmt.Errorf("iscsi: failed to sendtargets to portal %s output: %s, err %v", tp, out, err) continue } err = updateISCSINode(b, tp) if err != nil { // failure to update node db is rare. But deleting record will likely impact those who already start using it.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 22 12:53:01 UTC 2022 - 34.1K bytes - Viewed (0) -
pkg/test/util/retry/retry.go
successes := 0 attempts := 0 var lasterr error to := time.After(cfg.timeout) delay := cfg.delay for { if cfg.maxAttempts > 0 && attempts >= cfg.maxAttempts { return nil, fmt.Errorf("hit max attempts %d attempts (last error: %v)", attempts, lasterr) } select { case <-to: return nil, fmt.Errorf("timeout while waiting after %d attempts (last error: %v)", attempts, lasterr) default: }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Aug 08 16:43:05 UTC 2023 - 5.6K bytes - Viewed (0) -
pkg/kubelet/volumemanager/reconciler/reconstruct_test.go
} // Unmount runs in a go routine, wait for its finish var lastErr error err = retryWithExponentialBackOff(testOperationBackOffDuration, func() (bool, error) { if err := verifyTearDownCalls(fakePlugin, tc.expectedUnmounts); err != nil { lastErr = err return false, nil } return true, nil }) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 14.8K bytes - Viewed (0) -
pkg/kubeapiserver/authenticator/config.go
if err != nil { return err } var lastErr error if waitErr := wait.PollUntilContextCancel(ctx, 10*time.Second, true, func(_ context.Context) (done bool, err error) { lastErr = updatedJWTAuthenticator.healthCheck() return lastErr == nil, nil }); lastErr != nil || waitErr != nil { updatedJWTAuthenticator.cancel() return utilerrors.NewAggregate([]error{lastErr, waitErr}) // filters out nil errors }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 09 19:29:33 UTC 2024 - 15.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storageversion/manager.go
// this map allows quick status lookup for a GroupResource, during API request handling. managedStatus map[schema.GroupResource]*updateStatus } type updateStatus struct { done bool lastErr error } // NewDefaultManager creates a new defaultManager. func NewDefaultManager() Manager { s := &defaultManager{} s.completed.Store(false) s.managedResourceInfos = make(map[*ResourceInfo]struct{})
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 14 17:47:19 UTC 2023 - 10.5K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/plugin/v1beta1/stub.go
var lastErr error err := wait.PollUntilContextTimeout(context.Background(), 10*time.Second, 2*time.Minute, false, func(context.Context) (done bool, err error) { restartErr := m.Restart() if restartErr == nil { return true, nil } klog.ErrorS(restartErr, "Retrying after error") lastErr = restartErr return false, nil })
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 17 11:19:10 UTC 2023 - 11.5K bytes - Viewed (0) -
internal/rest/client.go
TraceOutput io.Writer // Debug trace output httpClient *http.Client url *url.URL newAuthToken func(audience string) string sync.RWMutex // mutex for lastErr lastErr error lastErrTime time.Time } type restError string func (e restError) Error() string { return string(e) } func (e restError) Timeout() bool { return true }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 14.4K bytes - Viewed (0) -
pkg/volume/csi/nodeinfomanager/nodeinfomanager.go
if csiKubeClient == nil { return goerrors.New("error getting CSI client") } var lastErr error err := wait.ExponentialBackoff(updateBackoff, func() (bool, error) { if lastErr = nim.tryInitializeCSINodeWithAnnotation(csiKubeClient); lastErr != nil { klog.V(2).Infof("Failed to publish CSINode: %v", lastErr) return false, nil } return true, nil }) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 09:02:45 UTC 2024 - 20.1K bytes - Viewed (0) -
cmd/kubeadm/app/util/config/cluster.go
var rawAPIEndpoint string var lastErr error // Let's tolerate some unexpected transient failures from the API server or load balancers. Also, if // static pods were not yet mirrored into the API server we want to wait for this propagation. err := wait.PollUntilContextTimeout(context.Background(), interval, timeout, true, func(ctx context.Context) (bool, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 11:04:08 UTC 2024 - 11K bytes - Viewed (0) -
pkg/volume/csi/csi_plugin.go
_, lastErr = client.StorageV1().CSINodes().Get(context.TODO(), string(nodeName), opts) if lastErr == nil || apierrors.IsNotFound(lastErr) { // API server contacted return true, nil } klog.V(2).Infof("Failed to contact API server when waiting for CSINode publishing: %s", lastErr) return false, nil }) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 29.2K bytes - Viewed (0)