- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 35 for mustGetUUID (0.11 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)