Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 106 for spool (0.03 sec)

  1. cmd/globals.go

    	consoleapi "github.com/minio/console/api"
    	"github.com/minio/dnscache"
    	"github.com/minio/madmin-go/v3"
    	"github.com/minio/minio-go/v7"
    	"github.com/minio/minio-go/v7/pkg/set"
    	"github.com/minio/minio/internal/bpool"
    	"github.com/minio/minio/internal/bucket/bandwidth"
    	"github.com/minio/minio/internal/config"
    	"github.com/minio/minio/internal/config/browser"
    	"github.com/minio/minio/internal/grid"
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  2. internal/bpool/bpool_test.go

    		t.Fatalf("bytepool length invalid: got %v want %v", len(b), width)
    	}
    	if cap(b) != capWidth {
    		t.Fatalf("bytepool cap invalid: got %v want %v", cap(b), capWidth)
    	}
    
    	bp.Put(b)
    
    	// Fill the pool beyond the capped pool size.
    	for i := uint64(0); i < size*2; i++ {
    		bp.Put(make([]byte, bp.w, bp.wcap))
    	}
    
    	b = bp.Get()
    	if len(b) != width {
    		t.Fatalf("bytepool length invalid: got %v want %v", len(b), width)
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Aug 29 01:40:52 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  3. cmd/batch-handlers.go

    	}
    	jpool.ResizeWorkers(workers)
    
    	randomWait := func() time.Duration {
    		// randomWait depends on the number of nodes to avoid triggering resume and cleanups at the same time.
    		return time.Duration(rand.Float64() * float64(time.Duration(globalEndpoints.NEndpoints())*time.Hour))
    	}
    
    	go func() {
    		jpool.resume(randomWait)
    		jpool.cleanupReports(randomWait)
    	}()
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Oct 18 15:32:09 UTC 2024
    - 62.2K bytes
    - Viewed (0)
  4. cmd/erasure-server-pool-decom_gen.go

    Harshavardhana <******@****.***> 1656968574 -0700
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jul 04 21:02:54 UTC 2022
    - 26.7K bytes
    - Viewed (0)
  5. docs/metrics/prometheus/alerts.md

        for: 5m
        labels:
          severity: critical
        annotations:
          summary: "Instance {{ $labels.server }} has lost quorum on pool {{ $labels.pool }} on set {{ $labels.set }}"
          description: "MinIO instance {{ $labels.server }} of job {{ $labels.job }} has lost quorum on pool {{ $labels.pool }} on set {{ $labels.set }} for more than 5 minutes."
    ```
    
    ## Verify the configuration and alerts
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sun Jan 28 20:53:59 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  6. cmd/metrics-v3-cluster-erasure-set.go

    	erasureSetReadQuorumMD = NewGaugeMD(erasureSetReadQuorum,
    		"Read quorum for the erasure set in a pool", poolIDL, setIDL)
    	erasureSetWriteQuorumMD = NewGaugeMD(erasureSetWriteQuorum,
    		"Write quorum for the erasure set in a pool", poolIDL, setIDL)
    	erasureSetOnlineDrivesCountMD = NewGaugeMD(erasureSetOnlineDrivesCount,
    		"Count of online drives in the erasure set in a pool", poolIDL, setIDL)
    	erasureSetHealingDrivesCountMD = NewGaugeMD(erasureSetHealingDrivesCount,
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue May 14 07:25:56 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  7. cmd/admin-handlers-pools.go

    			}
    		} else {
    			idx = globalEndpoints.GetPoolIdx(pool)
    			if idx == -1 {
    				// We didn't find any matching pools, invalid input
    				writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, errInvalidArgument), r.URL)
    				return
    			}
    		}
    		var pool *erasureSets
    		for pidx := range z.serverPools {
    			if pidx == idx {
    				pool = z.serverPools[idx]
    				break
    			}
    		}
    		if pool == nil {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Jun 28 00:22:30 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  8. cmd/fmt-gen.go

    	if err != nil {
    		log.Fatalf("failed to create format.json.zip: %v", err)
    	}
    	defer zipFile.Close()
    	fmtZipW := zip.NewWriter(zipFile)
    	defer fmtZipW.Close()
    	for _, pool := range pools { // for each pool
    		setCount, setDriveCount := pool.SetCount, pool.DrivesPerSet
    		format := newFormatErasureV3(setCount, setDriveCount)
    		format.ID = deploymentID
    		for i := 0; i < setCount; i++ { // for each erasure set
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Aug 13 22:22:04 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  9. internal/event/target/redis.go

    }
    
    // Close - releases the resources used by the pool.
    func (target *RedisTarget) Close() error {
    	close(target.quitCh)
    	if target.pool != nil {
    		return target.pool.Close()
    	}
    	return nil
    }
    
    func (target *RedisTarget) init() error {
    	return target.initOnce.Do(target.initRedis)
    }
    
    func (target *RedisTarget) initRedis() error {
    	conn := target.pool.Get()
    	defer conn.Close()
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  10. docs/distributed/DESIGN.md

                    if atTotal > choose && pool.Available > 0 {
                            return pool.Index
                    }
            }
            // Should not happen, but print values just in case.
            panic(fmt.Errorf("reached end of serverPools (total: %v, atTotal: %v, choose: %v)", total, atTotal, choose))
    }
    ```
    
    ## Other usages
    
    ### Advanced use cases with multiple ellipses
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Aug 15 23:04:20 UTC 2023
    - 8K bytes
    - Viewed (0)
Back to top