Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for Workers (0.21 sec)

  1. docs/metrics/prometheus/grafana/replication/minio-replication-node.json

              },
              "exemplar": true,
              "expr": "sum by (server) (minio_cluster_replication_average_active_workers{job=\"$scrape_jobs\"})",
              "interval": "1m",
              "intervalFactor": 2,
              "legendFormat": "{{server}}",
              "refId": "A"
            }
          ],
          "title": "Avg. Active Workers",
          "type": "timeseries"
        },
        {
          "datasource": {
            "type": "prometheus",
    Json
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Mar 28 17:15:39 GMT 2024
    - 57.5K bytes
    - Viewed (0)
  2. cmd/erasure-server-pool.go

    		if _, ok := err.(InsufficientReadQuorum); ok {
    			return objInfo, InsufficientWriteQuorum{}
    		}
    		return objInfo, err
    	}
    
    	// Delete marker already present we are not going to create new delete markers.
    	if pinfo.ObjInfo.DeleteMarker && opts.VersionID == "" {
    		pinfo.ObjInfo.Name = decodeDirObject(object)
    		return pinfo.ObjInfo, nil
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (0)
  3. cmd/batch-handlers.go

    // newBatchJobPool creates a pool of job manifest workers of specified size
    func newBatchJobPool(ctx context.Context, o ObjectLayer, workers int) *BatchJobPool {
    	jpool := &BatchJobPool{
    		ctx:          ctx,
    		objLayer:     o,
    		jobCh:        make(chan *BatchJobRequest, 10000),
    		workerKillCh: make(chan struct{}, workers),
    		jobCancelers: make(map[string]context.CancelFunc),
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 55.2K bytes
    - Viewed (0)
  4. cmd/erasure-object.go

    				errFileVersionNotFound,
    				errFileCorrupt,
    			) {
    				missingBlocks++
    			}
    		}
    
    		// if missing metadata can be reconstructed, attempt to reconstruct.
    		// additionally do not heal delete markers inline, let them be
    		// healed upon regular heal process.
    		if missingBlocks > 0 && missingBlocks < fi.Erasure.DataBlocks {
    			globalMRFState.addPartialOp(partialOperation{
    				bucket:    fi.Volume,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 77.2K bytes
    - Viewed (2)
  5. cmd/object-api-listobjects_test.go

    		// Test listing an object with uncommon delimiter and matching prefix
    		{testBuckets[4], "file1/", "", "guidSplunk", 1000, resultCases[35], nil, true},
    		// Test listing at prefix with expected prefix markers
    		{testBuckets[5], "dir/", "", SlashSeparator, 1, resultCases[36], nil, true},
    		// Test listing with prefix match
    		{testBuckets[5], "foo/201910/11", "", "", 1000, resultCases[37], nil, true},
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 11:07:40 GMT 2024
    - 73.1K bytes
    - Viewed (0)
  6. cmd/xl-storage-format-v2.go

    		}
    		isDeleteMarker = xl.Type == DeleteType
    		return errDoneForNow
    	})
    	return isDeleteMarker
    }
    
    // AllHidden returns true are no versions that would show up in a listing (ie all free markers)
    // Optionally also return early if top is a delete marker.
    func (x xlMetaBuf) AllHidden(topDeleteMarker bool) bool {
    	vers, headerV, _, buf, err := decodeXLHeaders(x)
    	if err != nil {
    		return false
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 05:07:37 GMT 2024
    - 63.6K bytes
    - Viewed (1)
Back to top