- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 116 for indexOf (0.15 sec)
-
index.yaml
Harshavardhana <******@****.***> 1714299277 -0700
Others - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 10:14:37 GMT 2024 - 53.9K bytes - Viewed (0) -
cmd/erasure-object.go
fi := metadata[index] // Assign index when index is initialized if fi.Erasure.Index == 0 { fi.Erasure.Index = index + 1 } if !fi.IsValid() { return errFileCorrupt } resp, err := disks[index].RenameData(ctx, srcBucket, srcEntry, fi, dstBucket, dstEntry, RenameOptions{}) if err != nil { return err } diskVersions[index] = resp.Sign
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 77.2K bytes - Viewed (2) -
cmd/erasure-server-pool-rebalance.go
part.Number, NewPutObjReader(hr), ObjectOptions{ PreserveETag: part.ETag, // Preserve original ETag to ensure same metadata. IndexCB: func() []byte { return part.Index // Preserve part Index to ensure decompression works. }, NoAuditLog: true, }) if err != nil { return fmt.Errorf("rebalanceObject: PutObjectPart() %w", err) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 19:29:28 GMT 2024 - 27.2K bytes - Viewed (0) -
cmd/erasure-common.go
} g := errgroup.WithNErrs(len(disks)) // Read files in parallel across disks. for index := range disks { index := index g.Go(func() (err error) { if disks[index] == nil { return errDiskNotFound } return disks[index].ReadMultiple(ctx, req, resps[index]) }, index) } dataArray := make([]ReadMultipleResp, 0, len(req.Files))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 4.6K bytes - Viewed (0) -
docs/debugging/reorder-disks/main.go
exp := argP.Expand() if node == "" { for index, e := range exp { result = append(result, localDisk{index: index, path: strings.Join(e, "")}) } } else { for index, e := range exp { u, err := url.Parse(strings.Join(e, "")) if err != nil { return nil, err } if strings.Contains(u.Host, node) { result = append(result, localDisk{index: index, path: u.Path}) } } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.4K bytes - Viewed (0) -
cmd/erasure-server-pool.go
nSets := make([]int, len(z.serverPools)) g := errgroup.WithNErrs(len(z.serverPools)) for index := range z.serverPools { index := index // Skip suspended pools or pools participating in rebalance for any new // I/O. if z.IsSuspended(index) || z.IsPoolRebalancing(index) { continue } pool := z.serverPools[index] nSets[index] = pool.setCount g.Go(func() error { // Get the set where it would be placed.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 80.5K bytes - Viewed (0) -
internal/grid/handlers_string.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 4.2K bytes - Viewed (0) -
internal/s3select/sql/jsonpath.go
} val, err := IterToValue(elem.Iter) if err != nil { return nil, false, err } return jsonpathEval(p[1:], val) default: return nil, false, errKeyLookup } case p[0].Index != nil: idx := *p[0].Index arr, ok := v.([]interface{}) if !ok { return nil, false, errIndexLookup } if idx >= len(arr) { return nil, false, nil } return jsonpathEval(p[1:], arr[idx])
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 3.4K bytes - Viewed (0) -
cmd/object-multipart-handlers.go
if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } if dstOpts.IndexCB != nil { dstOpts.IndexCB = compressionIndexEncrypter(objectEncryptionKey, dstOpts.IndexCB) } } srcInfo.PutObjReader = pReader copyObjectPart := objectAPI.CopyObjectPart // Copy source object to destination, if source and destination
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 17:44:56 GMT 2024 - 39K bytes - Viewed (0) -
cmd/object-handlers.go
if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } if dstOpts.IndexCB != nil { dstOpts.IndexCB = compressionIndexEncrypter(objEncKey, dstOpts.IndexCB) } } } srcInfo.PutObjReader = pReader srcInfo.UserDefined, err = getCpObjMetadataFromHeader(ctx, r, srcInfo.UserDefined) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 20:15:54 GMT 2024 - 125.2K bytes - Viewed (0)