- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 316 for itos (0.12 sec)
-
cmd/signature-v4.go
} query.Set(xhttp.AmzAlgorithm, signV4Algorithm) // Construct the query. query.Set(xhttp.AmzDate, t.Format(iso8601Format)) query.Set(xhttp.AmzExpires, strconv.Itoa(expireSeconds)) query.Set(xhttp.AmzSignedHeaders, strings.Join(pSignValues.SignedHeaders, ";")) query.Set(xhttp.AmzCredential, cred.AccessKey+SlashSeparator+pSignValues.Credential.getScope())
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:45:54 GMT 2024 - 12.3K bytes - Viewed (0) -
cmd/erasure-multipart.go
} if parityDrives >= len(onlineDisks)/2 { parityDrives = len(onlineDisks) / 2 } if parityOrig != parityDrives { userDefined[minIOErasureUpgraded] = strconv.Itoa(parityOrig) + "->" + strconv.Itoa(parityDrives) } } dataDrives := len(onlineDisks) - parityDrives // we now know the number of blocks this object needs for data and parity. // establish the writeQuorum using this data
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 43K bytes - Viewed (0) -
internal/config/notify/legacy.go
config.KV{ Key: target.KafkaQueueLimit, Value: strconv.Itoa(int(cfg.QueueLimit)), }, config.KV{ Key: target.KafkaTLS, Value: config.FormatBool(cfg.TLS.Enable), }, config.KV{ Key: target.KafkaTLSSkipVerify, Value: config.FormatBool(cfg.TLS.SkipVerify), }, config.KV{ Key: target.KafkaTLSClientAuth, Value: strconv.Itoa(int(cfg.TLS.ClientAuth)), }, config.KV{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 19 04:37:54 GMT 2024 - 13.1K bytes - Viewed (0) -
cmd/storage-rest-server.go
_, err = s.getStorage().ReadFile(r.Context(), volume, filePath, int64(offset), buf, verifier) if err != nil { s.writeErrorResponse(w, err) return } w.Header().Set(xhttp.ContentLength, strconv.Itoa(len(buf))) w.Write(buf) } // ReadFileStreamHandler - read section of a file. func (s *storageRESTServer) ReadFileStreamHandler(w http.ResponseWriter, r *http.Request) { if !s.IsValid(w, r) { return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 44.8K bytes - Viewed (0) -
cmd/signature-v4-parser_test.go
} } } // TestParsePreSignV4 - Validates the parsing logic of Presignied v4 request from its url query values. func TestParsePreSignV4(t *testing.T) { // converts the duration in seconds into string format. getDurationStr := strconv.Itoa // used in expected preSignValues, preSignValues.Date is of type time.Time . queryTime := UTCNow()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 27.4K bytes - Viewed (0) -
cmd/data-scanner.go
RespElements: map[string]string{"x-minio-versions": strconv.Itoa(len(objInfos))}, }) auditLogInternal(context.Background(), AuditLogOptions{ Event: "scanner:manyversions", APIName: "Scanner", Bucket: i.bucket, Object: i.objectPath(), Tags: map[string]interface{}{ "x-minio-versions": strconv.Itoa(len(objInfos)), }, }) } cumulativeSize := int64(0)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 11:18:58 GMT 2024 - 47.6K bytes - Viewed (0) -
cmd/storage-rest-client.go
values := make(url.Values) values.Set(storageRESTVolume, volume) values.Set(storageRESTFilePath, path) values.Set(storageRESTOffset, strconv.Itoa(int(offset))) values.Set(storageRESTLength, strconv.Itoa(int(length))) respBody, err := client.call(ctx, storageRESTMethodReadFileStream, values, nil, -1) if err != nil { return nil, err } return respBody, nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 26.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java
* and then. This means that we're silently swallowing an exception -- maybe even an Error. But * this is no worse than what FutureTask does in that situation. Additionally, because the * Future was cancelled, its listeners have been run, so its consumers will not hang. * * Contrast this to the situation we have if setResult() throws, a situation described below. */ I sourceResult; try {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 10.6K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/ImmutableCollection.java
} copyIntoArray(other, 0); return other; } /** If this collection is backed by an array of its elements in insertion order, returns it. */ @CheckForNull @Nullable Object[] internalArray() { return null; } /** * If this collection is backed by an array of its elements in insertion order, returns the offset * where this collection's elements start. */
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 21.5K bytes - Viewed (0) -
guava/src/com/google/common/collect/ImmutableCollection.java
} copyIntoArray(other, 0); return other; } /** If this collection is backed by an array of its elements in insertion order, returns it. */ @CheckForNull Object[] internalArray() { return null; } /** * If this collection is backed by an array of its elements in insertion order, returns the offset * where this collection's elements start. */ int internalArrayStart() {
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 18.7K bytes - Viewed (1)