- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 42 for attempts (0.04 seconds)
-
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) -
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) -
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) -
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) -
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) -
impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvnup/goals/AbstractUpgradeStrategy.java
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) -
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) -
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) -
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) -
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)