Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 35 for mustGetUUID (0.11 sec)

  1. cmd/format-erasure.go

    	}
    	format.ID = mustGetUUID()
    	format.Erasure.Version = formatErasureVersionV3
    	format.Erasure.DistributionAlgo = formatErasureVersionV3DistributionAlgoV3
    	format.Erasure.Sets = make([][]string, numSets)
    
    	for i := 0; i < numSets; i++ {
    		format.Erasure.Sets[i] = make([]string, setLen)
    		for j := 0; j < setLen; j++ {
    			format.Erasure.Sets[i][j] = mustGetUUID()
    		}
    	}
    	return format
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 23.2K bytes
    - Viewed (0)
  2. cmd/config.go

    	if err != nil {
    		return nil, err
    	}
    
    	return decryptData(data, historyFile)
    }
    
    func saveServerConfigHistory(ctx context.Context, objAPI ObjectLayer, kv []byte) error {
    	uuidKV := mustGetUUID() + kvPrefix
    	historyFile := pathJoin(minioConfigHistoryPrefix, uuidKV)
    
    	if GlobalKMS != nil {
    		var err error
    		kv, err = config.EncryptBytes(GlobalKMS, kv, kms.Context{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 23 10:07:06 UTC 2023
    - 6K bytes
    - Viewed (0)
  3. cmd/erasure-multipart.go

    	fi := newFileInfo(pathJoin(bucket, object), dataDrives, parityDrives)
    	fi.VersionID = opts.VersionID
    	if opts.Versioned && fi.VersionID == "" {
    		fi.VersionID = mustGetUUID()
    	}
    	fi.DataDir = mustGetUUID()
    
    	if ckSum := userDefined[ReplicationSsecChecksumHeader]; ckSum != "" {
    		v, err := base64.StdEncoding.DecodeString(ckSum)
    		if err == nil {
    			fi.Checksum = v
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 44.7K bytes
    - Viewed (0)
  4. cmd/erasure-object.go

    	if opts.Versioned && fi.VersionID == "" {
    		fi.VersionID = mustGetUUID()
    	}
    
    	fi.DataDir = mustGetUUID()
    	if ckSum := userDefined[ReplicationSsecChecksumHeader]; ckSum != "" {
    		if v, err := base64.StdEncoding.DecodeString(ckSum); err == nil {
    			fi.Checksum = v
    		}
    		delete(userDefined, ReplicationSsecChecksumHeader)
    	}
    	uniqueID := mustGetUUID()
    	tempObj := uniqueID
    
    	// Initialize erasure metadata.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
  5. cmd/warm-backend-s3.go

    		sessionName := conf.AWSRoleSessionName
    		if sessionName == "" {
    			// RoleSessionName has a limited set of characters (https://docs.aws.amazon.com/STS/latest/APIReference/API_AssumeRole.html)
    			sessionName = "minio-tier-" + mustGetUUID()
    		}
    		s3WebIdentityIAM := credentials.IAM{
    			Client: &http.Client{
    				Transport: NewHTTPTransport(),
    			},
    			EKSIdentity: struct {
    				TokenFile       string
    				RoleARN         string
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  6. cmd/prepare-storage.go

    	//  |__ e870a2c1-d09c-450c-a69c-6eaa54a89b3e
    	//
    	// In this example, `33a58b40-aecc-4c9f-a22f-ff17bfa33b62` directory contains
    	// temporary objects from one of the previous runs of minio server.
    	tmpID := mustGetUUID()
    	tmpOld := pathJoin(diskPath, minioMetaTmpBucket+"-old", tmpID)
    	if err := renameAll(pathJoin(diskPath, minioMetaTmpBucket),
    		tmpOld, diskPath); err != nil && !errors.Is(err, errFileNotFound) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 20:51:54 UTC 2024
    - 11.1K bytes
    - Viewed (1)
  7. cmd/admin-handlers-users_test.go

    }
    
    func (c *check) mustCreateIAMUser(ctx context.Context, admClnt *madmin.AdminClient) madmin.Credentials {
    	c.Helper()
    	randUser := mustGetUUID()
    	randPass := mustGetUUID()
    	err := admClnt.AddUser(ctx, randUser, randPass)
    	if err != nil {
    		c.Fatalf("should be able to create a user: %v", err)
    	}
    	return madmin.Credentials{
    		AccessKey: randUser,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 47.3K bytes
    - Viewed (0)
  8. cmd/listen-notification-handlers.go

    			writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    			return
    		}
    	}
    
    	rulesMap := event.NewRulesMap(eventNames, pattern, event.TargetID{ID: mustGetUUID()})
    
    	setEventStreamHeaders(w)
    
    	// Listen Publisher and peer-listen-client uses nonblocking send and hence does not wait for slow receivers.
    	// Use buffered channel to take care of burst sends or slow w.Write()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6K bytes
    - Viewed (0)
  9. cmd/bucket-replication-handlers.go

    	vars := mux.Vars(r)
    	bucket := vars["bucket"]
    	durationStr := r.URL.Query().Get("older-than")
    	arn := r.URL.Query().Get("arn")
    	resetID := r.URL.Query().Get("reset-id")
    	if resetID == "" {
    		resetID = mustGetUUID()
    	}
    	var (
    		days time.Duration
    		err  error
    	)
    	if durationStr != "" {
    		days, err = time.ParseDuration(durationStr)
    		if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 23.3K bytes
    - Viewed (0)
  10. cmd/xl-storage-free-version_test.go

    	// Add null version with tiered content
    	tierfi := fi
    	tierfi.VersionID = ""
    	fatalErr(xl.AddVersion(tierfi))
    	report()
    	tierfi.TransitionStatus = lifecycle.TransitionComplete
    	tierfi.TransitionedObjName = mustGetUUID()
    	tierfi.TransitionTier = "MINIOTIER-1"
    	var err error
    	_, err = xl.DeleteVersion(tierfi)
    	fatalErr(err)
    	report()
    
    	fvIDs := []string{
    		"00000000-0000-0000-0000-0000000000f1",
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Mar 02 05:11:03 UTC 2024
    - 7.8K bytes
    - Viewed (0)
Back to top