Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 42 for attempts (0.04 seconds)

  1. cmd/batch-job-common-types_gen.go

    		zb0001--
    		field, err = dc.ReadMapKeyPtr()
    		if err != nil {
    			err = msgp.WrapError(err)
    			return
    		}
    		switch msgp.UnsafeString(field) {
    		case "Attempts":
    			z.Attempts, err = dc.ReadInt()
    			if err != nil {
    				err = msgp.WrapError(err, "Attempts")
    				return
    			}
    		case "Delay":
    			z.Delay, err = dc.ReadDuration()
    			if err != nil {
    				err = msgp.WrapError(err, "Delay")
    				return
    			}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 21.9K bytes
    - Click Count (0)
  2. internal/event/target/kafka_scram_client_contrib.go

    	if err != nil {
    		return err
    	}
    	x.ClientConversation = x.NewConversation()
    	return nil
    }
    
    // Step takes a string provided from a server (or just an empty string for the
    // very first conversation step) and attempts to move the authentication
    // conversation forward.  It returns a string to be sent to the server or an
    // error if the server message is invalid.  Calling Step after a conversation
    // completes is also an error.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 3.2K bytes
    - Click Count (0)
  3. cmd/batch-handlers_gen.go

    			}
    		case "ra":
    			z.RetryAttempts, err = dc.ReadInt()
    			if err != nil {
    				err = msgp.WrapError(err, "RetryAttempts")
    				return
    			}
    		case "at":
    			z.Attempts, err = dc.ReadInt()
    			if err != nil {
    				err = msgp.WrapError(err, "Attempts")
    				return
    			}
    		case "cmp":
    			z.Complete, err = dc.ReadBool()
    			if err != nil {
    				err = msgp.WrapError(err, "Complete")
    				return
    			}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 20.4K bytes
    - Click Count (0)
  4. internal/logger/target/kafka/kafka_scram_client_contrib.go

    	if err != nil {
    		return err
    	}
    	x.ClientConversation = x.NewConversation()
    	return nil
    }
    
    // Step takes a string provided from a server (or just an empty string for the
    // very first conversation step) and attempts to move the authentication
    // conversation forward.  It returns a string to be sent to the server or an
    // error if the server message is invalid.  Calling Step after a conversation
    // completes is also an error.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 3.3K bytes
    - Click Count (0)
  5. api/maven-api-core/src/main/java/org/apache/maven/api/services/ModelSource.java

         * Implementations of this interface provide the ability to find POM files
         * in various project contexts.
         *
         * @since 4.0.0
         */
        interface ModelLocator {
            /**
             * Attempts to locate an existing POM file at or within the specified project path.
             *
             * <p>This method is used to find POM files in various contexts, such as:</p>
             * <ul>
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Mon Sep 29 14:45:25 GMT 2025
    - 4.4K bytes
    - Click Count (0)
  6. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvnup/goals/AbstractUpgradeStrategy.java

            }
            context.unindent();
        }
    
        /**
         * Extracts an Artifact from a POM document with parent resolution.
         * If groupId or version are missing, attempts to resolve from parent.
         *
         * <p>This method handles Maven's inheritance mechanism where groupId and version
         * can be inherited from the parent POM.
         *
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Tue Nov 18 18:03:26 GMT 2025
    - 7.1K bytes
    - Click Count (0)
  7. cmd/bucket-replication.go

    	var uploadID string
    	attempts := 1
    	for attempts <= 3 {
    		nctx, cancel := context.WithTimeout(ctx, time.Minute)
    		uploadID, err = c.NewMultipartUpload(nctx, bucket, object, opts)
    		cancel()
    		if err == nil {
    			break
    		}
    		if minio.ToErrorResponse(err).Code == "PreconditionFailed" {
    			return nil
    		}
    		attempts++
    		time.Sleep(time.Duration(rand.Int63n(int64(time.Second))))
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 118.2K bytes
    - Click Count (0)
  8. internal/rest/client.go

    		// Protect against integer overflow
    		panic("unit cannot exceed one hour")
    	}
    	return func(attempt uint) time.Duration {
    		if attempt > 16 {
    			// Protect against integer overflow
    			attempt = 16
    		}
    		// sleep = random_between(unit, min(cap, base * 2 ** attempt))
    		sleep := min(unit*time.Duration(1<<attempt), maxSleep)
    		sleep -= time.Duration(r.Float64() * float64(sleep-unit))
    		return sleep
    	}
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 14.7K bytes
    - Click Count (0)
  9. internal/s3select/sql/value.go

    	bytes, _ := v.ToBytes()
    	return string(bytes)
    }
    
    // Calculates minimum or maximum of v and a and assigns the result to
    // v - it works only on numeric arguments, where `v` is already
    // assumed to be numeric. Attempts conversion to numeric type for `a`
    // (first int, then float) only if the underlying values do not have a
    // type.
    func (v *Value) minmax(a *Value, isMax, isFirstRow bool) error {
    	err := inferTypeForArithOp(a)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 20.4K bytes
    - Click Count (0)
  10. cmd/notification.go

    					ctx := logger.SetReqInfo(ctx, reqInfo)
    					peersLogOnceIf(ctx, err, addr.String())
    				}
    
    				// Wait for a minimum of 100ms and dynamically increase this based on number of attempts.
    				if i < retryCount-1 {
    					time.Sleep(100*time.Millisecond + time.Duration(r.Float64()*float64(time.Second)))
    					continue
    				}
    			}
    			break
    		}
    	}()
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 46K bytes
    - Click Count (0)
Back to Top