- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for Transfer (0.18 sec)
-
internal/hash/checksum.go
// AsMap returns the func (c *Checksum) AsMap() map[string]string { if c == nil || !c.Valid() { return nil } return map[string]string{c.Type.String(): c.Encoded} } // TransferChecksumHeader will transfer any checksum value that has been checked. // If checksum was trailing, they must have been added to r.Trailer. func TransferChecksumHeader(w http.ResponseWriter, r *http.Request) { c, err := GetContentChecksum(r.Header)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 11.9K bytes - Viewed (0) -
cmd/metrics-v2.go
receivedCount MetricName = "received_count" sentCount MetricName = "sent_count" currTransferRate MetricName = "current_transfer_rate" avgTransferRate MetricName = "average_transfer_rate" maxTransferRate MetricName = "max_transfer_rate" credentialErrors MetricName = "credential_errors" currLinkLatency MetricName = "current_link_latency_ms"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 22:01:31 GMT 2024 - 132.6K bytes - Viewed (0) -
cmd/signature-v4-utils_test.go
// TestExtractSignedHeaders - Tests validate extraction of signed headers using list of signed header keys. func TestExtractSignedHeaders(t *testing.T) { signedHeaders := []string{"host", "x-amz-content-sha256", "x-amz-date", "transfer-encoding"} // If the `expect` key exists in the signed headers then golang server would have stripped out the value, expecting the `expect` header set to `100-continue` in the result.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 05 21:26:41 GMT 2024 - 14.3K bytes - Viewed (0) -
cmd/sftp-server-driver.go
if err != nil { return nil, err } _, err = obj.Stat() if err != nil { return nil, err } return obj, nil } // TransferError will catch network errors during transfer. // When TransferError() is called Close() will also // be called, so we do not need to Wait() here. func (w *writerAt) TransferError(err error) { _ = w.w.CloseWithError(err) _ = w.r.CloseWithError(err)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 12:23:42 GMT 2024 - 12.9K bytes - Viewed (0) -
cmd/object-api-options.go
} } opts.MTime = mtime opts.UserDefined = make(map[string]string) opts.UserDefined[ReservedMetadataPrefix+"Actual-Object-Size"] = r.Header.Get(xhttp.MinIOReplicationActualObjectSize) // Transfer SSEC key in opts.EncryptFn if crypto.SSEC.IsRequested(r.Header) { key, err := ParseSSECustomerRequest(r) if err == nil { // Set EncryptFn to return SSEC key
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Apr 20 09:05:54 GMT 2024 - 14.2K bytes - Viewed (0) -
cmd/data-scanner.go
// We scanned a folder, optionally send update. f.updateCache.deleteRecursive(h) f.updateCache.copyWithChildren(&f.newCache, h, folder.parent) f.sendUpdate() } } // Transfer existing if !into.Compacted { for _, folder := range existingFolders { h := hashPath(folder.name) f.updateCache.copyWithChildren(&f.oldCache, h, folder.parent) } } // Scan new...
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/metacache-stream.go
if err := w.mw.Flush(); err != nil { return err } return s2w.Close() } return nil } } var s2DecPool = sync.Pool{New: func() interface{} { // Default alloc block for network transfer. return s2.NewReader(nil, s2.ReaderAllocBlock(16<<10)) }} // metacacheReader allows reading a cache stream. type metacacheReader struct { mr *msgp.Reader current metaCacheEntry
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 19.5K bytes - Viewed (0)