Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for Errors (1.67 sec)

  1. cmd/httprange_test.go

    	}
    	for i, urs := range unparsableRangeSpecs {
    		rs, err := parseRequestRangeSpec(urs)
    		if err == nil {
    			t.Errorf("Case %d: Did not get an expected error - got %v", i, rs)
    		}
    		if isErrInvalidRange(err) {
    			t.Errorf("Case %d: Got invalid range error instead of a parse error", i)
    		}
    		if rs != nil {
    			t.Errorf("Case %d: Got non-nil rs though err != nil: %v", i, rs)
    		}
    	}
    
    	invalidRangeSpecs := []string{
    		"bytes=5-3",
    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. cmd/data-scanner_test.go

    	close(workers[0])
    	wg.Wait()
    	for _, obj := range expired {
    		switch obj.ObjectV.VersionID {
    		case uuids[2].String(), uuids[3].String(), uuids[4].String():
    		default:
    			t.Errorf("Unexpected versionID being expired: %#v\n", obj)
    		}
    	}
    }
    
    func TestEvalActionFromLifecycle(t *testing.T) {
    	// Tests cover only ExpiredObjectDeleteAllVersions and DelMarkerExpiration actions
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 11:18:58 GMT 2024
    - 6.9K bytes
    - Viewed (0)
  3. internal/logger/logrotate.go

    	f, err := newFile(path)
    	if err != nil {
    		return fmt.Errorf("unable to create new file at %v: %w", path, err)
    	}
    
    	w.f = f
    
    	return nil
    }
    
    // NewDir creates a new concurrency safe Writer which performs log rotation.
    func NewDir(opts Options) (io.WriteCloser, error) {
    	if err := os.MkdirAll(opts.Directory, os.ModePerm); err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 02 11:38:40 GMT 2024
    - 5.8K bytes
    - Viewed (0)
  4. cmd/metrics-v3-handler.go

    )
    
    type promLogger struct{}
    
    func (p promLogger) Println(v ...interface{}) {
    	s := make([]string, 0, len(v))
    	for _, val := range v {
    		s = append(s, fmt.Sprintf("%v", val))
    	}
    	err := fmt.Errorf("metrics handler error: %v", strings.Join(s, " "))
    	metricsLogIf(GlobalContext, err)
    }
    
    type metricsV3Server struct {
    	registry *prometheus.Registry
    	opts     promhttp.HandlerOpts
    	authFn   func(http.Handler) http.Handler
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 02 17:37:57 GMT 2024
    - 7.5K bytes
    - Viewed (0)
  5. cmd/httprange.go

    			return nil, fmt.Errorf("Byte position ('%s') must not have a sign", offsetBeginString)
    		} else if offsetBegin, err = strconv.ParseInt(offsetBeginString, 10, 64); err != nil {
    			return nil, fmt.Errorf("'%s' does not have a valid first byte position value", rangeString)
    		} else if offsetBegin < 0 {
    			return nil, fmt.Errorf("First byte position is negative ('%d')", offsetBegin)
    		}
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 5.9K bytes
    - Viewed (0)
  6. cmd/metrics-v3-cluster-iam.go

    )
    
    // loadClusterIAMMetrics - `MetricsLoaderFn` for cluster IAM metrics.
    func loadClusterIAMMetrics(_ context.Context, m MetricValues, _ *metricsCache) error {
    	m.Set(lastSyncDurationMillis, float64(atomic.LoadUint64(&globalIAMSys.LastRefreshDurationMilliseconds)))
    	pluginAuthNMetrics := globalAuthNPlugin.Metrics()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 02 08:20:42 GMT 2024
    - 4.5K bytes
    - Viewed (0)
Back to top