- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 114 for obj (5.47 sec)
-
cmd/erasure-server-pool.go
concurrent = len(objects) } var mu sync.Mutex eg := errgroup.WithNErrs(len(objects)).WithConcurrency(concurrent) for j, obj := range objects { j := j obj := obj eg.Go(func() error { pinfo, _, err := z.getPoolInfoExistingWithOpts(ctx, bucket, obj.ObjectName, ObjectOptions{ NoLock: true, }) if err != nil { if !isErrObjectNotFound(err) && !isErrVersionNotFound(err) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 80.5K bytes - Viewed (0) -
cmd/tier-journal.go
type TierJournal struct { *tierDiskJournal // for processing legacy journal entries *tierMemJournal // for processing new journal entries } type jentry struct { ObjName string `msg:"obj"` VersionID string `msg:"vid"` TierName string `msg:"tier"` } const ( tierJournalVersion = 1 tierJournalHdrLen = 2 // 2 bytes )
Go - Registered: Sun Feb 25 19:28:16 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 7.4K bytes - Viewed (0) -
cmd/jwt_test.go
func TestWebRequestAuthenticate(t *testing.T) { ctx, cancel := context.WithCancel(context.Background()) defer cancel() obj, fsDir, err := prepareFS(ctx) if err != nil { t.Fatal(err) } defer os.RemoveAll(fsDir) if err = newTestConfig(globalMinioDefaultRegion, obj); err != nil { t.Fatal(err) } creds := globalActiveCred token, err := getTokenString(creds.AccessKey, creds.SecretKey)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:45:14 GMT 2024 - 4.5K bytes - Viewed (0) -
cmd/benchmark-utils_test.go
// Creates Object layer setup ( MakeBucket ) and then runs the PutObject benchmark. func runPutObjectBenchmark(b *testing.B, obj ObjectLayer, objSize int) { var err error // obtains random bucket name. bucket := getRandomBucketName() // create bucket. err = obj.MakeBucket(context.Background(), bucket, MakeBucketOptions{}) if err != nil { b.Fatal(err) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Dec 23 15:46:00 GMT 2022 - 8.2K bytes - Viewed (0) -
cmd/tier-journal_gen.go
return } for zb0001 > 0 { zb0001-- field, err = dc.ReadMapKeyPtr() if err != nil { err = msgp.WrapError(err) return } switch msgp.UnsafeString(field) { case "obj": z.ObjName, err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "ObjName") return } case "vid": z.VersionID, err = dc.ReadString() if err != nil {
Go - Registered: Sun Feb 25 19:28:16 GMT 2024 - Last Modified: Thu Jun 03 21:26:51 GMT 2021 - 6.1K bytes - Viewed (0) -
cmd/object-api-listobjects_test.go
func testListObjectsOnVersionedBuckets(obj ObjectLayer, instanceType string, t1 TestErrHandler) { _testListObjects(obj, instanceType, t1, true) } // Unit test for ListObjects. func testListObjects(obj ObjectLayer, instanceType string, t1 TestErrHandler) { _testListObjects(obj, instanceType, t1, false) } func _testListObjects(obj ObjectLayer, instanceType string, t1 TestErrHandler, versioned bool) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 11:07:40 GMT 2024 - 73.1K bytes - Viewed (0) -
cmd/object-api-multipart_test.go
err = obj.MakeBucket(context.Background(), bucket, MakeBucketOptions{}) if err != nil { // failed to create newbucket, abort. t.Fatalf("%s : %s", instanceType, err.Error()) } res, err := obj.NewMultipartUpload(context.Background(), bucket, "\\", opts) if err != nil { t.Fatalf("%s : %s", instanceType, err.Error()) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 77.1K bytes - Viewed (0) -
cmd/post-policy_test.go
// #16849 func testPostPolicyReservedBucketExploit(obj ObjectLayer, instanceType string, dirs []string, t TestErrHandler) { if err := newTestConfig(globalMinioDefaultRegion, obj); err != nil { t.Fatalf("Initializing config.json failed") } // Register the API end points with Erasure/FS object layer. apiRouter := initTestAPIEndPoints(obj, []string{"PostPolicy"}) credentials := globalActiveCred
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:45:54 GMT 2024 - 29.6K bytes - Viewed (0) -
internal/bucket/versioning/versioning_test.go
if v.PrefixEnabled(prefix) || !v.PrefixSuspended(prefix) { t.Fatalf("Test %d: Expected versioning to be excluded for %s", i+1, prefix) } } // Test applicability for regular objects if prefix := "prefix-1/obj-1"; !v.PrefixEnabled(prefix) || v.PrefixSuspended(prefix) { t.Fatalf("Expected versioning to be enabled for %s", prefix) } // Test when ExcludeFolders is disabled v.ExcludeFolders = false
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 08 05:06:44 GMT 2022 - 8.8K bytes - Viewed (0) -
cmd/metacache-server-pool.go
func triggerExpiryAndRepl(ctx context.Context, o listPathOptions, obj metaCacheEntry) (skip bool) { versioned := o.Versioning != nil && o.Versioning.Versioned(obj.name) // skip latest object from listing only for regular // listObjects calls, versioned based listing cannot // filter out between versions 'obj' cannot be truncated // in such a manner, so look for skipping an object only
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 12.8K bytes - Viewed (0)