Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for 1040 (0.56 sec)

  1. cmd/httprange_test.go

    	}{
    		{"bytes=0-", 0, 10},
    		{"bytes=1-", 1, 9},
    		{"bytes=0-9", 0, 10},
    		{"bytes=1-10", 1, 9},
    		{"bytes=1-1", 1, 1},
    		{"bytes=2-5", 2, 4},
    		{"bytes=-5", 5, 5},
    		{"bytes=-1", 9, 1},
    		{"bytes=-1000", 0, 10},
    	}
    	for i, testCase := range validRangeSpecs {
    		rs, err := parseRequestRangeSpec(testCase.spec)
    		if err != nil {
    			t.Errorf("unexpected err: %v", err)
    		}
    		o, l, err := rs.GetOffsetLength(resourceSize)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 3.7K bytes
    - Viewed (0)
  2. internal/bucket/replication/replication.go

    			}
    		}
    	}
    	return &config, nil
    }
    
    // Validate - validates the replication configuration
    func (c Config) Validate(bucket string, sameTarget bool) error {
    	// replication config can't have more than 1000 rules
    	if len(c.Rules) > 1000 {
    		return errReplicationTooManyRules
    	}
    	// replication config should have at least one rule
    	if len(c.Rules) == 0 {
    		return errReplicationNoRule
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Mar 28 17:44:56 GMT 2024
    - 8.9K bytes
    - Viewed (0)
  3. cmd/jwt.go

    	errMalformedAuth      = errors.New("Malformed authentication input")
    )
    
    type cacheKey struct {
    	accessKey, secretKey, audience string
    }
    
    var cacheLRU = expirable.NewLRU[cacheKey, string](1000, nil, 15*time.Second)
    
    func authenticateNode(accessKey, secretKey, audience string) (string, error) {
    	claims := xjwt.NewStandardClaims()
    	claims.SetExpiry(UTCNow().Add(defaultInterNodeJWTExpiry))
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:45:14 GMT 2024
    - 5.4K bytes
    - Viewed (0)
  4. cmd/metrics-v3-cache.go

    	if ioStats.WriteIOs > 0 {
    		m.writesAwait = float64(ioStats.WriteTicks) / float64(ioStats.WriteIOs)
    	}
    
    	// TotalTicks is in milliseconds
    	m.percUtil = float64(ioStats.TotalTicks) * 100 / (durationSecs * 1000)
    
    	return
    }
    
    func newDriveMetricsCache() *cachevalue.Cache[storageMetrics] {
    	var (
    		// prevDriveIOStats is used to calculate "per second"
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 23:56:12 GMT 2024
    - 7.9K bytes
    - Viewed (0)
  5. cmd/erasure-metadata_test.go

    }
    
    func TestFindFileInfoInQuorum(t *testing.T) {
    	getNFInfo := func(n int, quorum int, t int64, dataDir string, succModTimes []time.Time) []FileInfo {
    		fi := newFileInfo("test", 8, 8)
    		fi.AddObjectPart(1, "etag", 100, 100, UTCNow(), nil, nil)
    		fi.ModTime = time.Unix(t, 0)
    		fi.DataDir = dataDir
    		fis := make([]FileInfo, n)
    		for i := range fis {
    			fis[i] = fi
    			fis[i].Erasure.Index = i + 1
    			if succModTimes != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 00:31:12 GMT 2024
    - 9.1K bytes
    - Viewed (0)
Back to top