Search Options

Results per page
Sort
Preferred Languages
Advance

Results 501 - 510 of 2,448 for errorf (0.08 sec)

  1. cmd/site-replication_test.go

    			[]string{},
    		},
    	}
    
    	for i, tc := range testCases {
    		names := getMissingSiteNames(tc.oldDepIDs, tc.newDepIDs, tc.currSites)
    		if len(names) != len(tc.expNames) {
    			t.Errorf("Test %d: Expected `%v`, got `%v`", i+1, tc.expNames, names)
    		}
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 20 00:53:08 UTC 2023
    - 2.2K bytes
    - Viewed (0)
  2. internal/event/targetlist.go

    	maxConcurrentAsyncSend = 50000
    )
    
    // Target - event target interface
    type Target interface {
    	ID() TargetID
    	IsActive() (bool, error)
    	Save(Event) error
    	SendFromStore(store.Key) error
    	Close() error
    	Store() TargetStore
    }
    
    // TargetStore is a shallow version of a target.Store
    type TargetStore interface {
    	Len() int
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  3. cmd/bucket-replication-utils.go

    // parse size from content-range header
    func parseSizeFromContentRange(h http.Header) (sz int64, err error) {
    	cr := h.Get(xhttp.ContentRange)
    	if cr == "" {
    		return sz, fmt.Errorf("Content-Range not set")
    	}
    	parts := contentRangeRegexp.FindStringSubmatch(cr)
    	if len(parts) != 4 {
    		return sz, fmt.Errorf("invalid Content-Range header %s", cr)
    	}
    	if parts[3] == "*" {
    		return -1, nil
    	}
    	var usz uint64
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 26.3K bytes
    - Viewed (0)
  4. cmd/data-scanner.go

    func scanDataFolder(ctx context.Context, disks []StorageAPI, drive *xlStorage, cache dataUsageCache, getSize getSizeFn, scanMode madmin.HealScanMode, weSleep func() bool) (dataUsageCache, error) {
    	switch cache.Info.Name {
    	case "", dataUsageRoot:
    		return cache, errors.New("internal error: root scan attempted")
    	}
    	basePath := drive.drivePath
    	updatePath, closeDisk := globalScannerMetrics.currentPathUpdater(basePath, cache.Info.Name)
    	defer closeDisk()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 21:10:34 UTC 2024
    - 48.4K bytes
    - Viewed (0)
  5. internal/logger/target/console/console.go

    func (c *Target) Validate() error {
    	return nil
    }
    
    // Endpoint returns the backend endpoint
    func (c *Target) Endpoint() string {
    	return ""
    }
    
    func (c *Target) String() string {
    	return "console"
    }
    
    // Send log message 'e' to console
    func (c *Target) Send(e interface{}) error {
    	entry, ok := e.(log.Entry)
    	if !ok {
    		return fmt.Errorf("Uexpected log entry structure %#v", e)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  6. cmd/peer-rest-client.go

    	err = gob.NewDecoder(waitReader).Decode(&result)
    	if err != nil {
    		return result, err
    	}
    	if result.Error != "" {
    		return result, errors.New(result.Error)
    	}
    	return result, nil
    }
    
    func (client *peerRESTClient) DriveSpeedTest(ctx context.Context, opts madmin.DriveSpeedTestOpts) (madmin.DriveSpeedTestResult, error) {
    	queryVals := make(url.Values)
    	if opts.Serial {
    		queryVals.Set("serial", "true")
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  7. internal/config/browser/browser.go

    		cfg.ReferrerPolicy = referrerPolicy
    	default:
    		return cfg, fmt.Errorf("invalid value %v for %s", referrerPolicy, browserReferrerPolicy)
    	}
    
    	return cfg, nil
    }
    
    // GetCSPolicy - Get the Content security Policy
    func (browseCfg *Config) GetCSPolicy() string {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 21 00:58:58 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  8. cmd/xl-storage-free-version.go

    	return false
    }
    
    // AddFreeVersion adds a free-version if needed for fi.VersionID version.
    // Free-version will be added if fi.VersionID has transitioned.
    func (x *xlMetaV2) AddFreeVersion(fi FileInfo) error {
    	var uv uuid.UUID
    	var err error
    	switch fi.VersionID {
    	case "", nullVersionID:
    	default:
    		uv, err = uuid.Parse(fi.VersionID)
    		if err != nil {
    			return err
    		}
    	}
    
    	for i, version := range x.versions {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Mar 02 05:11:03 UTC 2024
    - 3.4K bytes
    - Viewed (0)
  9. internal/event/target/nsq.go

    }
    
    // Validate NSQArgs fields
    func (n NSQArgs) Validate() error {
    	if !n.Enable {
    		return nil
    	}
    
    	if n.NSQDAddress.IsEmpty() {
    		return errors.New("empty nsqdAddress")
    	}
    
    	if n.Topic == "" {
    		return errors.New("empty topic")
    	}
    	if n.QueueDir != "" {
    		if !filepath.IsAbs(n.QueueDir) {
    			return errors.New("queueDir path should be absolute")
    		}
    	}
    
    	return nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  10. clause/joins_test.go

    			stmt := &gorm.Statement{DB: db, Table: user.Table, Schema: user, Clauses: map[string]clause.Clause{}}
    			result.join.Build(stmt)
    			if result.sql != stmt.SQL.String() {
    				t.Errorf("want: %s, got: %s", result.sql, stmt.SQL.String())
    			}
    		})
    	}
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Nov 03 13:03:13 UTC 2022
    - 2.6K bytes
    - Viewed (0)
Back to top