- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 92 for loaders (0.2 sec)
-
cmd/site-replication.go
uerr := globalIAMSys.store.loadUsers(ctx, regUser, userAccounts) if uerr != nil { return info, errSRBackendIssue(uerr) } serr := globalIAMSys.store.loadUsers(ctx, svcUser, userAccounts) if serr != nil { return info, errSRBackendIssue(serr) } terr := globalIAMSys.store.loadUsers(ctx, stsUser, userAccounts) if terr != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 184.2K bytes - Viewed (1) -
internal/grid/connection.go
} } for { // Handle the extremely unlikely scenario that we wrapped. if _, loaded := c.outgoing.LoadOrStore(client.MuxID, client); client.MuxID != 0 && !loaded { if debugReqs { _, found := c.outgoing.Load(client.MuxID) fmt.Println(client.MuxID, c.String(), "Connection.newMuxClient: RELOADED MUX. loaded:", loaded, "found:", found) } return client, nil } client.MuxID = atomic.AddUint64(&c.NextID, 1)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0) -
internal/http/headers.go
AmzMetaUnencryptedContentLength = "X-Amz-Meta-X-Amz-Unencrypted-Content-Length" AmzMetaUnencryptedContentMD5 = "X-Amz-Meta-X-Amz-Unencrypted-Content-Md5" // AWS server-side encryption headers for SSE-S3, SSE-KMS and SSE-C. AmzServerSideEncryption = "X-Amz-Server-Side-Encryption" AmzServerSideEncryptionKmsID = AmzServerSideEncryption + "-Aws-Kms-Key-Id"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 17:44:56 GMT 2024 - 10.4K bytes - Viewed (1) -
cmd/api-headers.go
w.Header().Set(xhttp.CacheControl, "no-cache") // nginx to turn off buffering w.Header().Set("X-Accel-Buffering", "no") // nginx to turn off buffering } // Write http common headers func setCommonHeaders(w http.ResponseWriter) { // Set the "Server" http header. w.Header().Set(xhttp.ServerInfo, MinioStoreName) // Set `x-amz-bucket-region` only if region is set on the server
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6.9K bytes - Viewed (1) -
cmd/signature-v4.go
) // getCanonicalHeaders generate a list of request headers with their values func getCanonicalHeaders(signedHeaders http.Header) string { var headers []string vals := make(http.Header) for k, vv := range signedHeaders { k = strings.ToLower(k) headers = append(headers, k) vals[k] = vv } sort.Strings(headers) var buf bytes.Buffer for _, k := range headers { buf.WriteString(k) buf.WriteByte(':')
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/object-handlers-common.go
if objInfo.ModTime.IsZero() || objInfo.ModTime.Equal(time.Unix(0, 0)) { return false } // Headers to be set of object content is not going to be written to the client. writeHeaders := func() { // set common headers setCommonHeaders(w) // set object-related metadata headers w.Header().Set(xhttp.LastModified, objInfo.ModTime.UTC().Format(http.TimeFormat)) if objInfo.ETag != "" {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 09 08:17:49 GMT 2024 - 14.6K bytes - Viewed (0) -
cmd/object-api-options.go
} // get ObjectOptions for Copy calls with encryption headers provided on the target side and source side metadata func copyDstOpts(ctx context.Context, r *http.Request, bucket, object string, metadata map[string]string) (opts ObjectOptions, err error) { return putOptsFromReq(ctx, r, bucket, object, metadata) } // get ObjectOptions for Copy calls with encryption headers provided on the source side
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/metacache-set.go
// not a storage error. return nil } readers := make([]*metacacheReader, len(disks)) defer func() { for _, r := range readers { r.Close() } }() for i := range disks { r, w := io.Pipe() // Make sure we close the pipe so blocked writes doesn't stay around. defer r.CloseWithError(context.Canceled) readers[i] = newMetacacheReader(r) d := disks[i]
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:59:08 GMT 2024 - 30.4K bytes - Viewed (0) -
cmd/generic-handlers.go
// Make sure we remove any existing headers before // proxying the request to another node. for k := range w.Header() { w.Header().Del(k) } globalForwarder.ServeHTTP(w, r) return } h.ServeHTTP(w, r) }) } // addCustomHeadersMiddleware adds various HTTP(S) response headers. // Security Headers enable various security protections behaviors in the client's browser.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 11 01:08:52 GMT 2024 - 20.7K bytes - Viewed (0) -
internal/config/scanner/scanner.go
EnvIdleSpeed = "MINIO_SCANNER_IDLE_SPEED" ExcessVersions = "alert_excess_versions" EnvExcessVersions = "MINIO_SCANNER_ALERT_EXCESS_VERSIONS" ExcessFolders = "alert_excess_folders" EnvExcessFolders = "MINIO_SCANNER_ALERT_EXCESS_FOLDERS" // All below are deprecated in October 2022 and // replaced them with a single speed parameter Delay = "delay" MaxWait = "max_wait" Cycle = "cycle"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 11 01:10:30 GMT 2024 - 5.5K bytes - Viewed (0)