- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 76 for init (0.2 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)