- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for setObjectLayer (0.28 sec)
-
cmd/erasure-healing-common_test.go
} ctx, cancel := context.WithCancel(t.Context()) defer cancel() obj, disks, err := prepareErasure16(ctx) if err != nil { t.Fatalf("Prepare Erasure backend failed - %v", err) } setObjectLayer(obj) defer obj.Shutdown(t.Context()) defer removeRoots(disks) type tamperKind int const ( noTamper tamperKind = iota deletePart corruptPart )
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 22.4K bytes - Viewed (0) -
cmd/test-utils_test.go
localMetacacheMgr.deleteAll() } objLayer, fsDir, err := prepareFS(ctx) if err != nil { t.Fatalf("Initialization of object layer failed for single node setup: %s", err) } setObjectLayer(objLayer) initAllSubsystems(ctx) // initialize the server and obtain the credentials and root. // credentials are necessary to sign the HTTP request.
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 77K bytes - Viewed (0) -
cmd/data-scanner_test.go
// Prepare object layer objAPI, disks, err := prepareErasure(t.Context(), 8) if err != nil { t.Fatalf("Failed to initialize object layer: %v", err) } defer removeRoots(disks) setObjectLayer(objAPI) // Prepare bucket metadata globalBucketMetadataSys = NewBucketMetadataSys() globalBucketObjectLockSys = &BucketObjectLockSys{} globalBucketVersioningSys = &BucketVersioningSys{} lcXML := `
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 12K bytes - Viewed (0) -
cmd/api-router.go
globalConsoleSrv = srv globalObjLayerMutex.Unlock() } func newObjectLayerFn() ObjectLayer { globalObjLayerMutex.RLock() defer globalObjLayerMutex.RUnlock() return globalObjectAPI } func setObjectLayer(o ObjectLayer) { globalObjLayerMutex.Lock() globalObjectAPI = o globalObjLayerMutex.Unlock() } // objectAPIHandlers implements and provides http handlers for S3 API. type objectAPIHandlers struct {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Wed May 07 15:37:12 UTC 2025 - 23.3K bytes - Viewed (0) -
cmd/erasure-object_test.go
ctx, cancel := context.WithCancel(t.Context()) defer cancel() obj, fsDirs, err := prepareErasureSets32(ctx) if err != nil { t.Fatal("Unable to initialize 'Erasure' object layer.", err) } setObjectLayer(obj) initConfigSubsystem(ctx, obj) // Remove all dirs. for _, dir := range fsDirs { defer os.RemoveAll(dir) } type testCaseType struct { bucket string object string }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 38.3K bytes - Viewed (0) -
cmd/erasure-healing_test.go
} defer removeRoots(fsDirs) // Everything is fine, should return nil objLayer, _, err := initObjectLayer(ctx, mustGetPoolEndpoints(0, fsDirs...)) if err != nil { t.Fatal(err) } setObjectLayer(objLayer) bucket := getRandomBucketName() object := getRandomObjectName() data := bytes.Repeat([]byte("a"), 128*1024) err = objLayer.MakeBucket(ctx, bucket, MakeBucketOptions{}) if err != nil {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 48.5K bytes - Viewed (0) -
cmd/erasure-server-pool.go
// so various tasks will be useful bootstrapTrace("initAutoHeal", func() { initAutoHeal(GlobalContext, z) }) // initialize the object layer. defer setObjectLayer(z) r := rand.New(rand.NewSource(time.Now().UnixNano())) attempt := 1 for { var err error bootstrapTrace(fmt.Sprintf("poolMeta.Init: loading pool metadata, attempt: %d", attempt), func() {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 89.1K bytes - Viewed (0)