Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 126 for Sets (0.14 sec)

  1. cmd/erasure-sets.go

    func (s *erasureSets) StorageInfo(ctx context.Context) StorageInfo {
    	var storageInfo madmin.StorageInfo
    
    	storageInfos := make([]madmin.StorageInfo, len(s.sets))
    
    	g := errgroup.WithNErrs(len(s.sets))
    	for index := range s.sets {
    		index := index
    		g.Go(func() error {
    			storageInfos[index] = s.sets[index].StorageInfo(ctx)
    			return nil
    		}, index)
    	}
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Apr 15 08:25:46 GMT 2024
    - 37.5K bytes
    - Viewed (5)
  2. cmd/erasure-sets_test.go

    // consistently for a given object name.
    func TestHashedLayer(t *testing.T) {
    	// Test distribution with 16 sets.
    	var objs [16]*erasureObjects
    	for i := range objs {
    		objs[i] = &erasureObjects{}
    	}
    
    	sets := &erasureSets{sets: objs[:], distributionAlgo: "CRCMOD"}
    
    	testCases := []struct {
    		objectName  string
    		expectedObj *erasureObjects
    	}{
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Feb 12 07:21:56 GMT 2024
    - 6.9K bytes
    - Viewed (0)
  3. cmd/object-api-interface.go

    	r.ReplicationStatusInternal = rstatus
    	r.Targets = replicationStatusesMap(rstatus)
    	return
    }
    
    // SetEvalMetadataFn sets the metadata evaluation function
    func (o *ObjectOptions) SetEvalMetadataFn(f EvalMetadataFn) {
    	o.EvalMetadataFn = f
    }
    
    // SetEvalRetentionBypassFn sets the retention bypass function
    func (o *ObjectOptions) SetEvalRetentionBypassFn(f EvalRetentionBypassFn) {
    	o.EvalRetentionBypassFn = f
    }
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sat Apr 20 09:05:54 GMT 2024
    - 16.9K bytes
    - Viewed (0)
  4. cmd/global-heal.go

    				ss.HealPriority = "high"
    				status.HealDisks = append(status.HealDisks, disk.Endpoint)
    			}
    		}
    		sortDisks(ss.Disks)
    		status.Sets = append(status.Sets, ss)
    	}
    	sort.Slice(status.Sets, func(i, j int) bool {
    		return status.Sets[i].ID < status.Sets[j].ID
    	})
    
    	backendInfo := o.BackendInfo()
    	status.SCParity = make(map[string]int)
    	status.SCParity[storageclass.STANDARD] = backendInfo.StandardSCParity
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Apr 08 09:22:13 GMT 2024
    - 14.2K bytes
    - Viewed (1)
  5. docs/distributed/DESIGN.md

    - *If total drives has many common divisors the algorithm chooses the minimum amounts of erasure sets possible for a erasure set size of any N*.  In the example with 1024 drives - 4, 8, 16 are GCD factors. With 16 drives we get a total of 64 possible sets, with 8 drives we get a total of 128 possible sets, with 4 drives we get a total of 256 possible sets. So algorithm automatically chooses 64 sets, which is *16* 64 = 1024* drives in total.
    
    Plain Text
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Aug 15 23:04:20 GMT 2023
    - 8K bytes
    - Viewed (0)
  6. internal/config/errors.go

    		`MINIO_STORAGE_CLASS_STANDARD: Format "EC:<Default_Parity_Standard_Class>" (e.g. "EC:3"). This sets the number of parity drives for MinIO server in Standard mode. Objects are stored in Standard mode, if storage class is not defined in Put request
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Mar 18 22:25:32 GMT 2024
    - 9.1K bytes
    - Viewed (0)
  7. cmd/metrics-v3-types.go

    			}
    			metrics = append(metrics,
    				prometheus.MustNewConstMetric(promDesc, desc.Type.toProm(), v.Value,
    					labelValues...))
    		}
    	}
    	return metrics
    }
    
    // Set - sets a metric value along with any provided labels. It is used only
    // with Gauge and Counter metrics.
    //
    // If the MetricName given here is not present in the `MetricsGroup`'s
    // descriptors, this function panics.
    //
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sun Mar 10 09:15:15 GMT 2024
    - 14.6K bytes
    - Viewed (0)
  8. cmd/routers.go

    	// set x-amz-request-id header and others
    	addCustomHeadersMiddleware,
    	// The generic tracer needs to be the first middleware to catch all requests
    	// returned early by any other middleware (but after the middleware that
    	// sets the amz request id).
    	httpTracerMiddleware,
    	// Auth middleware verifies incoming authorization headers and routes them
    	// accordingly. Client receives a HTTP error for invalid/unsupported
    	// signatures.
    	//
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Mar 08 19:08:18 GMT 2024
    - 3.6K bytes
    - Viewed (1)
  9. cmd/erasure.go

    	// Put all buckets into channel.
    	bucketCh := make(chan BucketInfo, len(buckets))
    
    	// Shuffle buckets to ensure total randomness of buckets, being scanned.
    	// Otherwise same set of buckets get scanned across erasure sets always.
    	// at any given point in time. This allows different buckets to be scanned
    	// in different order per erasure set, this wider spread is needed when
    	// there are lots of buckets with different order of objects in them.
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Apr 15 10:02:39 GMT 2024
    - 16K bytes
    - Viewed (1)
  10. cmd/erasure-healing_test.go

    		t.Fatalf("Unable to initialize server config. %s", err)
    	}
    
    	defer removeRoots(fsDirs)
    
    	z := obj.(*erasureServerPools)
    	er := z.serverPools[0].sets[0]
    
    	// Create "bucket"
    	err = obj.MakeBucket(ctx, "bucket", MakeBucketOptions{})
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	bucket := "bucket"
    	object := "object"
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Wed Mar 27 15:10:40 GMT 2024
    - 47.6K bytes
    - Viewed (0)
Back to top