- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 144 for Subobject (0.2 sec)
-
cmd/erasure-object.go
return er.putObject(ctx, bucket, object, data, opts) } // putObject wrapper for erasureObjects PutObject func (er erasureObjects) putObject(ctx context.Context, bucket string, object string, r *PutObjReader, opts ObjectOptions) (objInfo ObjectInfo, err error) { if !opts.NoAuditLog { auditObjectErasureSet(ctx, object, &er) } data := r.Reader if opts.CheckPrecondFn != nil { if !opts.NoLock {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 78.6K bytes - Viewed (0) -
cmd/erasure-server-pool.go
defer lk.RUnlock(lkctx) } objInfo, _, err = z.getLatestObjectInfoWithIdx(ctx, bucket, object, opts) return objInfo, err } // PutObject - writes an object to least used erasure pool. func (z *erasureServerPools) PutObject(ctx context.Context, bucket string, object string, data *PutObjReader, opts ObjectOptions) (ObjectInfo, error) { // Validate put object input args.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 30 11:58:12 UTC 2024 - 82.5K bytes - Viewed (0) -
cmd/bucket-handlers_test.go
} func testRemoveBucketHandler(obj ObjectLayer, instanceType, bucketName string, apiRouter http.Handler, credentials auth.Credentials, t *testing.T, ) { _, err := obj.PutObject(GlobalContext, bucketName, "test-object", mustGetPutObjReader(t, bytes.NewReader([]byte{}), int64(0), "", "e3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855"), ObjectOptions{}) // if object upload fails stop the test.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:50:49 UTC 2024 - 39.8K bytes - Viewed (0) -
cmd/object-api-listobjects_test.go
{testBuckets[1], "unique/folder/1.txt", "content", nil, true}, } for _, object := range testObjects { md5Bytes := md5.Sum([]byte(object.content)) _, err = obj.PutObject(context.Background(), object.parentBucket, object.name, mustGetPutObjReader(t, bytes.NewBufferString(object.content), int64(len(object.content)), hex.EncodeToString(md5Bytes[:]), ""), ObjectOptions{
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 01 11:07:40 UTC 2024 - 73.1K bytes - Viewed (0) -
docs/distributed/README.md
If one or more drives are offline at the start of a PutObject or NewMultipartUpload operation the object will have additional data protection bits added automatically to provide additional safety for these objects. ### High availability
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 8.8K bytes - Viewed (0) -
cmd/perf-tests.go
defer wg.Done() for { t := time.Now() reader := newRandomReader(opts.objectSize) tmpObjName := pathJoin(objNamePrefix, fmt.Sprintf("%d/%d", i, objCountPerThread[i])) info, err := clnt.PutObject(uploadsCtx, opts.bucketName, tmpObjName, reader, int64(opts.objectSize), popts) if err != nil { if !contextCanceled(uploadsCtx) && !errors.Is(err, context.Canceled) { errOnce.Do(func() {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 11.8K bytes - Viewed (0) -
cmd/erasure-metadata-utils.go
} return metadataArray, g.Wait() } // shuffleDisksAndPartsMetadataByIndex this function should be always used by GetObjectNInfo() // and CompleteMultipartUpload code path, it is not meant to be used with PutObject, // NewMultipartUpload metadata shuffling. func shuffleDisksAndPartsMetadataByIndex(disks []StorageAPI, metaArr []FileInfo, fi FileInfo) (shuffledDisks []StorageAPI, shuffledPartsMetadata []FileInfo) {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 11.7K bytes - Viewed (0) -
cmd/erasure-server-pool-rebalance.go
} return err } hr, err := hash.NewReader(ctx, gr, oi.Size, "", "", actualSize) if err != nil { return fmt.Errorf("rebalanceObject: hash.NewReader() %w", err) } _, err = z.PutObject(ctx, bucket, oi.Name, NewPutObjReader(hr), ObjectOptions{ DataMovement: true, VersionID: oi.VersionID, MTime: oi.ModTime, UserDefined: oi.UserDefined,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 03 15:45:54 UTC 2024 - 27.3K bytes - Viewed (0) -
pkg/kube/inject/inject.go
return err } var updated []byte if err == nil { outObject, err := IntoObject(injector, sidecarTemplate, valuesConfig, revision, meshconfig, obj, warningHandler) // nolint: vetshadow if err != nil { return err } if updated, err = yaml.Marshal(outObject); err != nil { return err } } else { updated = raw // unchanged }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 20:35:11 UTC 2024 - 28.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/storage/AdminStorageAction.java
.stream(in, uploadFile.getFileSize(), -1).contentType("application/octet-stream").build(); minioClient.putObject(args); } catch (final Exception e) { throw new StorageException("Failed to upload " + objectName, e); } }
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 19.9K bytes - Viewed (0)