Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 21 for Background (0.2 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top