- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 21 for Background (0.2 sec)
-
cmd/xl-storage_test.go
if err = xlStorage.MakeVol(context.Background(), "exists-legacy"); err != nil { t.Fatalf("Unable to create a volume \"exists-legacy\", %s", err) } if err = xlStorage.AppendFile(context.Background(), "exists-legacy", "as-file/xl.json", []byte(legacyJSON)); err != nil { t.Fatalf("Unable to create a file \"as-file\", %s", err) }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 11 17:45:28 GMT 2024 - 66.7K bytes - Viewed (0) -
cmd/peer-rest-server.go
info := madmin.GetPartitions(context.Background(), globalLocalNodeName) return madminPartitions.NewJSONWith(&info), nil } // GetOSInfoHandler - returns operating system's information. func (s *peerRESTServer) GetOSInfoHandler(_ *grid.MSS) (*grid.JSON[madmin.OSInfo], *grid.RemoteErr) { info := madmin.GetOSInfo(context.Background(), globalLocalNodeName) return madminOSInfo.NewJSONWith(&info), nil }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 51.8K 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()) } err = obj.AbortMultipartUpload(context.Background(), bucket, "\\", res.UploadID, opts)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 77.1K bytes - Viewed (0) -
cmd/test-utils_test.go
applyDynamicConfigForSubSys(context.Background(), obj, globalServerConfig, config.StorageClassSubSys) // Save config. return saveServerConfig(context.Background(), obj, globalServerConfig) } // Deleting the temporary backend and stopping the server. func (testServer TestServer) Stop() { testServer.cancel() testServer.Server.Close() testServer.Obj.Shutdown(context.Background()) os.RemoveAll(testServer.Root)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:06:57 GMT 2024 - 75.7K bytes - Viewed (0) -
cmd/sts-handlers_test.go
runAllIAMSTSTests(testCase, &check{t, testCase.serverType}) }, ) } } func (s *TestSuiteIAM) TestSTSServiceAccountsWithUsername(c *check) { ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second) defer cancel() bucket := "dillon-bucket" err := s.client.MakeBucket(ctx, bucket, minio.MakeBucketOptions{}) if err != nil { c.Fatalf("bucket create error: %v", err) }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 25 15:50:16 GMT 2024 - 85.7K bytes - Viewed (0) -
cmd/object-api-listobjects_test.go
"bucket-suspended-version-id", } for _, bucket := range testBuckets { err := obj.MakeBucket(context.Background(), bucket, MakeBucketOptions{ VersioningEnabled: true, }) if err != nil { t.Fatalf("%s : %s", instanceType, err) } meta, err := loadBucketMetadata(context.Background(), obj, bucket) if err != nil { t.Fatalf("%s : %s", instanceType, err) }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 73.1K bytes - Viewed (0) -
istioctl/pkg/describe/describe.go
if err != nil { return fmt.Errorf("failed to fetch workload namespace PeerAuthentication: %v", err) } rootPAList, err := configClient.SecurityV1beta1().PeerAuthentications(meshCfg.RootNamespace).List(context.Background(), metav1.ListOptions{}) if err != nil {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 50.4K bytes - Viewed (0) -
cmd/erasure-server-pool.go
z.poolMeta.dontSave = true bootstrapTrace("newSharedLock", func() { globalLeaderLock = newSharedLock(GlobalContext, z, "leader.lock") }) // Enable background operations on // // - Disk auto healing // - MRF (most recently failed) healing // - Background expiration routine for lifecycle policies bootstrapTrace("initAutoHeal", func() { initAutoHeal(GlobalContext, z) })
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 80.1K bytes - Viewed (0) -
cmd/iam-store.go
for item := range listIAMConfigItems(context.Background(), iamOS.objAPI, iamConfigPrefix+SlashSeparator+policyDBSTSUsersListKey) { user := strings.TrimSuffix(item.Item, ".json") if userPredicate != nil && !userPredicate(user) { continue } var mappedPolicy MappedPolicy store.loadIAMConfig(context.Background(), &mappedPolicy, getMappedPolicyPath(user, stsUser, false))
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Apr 27 10:04:10 GMT 2024 - 75.2K bytes - Viewed (2) -
cmd/erasure-object.go
if err != nil { if errors.Is(err, errErasureReadQuorum) && !strings.HasPrefix(srcBucket, minioMetaBucket) { _, derr := er.deleteIfDangling(context.Background(), srcBucket, srcObject, metaArr, errs, nil, srcOpts) if derr != nil { err = derr } } return ObjectInfo{}, toObjectErr(err, srcBucket, srcObject) } // List all online disks.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 76.9K bytes - Viewed (2)