Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 55 for Ball (0.18 sec)

  1. cmd/admin-handlers-idp-ldap.go

    //	policy mapping
    //
    //	policy=... -> repeatable query parameter, specifying policy to query for
    //	user/group mapping
    //
    // When all query parameters are omitted, returns mappings for all policies.
    func (a adminAPIHandlers) ListLDAPPolicyMappingEntities(w http.ResponseWriter, r *http.Request) {
    	ctx := r.Context()
    
    	// Check authorization.
    
    	objectAPI, cred := validateAdminReq(ctx, w, r,
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 25 15:50:16 GMT 2024
    - 13.3K bytes
    - Viewed (0)
  2. cmd/erasure-multipart.go

    }
    
    // writeAllDisks - writes 'b' to all provided disks.
    // If write cannot reach quorum, the files will be deleted from all disks.
    func writeAllDisks(ctx context.Context, disks []StorageAPI, dstBucket, dstEntry string, b []byte, writeQuorum int) ([]StorageAPI, error) {
    	g := errgroup.WithNErrs(len(disks))
    
    	// Write file to all underlying storage disks.
    	for index := range disks {
    		index := index
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 43K bytes
    - Viewed (0)
  3. cmd/erasure-healing.go

    	if err := listPathRaw(ctx, lopts); err != nil {
    		return fmt.Errorf("listPathRaw returned %w: opts(%#v)", err, lopts)
    	}
    
    	return nil
    }
    
    // listAllBuckets lists all buckets from all disks. It also
    // returns the occurrence of each buckets in all disks
    func listAllBuckets(ctx context.Context, storageDisks []StorageAPI, healBuckets map[string]VolInfo, readQuorum int) error {
    	g := errgroup.WithNErrs(len(storageDisks))
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 33.1K bytes
    - Viewed (0)
  4. cmd/server-main.go

    		if globalIsDistErasure {
    			logger.Info("Waiting for all MinIO sub-systems to be initialize...")
    		}
    
    		// Upon success migrating the config, initialize all sub-systems
    		// if all sub-systems initialized successfully return right away
    		err := initConfigSubsystem(ctx, newObject)
    		if err == nil {
    			// All successful return.
    			if globalIsDistErasure {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 33K bytes
    - Viewed (1)
  5. cmd/object-handlers_test.go

    			if objLen == 0 {
    				continue
    			}
    
    			// Various ranges to query - all are valid!
    			rangeHdrs := []string{
    				// Read first byte of object
    				fmt.Sprintf("bytes=%d-%d", 0, 0),
    				// Read second byte of object
    				fmt.Sprintf("bytes=%d-%d", 1, 1),
    				// Read last byte of object
    				fmt.Sprintf("bytes=-%d", 1),
    				// Read all but first byte of object
    				"bytes=1-",
    				// Read first half of object
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 160K bytes
    - Viewed (0)
  6. cmd/metacache-set.go

    			askDisks = getListQuorum("strict", er.setDriveCount)
    		}
    	}
    
    	var fallbackDisks []StorageAPI
    
    	// Special case: ask all disks if the drive count is 4
    	if er.setDriveCount == 4 || askDisks > len(disks) {
    		askDisks = len(disks) // use all available drives
    	}
    
    	// However many we ask, versions must exist on ~50%
    	listingQuorum := (askDisks + 1) / 2
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 19:52:52 GMT 2024
    - 30.4K bytes
    - Viewed (0)
  7. cmd/metrics-v3.go

    	// we also have standard collectors like `GoCollector`.
    
    	// Create all Non-`MetricGroup` collectors here.
    	collectors := map[collectorPath]prometheus.Collector{
    		systemGoCollectorPath: collectors.NewGoCollector(),
    	}
    
    	// Add all `MetricGroup` collectors to the map.
    	for _, mg := range allMetricGroups {
    		collectors[mg.CollectorPath] = mg
    	}
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 16:07:23 GMT 2024
    - 10K bytes
    - Viewed (0)
  8. cmd/data-scanner.go

    	if action == lifecycle.DeleteAllVersionsAction {
    		return true, 0
    	}
    
    	// For instance, an applied lifecycle means we remove/transitioned an object
    	// from the current deployment, which means we don't have to call healing
    	// routine even if we are asked to do via heal flag.
    	if action == lifecycle.NoneAction {
    		if i.heal.enabled {
    			done := globalScannerMetrics.time(scannerMetricHealCheck)
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 47.4K bytes
    - Viewed (0)
  9. cmd/admin-handlers-users.go

    	encryptedData, err := madmin.EncryptData(cred.SecretKey, data)
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    
    	writeSuccessResponseJSON(w, encryptedData)
    
    	// Call hook for cluster-replication if the service account is not for a
    	// root user.
    	if newCred.ParentUser != globalActiveCred.AccessKey {
    		replLogIf(ctx, globalSiteReplicationSys.IAMChangeHook(ctx, madmin.SRIAMItem{
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 25 15:50:16 GMT 2024
    - 77.3K bytes
    - Viewed (0)
  10. cmd/data-usage-cache.go

    			// spl interval: [1024B, 1MiB)
    			res[szInt.name] = splCount
    		case humanize.KiByte <= szInt.start && szInt.end <= humanize.MiByte-1:
    			// intervals that fall within the spl interval above; they
    			// appear earlier in this array of intervals, see
    			// ObjectsHistogramIntervals
    			splCount += count
    			fallthrough
    		default:
    			res[szInt.name] = count
    		}
    	}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 41.4K bytes
    - Viewed (1)
Back to top