Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 108 for index (0.04 sec)

  1. cmd/erasure-decode_test.go

    		bitrotReaders := make([]io.ReaderAt, len(disks))
    		for index, disk := range disks {
    			if disk == OfflineDisk {
    				continue
    			}
    			tillOffset := erasure.ShardFileOffset(test.offset, test.length, test.data)
    
    			bitrotReaders[index] = newBitrotReader(disk, nil, "testbucket", "object", tillOffset, writeAlgorithm, bitrotWriterSum(writers[index]), erasure.ShardSize())
    		}
    
    		writer := bytes.NewBuffer(nil)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 21.1K bytes
    - Viewed (0)
  2. cmd/xl-storage-format_test.go

    	}
    	if unMarshalXLMeta.Erasure.Index != jsoniterXLMeta.Erasure.Index {
    		t.Errorf("Expected the erasure index to be %v, but got %v.", unMarshalXLMeta.Erasure.Index, jsoniterXLMeta.Erasure.Index)
    	}
    	if len(unMarshalXLMeta.Erasure.Distribution) != len(jsoniterXLMeta.Erasure.Distribution) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Feb 22 06:26:06 UTC 2024
    - 17.6K bytes
    - Viewed (0)
  3. cmd/bucket-listobjects-handlers.go

    	return subToken, false
    }
    
    func proxyRequestByNodeIndex(ctx context.Context, w http.ResponseWriter, r *http.Request, index int) (success bool) {
    	if len(globalProxyEndpoints) == 0 {
    		return false
    	}
    	if index < 0 || index >= len(globalProxyEndpoints) {
    		return false
    	}
    	ep := globalProxyEndpoints[index]
    	if ep.IsLocal {
    		return false
    	}
    	return proxyRequest(ctx, w, r, ep)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 11 03:13:30 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  4. cmd/httprange.go

    	}
    
    	// Trim byte range prefix.
    	byteRangeString := strings.TrimPrefix(rangeString, byteRangePrefix)
    
    	// Check if range string contains delimiter '-', else return error. eg. "bytes=8"
    	sepIndex := strings.Index(byteRangeString, "-")
    	if sepIndex == -1 {
    		return nil, fmt.Errorf("'%s' does not have a valid range value", rangeString)
    	}
    
    	offsetBeginString := byteRangeString[:sepIndex]
    	offsetBegin := int64(-1)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 09 08:44:07 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  5. cmd/batch-handlers.go

    	jobID := r.Form.Get("jobId")
    	if jobID == "" {
    		writeErrorResponseJSON(ctx, w, toAPIError(ctx, errInvalidArgument), r.URL)
    		return
    	}
    
    	req := BatchJobRequest{ID: jobID}
    	if i := strings.Index(jobID, "-"); i > 0 {
    		switch madmin.BatchJobType(jobID[:i]) {
    		case madmin.BatchJobReplicate:
    			req.Replicate = &BatchJobReplicateV1{}
    		case madmin.BatchJobKeyRotate:
    			req.KeyRotate = &BatchJobKeyRotateV1{}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 18 15:32:09 UTC 2024
    - 62.2K bytes
    - Viewed (0)
  6. docs/metrics/prometheus/README.md

    This document explains how to setup Prometheus and configure it to scrape data from MinIO servers.
    
    ## Prerequisites
    
    To get started with MinIO, refer [MinIO QuickStart Document](https://min.io/docs/minio/linux/index.html#quickstart-for-linux).
    Follow below steps to get started with MinIO monitoring using Prometheus.
    
    ### 1. Download Prometheus
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 12 15:49:30 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  7. cmd/bucket-handlers.go

    	bucketsToBeUpdatedSlice := bucketsToBeUpdated.ToSlice()
    	g := errgroup.WithNErrs(len(bucketsToBeUpdatedSlice)).WithConcurrency(50)
    
    	for index := range bucketsToBeUpdatedSlice {
    		index := index
    		g.Go(func() error {
    			return globalDNSConfig.Put(bucketsToBeUpdatedSlice[index])
    		}, index)
    	}
    
    	ctx := GlobalContext
    	for _, err := range g.Wait() {
    		if err != nil {
    			dnsLogIf(ctx, err)
    			return
    		}
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 12:24:04 UTC 2024
    - 63.4K bytes
    - Viewed (0)
  8. cmd/endpoint.go

    			} else if p < 1 || p > 65535 {
    				return ep, fmt.Errorf("invalid URL endpoint format: port number must be between 1 to 65535")
    			}
    		}
    		if i := strings.Index(host, "%"); i > -1 {
    			host = host[:i]
    		}
    
    		if host == "" {
    			return ep, fmt.Errorf("invalid URL endpoint format: empty host name")
    		}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 34.2K bytes
    - Viewed (0)
  9. cmd/erasure-server-pool-decom.go

    				part.Number,
    				NewPutObjReader(hr),
    				ObjectOptions{
    					PreserveETag: part.ETag, // Preserve original ETag to ensure same metadata.
    					IndexCB: func() []byte {
    						return part.Index // Preserve part Index to ensure decompression works.
    					},
    					NoAuditLog: true,
    				})
    			if err != nil {
    				return fmt.Errorf("decommissionObject: PutObjectPart() %w", err)
    			}
    			parts[i] = CompletePart{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 42.2K bytes
    - Viewed (0)
  10. cmd/osmetric_string.go

    // Code generated by "stringer -type=osMetric -trimprefix=osMetric os-instrumented.go"; DO NOT EDIT.
    
    package cmd
    
    import "strconv"
    
    func _() {
    	// An "invalid array index" compiler error signifies that the constant values have changed.
    	// Re-run the stringer command to generate them again.
    	var x [1]struct{}
    	_ = x[osMetricRemoveAll-0]
    	_ = x[osMetricMkdirAll-1]
    	_ = x[osMetricMkdir-2]
    	_ = x[osMetricRename-3]
    	_ = x[osMetricOpenFileW-4]
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Feb 15 01:09:38 UTC 2024
    - 1.3K bytes
    - Viewed (0)
Back to top