- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 279 for headers (0.32 sec)
-
cmd/handler-utils.go
return map[string]string{} } return map[string]string{ "requestId": w.Header().Get(xhttp.AmzRequestID), "nodeId": w.Header().Get(xhttp.AmzRequestHostID), "content-length": w.Header().Get(xhttp.ContentLength), // Add more fields here. } } // Trims away `aws-chunked` from the content-encoding header if present. // Streaming signature clients can have custom content-encoding such as
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 15.5K bytes - Viewed (3) -
internal/s3select/genmessage.go
buf.WriteByte(7) buf.Write([]byte{0, 7}) buf.WriteString("Records") fmt.Println(buf.Bytes()) } // Continuation Message // ==================== // Header specification // -------------------- // Continuation messages contain two headers, as follows: // https://docs.aws.amazon.com/AmazonS3/latest/API/images/s3select-frame-diagram-cont.png // // Payload specification // ---------------------
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Aug 19 01:35:22 GMT 2021 - 4.4K bytes - Viewed (0) -
cmd/signature-v4-parser.go
return "", ErrMissingSignTag } if signFields[1] == "" { return "", ErrMissingFields } signature := signFields[1] return signature, ErrNone } // Parse slice of signed headers from signed headers tag. func parseSignedHeader(signedHdrElement string) ([]string, APIErrorCode) { signedHdrFields := strings.Split(strings.TrimSpace(signedHdrElement), "=") if len(signedHdrFields) != 2 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 9.4K bytes - Viewed (0) -
cmd/bucket-object-lock.go
// enforceRetentionBypassForDelete enforces whether an existing object under governance can be deleted // with governance bypass headers set in the request. // Objects under site wide WORM can never be overwritten. // For objects in "Governance" mode, overwrite is allowed if a) object retention date is past OR // governance bypass headers are set and user has governance bypass permissions.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 13.2K bytes - Viewed (0) -
internal/crypto/sse.go
// - SSE-KMS type Type interface { fmt.Stringer IsRequested(http.Header) bool IsEncrypted(map[string]string) bool } // IsRequested returns true and the SSE Type if the HTTP headers // indicate that some form server-side encryption is requested. // // If no SSE headers are present then IsRequested returns false // and no Type. func IsRequested(h http.Header) (Type, bool) { switch { case S3.IsRequested(h): return S3, true
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Aug 30 15:26:43 GMT 2022 - 4.4K bytes - Viewed (0) -
internal/event/target/amqp.go
if err != nil { return err } headers := make(amqp091.Table) // Add more information here as required, but be aware to not overload headers headers["minio-bucket"] = eventData.S3.Bucket.Name headers["minio-event"] = eventData.EventName.String() if err = ch.ExchangeDeclare(target.args.Exchange, target.args.ExchangeType, target.args.Durable,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 10K bytes - Viewed (0) -
cmd/object-handlers.go
w.Header().Set(xhttp.AmzServerSideEncryptionKmsContext, kmsCtx) } case crypto.SSEC: w.Header().Set(xhttp.AmzServerSideEncryptionCustomerAlgorithm, r.Header.Get(xhttp.AmzServerSideEncryptionCustomerAlgorithm)) w.Header().Set(xhttp.AmzServerSideEncryptionCustomerKeyMD5, r.Header.Get(xhttp.AmzServerSideEncryptionCustomerKeyMD5)) } objInfo.ETag = getDecryptedETag(r.Header, objInfo, false) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 20:15:54 GMT 2024 - 125.2K bytes - Viewed (0) -
cmd/api-router.go
} // Set of s3 handler options as bit flags. type s3HFlag uint8 const ( // when provided, disables Gzip compression. noGZS3HFlag = 1 << iota // when provided, enables only tracing of headers. Otherwise, both headers // and body are traced. traceHdrsS3HFlag // when provided, disables throttling via the `maxClients` middleware. noThrottleS3HFlag ) func (h s3HFlag) has(flag s3HFlag) bool {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 04 18:05:56 GMT 2024 - 22.8K bytes - Viewed (0) -
internal/grid/trace.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Feb 02 22:54:54 GMT 2024 - 4K bytes - Viewed (0) -
internal/config/cache/remote.go
func (r *CondCheck) Init(bucket, object string, header http.Header) { r.Key = object r.Bucket = bucket ifModifiedSinceHeader := header.Get(xhttp.IfModifiedSince) if ifModifiedSinceHeader != "" { if givenTime, err := amztime.ParseHeader(ifModifiedSinceHeader); err == nil { r.IfModifiedSince = &givenTime } } ifUnmodifiedSinceHeader := header.Get(xhttp.IfUnmodifiedSince) if ifUnmodifiedSinceHeader != "" {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Nov 22 21:46:17 GMT 2023 - 3.7K bytes - Viewed (0)