Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 76 for init (0.2 sec)

  1. cmd/metacache-set.go

    func getListQuorum(quorum string, driveCount int) int {
    	switch quorum {
    	case "disk":
    		return 1
    	case "reduced":
    		return 2
    	case "optimal":
    		return (driveCount + 1) / 2
    	case "auto":
    		return -1
    	}
    	// defaults to 'strict'
    	return driveCount
    }
    
    func calcCommonWritesDeletes(infos []DiskInfo, readQuorum int) (commonWrite, commonDelete uint64) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 17:59:08 GMT 2024
    - 30.4K bytes
    - Viewed (0)
  2. cmd/admin-handlers.go

    }
    
    func getPoolsInfo(ctx context.Context, allDisks []madmin.Disk) (map[int]map[int]madmin.ErasureSetInfo, error) {
    	objectAPI := newObjectLayerFn()
    	if objectAPI == nil {
    		return nil, errServerNotInitialized
    	}
    
    	z, ok := objectAPI.(*erasureServerPools)
    	if !ok {
    		return nil, errServerNotInitialized
    	}
    
    	poolsInfo := make(map[int]map[int]madmin.ErasureSetInfo)
    	for _, d := range allDisks {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 29 17:39:04 GMT 2024
    - 97.8K bytes
    - Viewed (2)
  3. cmd/object-api-interface.go

    	MaxParts            int                 // used in GetObjectAttributes. Signals how many parts we should return
    	PartNumberMarker    int                 // used in GetObjectAttributes. Signals the part number after which results should be returned
    	PartNumber          int                 // only useful in case of GetObject/HeadObject
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 17K bytes
    - Viewed (0)
  4. internal/bucket/lifecycle/lifecycle.go

    // Event contains a lifecycle action with associated info
    type Event struct {
    	Action                  Action
    	RuleID                  string
    	Due                     time.Time
    	NoncurrentDays          int
    	NewerNoncurrentVersions int
    	StorageClass            string
    }
    
    // Eval returns the lifecycle event applicable now.
    func (lc Lifecycle) Eval(obj ObjectOpts) Event {
    	return lc.eval(obj, time.Now().UTC())
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:11:10 GMT 2024
    - 17.5K bytes
    - Viewed (0)
  5. cmd/erasure.go

    // OfflineDisk represents an unavailable disk.
    var OfflineDisk StorageAPI // zero value is nil
    
    // erasureObjects - Implements ER object layer.
    type erasureObjects struct {
    	setDriveCount      int
    	defaultParityCount int
    
    	setIndex  int
    	poolIndex int
    
    	// getDisks returns list of storageAPIs.
    	getDisks func() []StorageAPI
    
    	// getLockers returns list of remote and local lockers.
    	getLockers func() ([]dsync.NetLocker, string)
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 16K bytes
    - Viewed (1)
  6. cmd/erasure-multipart.go

    			UploadID:  base64.RawURLEncoding.EncodeToString([]byte(fmt.Sprintf("%s.%s", globalDeploymentID(), uploadID))),
    			Initiated: startTime,
    		})
    		populatedUploadIDs.Add(uploadID)
    	}
    
    	sort.Slice(uploads, func(i int, j int) bool {
    		return uploads[i].Initiated.Before(uploads[j].Initiated)
    	})
    
    	uploadIndex := 0
    	if uploadIDMarker != "" {
    		for uploadIndex < len(uploads) {
    			if uploads[uploadIndex].UploadID != uploadIDMarker {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 43K bytes
    - Viewed (0)
  7. cmd/batch-handlers.go

    type batchJobInfo struct {
    	mu sync.RWMutex `json:"-" msg:"-"`
    
    	Version       int       `json:"-" msg:"v"`
    	JobID         string    `json:"jobID" msg:"jid"`
    	JobType       string    `json:"jobType" msg:"jt"`
    	StartTime     time.Time `json:"startTime" msg:"st"`
    	LastUpdate    time.Time `json:"lastUpdate" msg:"lu"`
    	RetryAttempts int       `json:"retryAttempts" msg:"ra"`
    
    	Complete bool `json:"complete" msg:"cmp"`
    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)
  8. cmd/sts-handlers.go

    		writeSTSErrorResponse(ctx, w, ErrSTSInvalidParameterValue, fmt.Errorf("Invalid empty `Token` parameter provided"))
    		return
    	}
    
    	durationParam := r.Form.Get(stsDurationSeconds)
    	var requestedDuration int
    	if durationParam != "" {
    		var err error
    		requestedDuration, err = strconv.Atoi(durationParam)
    		if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 21:31:13 GMT 2024
    - 34.7K bytes
    - Viewed (2)
  9. cmd/erasure-metadata_test.go

    	"time"
    
    	"github.com/dustin/go-humanize"
    )
    
    const ActualSize = 1000
    
    // Test FileInfo.AddObjectPart()
    func TestAddObjectPart(t *testing.T) {
    	testCases := []struct {
    		partNum       int
    		expectedIndex int
    	}{
    		{1, 0},
    		{2, 1},
    		{4, 2},
    		{5, 3},
    		{7, 4},
    		// Insert part.
    		{3, 2},
    		// Replace existing part.
    		{4, 3},
    		// Missing part.
    		{6, -1},
    	}
    
    	// Setup.
    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)
  10. cmd/global-heal.go

    			}
    		}
    		sortDisks(ss.Disks)
    		status.Sets = append(status.Sets, ss)
    	}
    	sort.Slice(status.Sets, func(i, j int) bool {
    		return status.Sets[i].ID < status.Sets[j].ID
    	})
    
    	backendInfo := o.BackendInfo()
    	status.SCParity = make(map[string]int)
    	status.SCParity[storageclass.STANDARD] = backendInfo.StandardSCParity
    	status.SCParity[storageclass.RRS] = backendInfo.RRSCParity
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 15K bytes
    - Viewed (1)
Back to top