Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 16 of 16 for globalDeploymentID (0.63 sec)

  1. cmd/erasure-multipart.go

    				startTime = time.Unix(0, t)
    			}
    		}
    		uploads = append(uploads, MultipartInfo{
    			Bucket:    bucket,
    			Object:    object,
    			UploadID:  base64.RawURLEncoding.EncodeToString(fmt.Appendf(nil, "%s.%s", globalDeploymentID(), uploadID)),
    			Initiated: startTime,
    		})
    		populatedUploadIDs.Add(uploadID)
    	}
    
    	sort.Slice(uploads, func(i int, j int) bool {
    		return uploads[i].Initiated.Before(uploads[j].Initiated)
    	})
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 47.3K bytes
    - Viewed (0)
  2. cmd/bucket-lifecycle.go

    func genTransitionObjName(bucket string) (string, error) {
    	u, err := uuid.NewRandom()
    	if err != nil {
    		return "", err
    	}
    	us := u.String()
    	hash := xxh3.HashString(pathJoin(globalDeploymentID(), bucket))
    	obj := fmt.Sprintf("%s/%s/%s/%s", strconv.FormatUint(hash, 16), us[0:2], us[2:4], us)
    	return obj, nil
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 33.7K bytes
    - Viewed (0)
  3. cmd/object-handlers.go

    				Message:    serr.ErrorMessage(),
    				BucketName: bucket,
    				Key:        object,
    				Resource:   r.URL.Path,
    				RequestID:  w.Header().Get(xhttp.AmzRequestID),
    				HostID:     globalDeploymentID(),
    			})
    			writeResponse(w, serr.HTTPStatusCode(), encodedErrorResponse, mimeXML)
    		} else {
    			writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		}
    		return
    	}
    	defer s3Select.Close()
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 120.6K bytes
    - Viewed (0)
  4. cmd/api-response.go

    		Message:    errBody,
    		Resource:   reqURL.Path,
    		BucketName: reqInfo.BucketName,
    		Key:        reqInfo.ObjectName,
    		RequestID:  w.Header().Get(xhttp.AmzRequestID),
    		HostID:     globalDeploymentID(),
    	}
    	encodedErrorResponse := encodeResponseJSON(errorResponse)
    	writeResponse(w, err.HTTPStatusCode, encodedErrorResponse, mimeJSON)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Feb 18 16:25:55 UTC 2025
    - 33.7K bytes
    - Viewed (0)
  5. cmd/erasure-healing.go

    	if reqInfo != nil {
    		newReqInfo = logger.NewReqInfo(reqInfo.RemoteHost, reqInfo.UserAgent, reqInfo.DeploymentID, reqInfo.RequestID, reqInfo.API, bucket, object)
    	} else {
    		newReqInfo = logger.NewReqInfo("", "", globalDeploymentID(), "", "Heal", bucket, object)
    	}
    	healCtx := logger.SetReqInfo(GlobalContext, newReqInfo)
    
    	// Healing directories handle it separately.
    	if HasSuffix(object, SlashSeparator) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 34.6K bytes
    - Viewed (0)
  6. cmd/server-main.go

    		}
    	})
    
    	for _, n := range globalNodes {
    		nodeName := n.Host
    		if n.IsLocal {
    			nodeName = globalLocalNodeName
    		}
    		nodeNameSum := sha256.Sum256([]byte(nodeName + globalDeploymentID()))
    		globalNodeNamesHex[hex.EncodeToString(nodeNameSum[:])] = struct{}{}
    	}
    
    	bootstrapTrace("waitForQuorum", func() {
    		result := newObject.Health(context.Background(), HealthOptions{NoLogging: true})
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue May 27 15:18:36 UTC 2025
    - 35.9K bytes
    - Viewed (4)
Back to top