- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 80 for Try (0.23 sec)
-
cmd/sts-errors.go
}, ErrSTSNotInitialized: { Code: "STSNotInitialized", Description: "STS API not initialized, please try again.", HTTPStatusCode: http.StatusServiceUnavailable, }, ErrSTSIAMNotInitialized: { Code: "STSIAMNotInitialized", Description: "STS IAM not initialized, please try again.", HTTPStatusCode: http.StatusServiceUnavailable, }, ErrSTSUpstreamError: { Code: "InternalError",
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 5.8K bytes - Viewed (0) -
internal/lsync/lrwmutex.go
const ( lockRetryInterval = 50 * time.Millisecond ) // lockLoop will acquire either a read or a write lock // // The call will block until the lock is granted using a built-in // timing randomized back-off algorithm to try again until successful func (lm *LRWMutex) lockLoop(ctx context.Context, id, source string, timeout time.Duration, isWriteLock bool) (locked bool) { r := rand.New(rand.NewSource(time.Now().UnixNano()))
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 4.8K bytes - Viewed (0) -
internal/s3select/parquet/errors.go
return err.message } func errParquetParsingError(err error) *s3Error { return &s3Error{ code: "ParquetParsingError", message: "Error parsing Parquet file. Please check the file and try again.", statusCode: 400, cause: err, }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 1.4K bytes - Viewed (0) -
internal/store/batch_test.go
} if len(items) != 1 { t.Fatalf("Expected length of the batch items to be 1 but got %v", len(items)) } if len(keys) != 1 { t.Fatalf("Expected length of the batch keys to be 1 but got %v", len(items)) } // try adding again after Get. for i := 0; i < int(limit); i++ { if err := batch.Add(i, i); err != nil { t.Fatalf("failed to add item %v to batch after Get; %v", i, err) } if _, ok := batch.GetByKey(i); !ok {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 3.8K bytes - Viewed (0) -
istioctl/cmd/sysexits.go
// limitations under the License. package cmd import ( "strings" "istio.io/istio/istioctl/pkg/analyze" "istio.io/istio/istioctl/pkg/util" ) // Values should try to use sendmail-style values as in <sysexits.h> // See e.g. https://man.openbsd.org/sysexits.3 // or `less /usr/includes/sysexits.h` if you're on Linux // // Picking the right range is tricky--there are a lot of reserved ones (see
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Thu Jun 15 15:02:17 GMT 2023 - 1.9K bytes - Viewed (0) -
cmd/post-policy-fan-out.go
encrd, objectEncryptionKey, err := newEncryptReader(ctx, hr, opts.Kind, opts.KeyID, opts.Key, bucket, req.Key, userDefined, opts.KmsCtx) if err != nil { errs[idx] = err return } // do not try to verify encrypted content/ hr, err = hash.NewReader(ctx, encrd, -1, "", "", -1) if err != nil { errs[idx] = err return } reader, err = reader.WithEncryption(hr, &objectEncryptionKey)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 3.5K bytes - Viewed (0) -
internal/dsync/drwmutex.go
isReadLock := true return dm.lockBlocking(ctx, cancel, id, source, isReadLock, opts) } // lockBlocking will try to acquire either a read or a write lock // // The function will loop using a built-in timing randomized back-off // algorithm until either the lock is acquired successfully or more // time has elapsed than the timeout value.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 19.7K bytes - Viewed (0) -
internal/s3select/simdj/errors.go
return err.message } func errJSONParsingError(err error) *s3Error { return &s3Error{ code: "JSONParsingError", message: fmt.Sprintf("Encountered an error parsing the JSON file: %v. Check the file and try again.", err), statusCode: 400, cause: err, }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 1.4K bytes - Viewed (0) -
internal/s3select/csv/errors.go
return err.message } func errCSVParsingError(err error) *s3Error { return &s3Error{ code: "CSVParsingError", message: "Encountered an error parsing the CSV file. Check the file and try again.", statusCode: 400, cause: err, } } func errInvalidTextEncodingError() *s3Error { return &s3Error{ code: "InvalidTextEncoding", message: "UTF-8 encoding is required.",
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 1.6K bytes - Viewed (0) -
internal/amztime/parse.go
t, err := time.Parse(dateFormat, timeStr) if err == nil { return t, nil } } return time.Time{}, ErrMalformedDate } // ParseReplicationTS parse http.TimeFormat first // will try time.RFC3339Nano when parse http.TimeFormat failed func ParseReplicationTS(str string) (time.Time, error) { tm, err := time.Parse(http.TimeFormat, str) if tm.IsZero() || err != nil { tm, err = time.Parse(time.RFC3339Nano, str)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 2.5K bytes - Viewed (0)