- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for removeObject (0.23 sec)
-
cmd/sts-handlers_test.go
if err = minioClient.RemoveObjectTagging(ctx, bucket, object, minio.RemoveObjectTaggingOptions{}); err != nil { c.Fatalf("user is unable to delete the object tags: %v", err) } if err = minioClient.RemoveObject(ctx, bucket, object, minio.RemoveObjectOptions{}); err != nil { c.Fatalf("user is unable to delete the object: %v", err) } } func (s *TestSuiteIAM) TestSTS(c *check) {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 18 19:09:19 GMT 2024 - 84.7K bytes - Viewed (0) -
cmd/bucket-replication-handlers.go
if sameTarget && bucket == clnt.Bucket { writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrBucketRemoteIdenticalToSource), r.URL) return } reader := bytes.NewReader(buf) // fake a PutObject and RemoveObject call to validate permissions c := &minio.Core{Client: clnt.Client} putOpts := minio.PutObjectOptions{ Internal: minio.AdvancedPutOptions{ SourceVersionID: mustGetUUID(),
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sat Oct 28 04:08:53 GMT 2023 - 23.2K bytes - Viewed (0) -
cmd/warm-backend-s3.go
} func (s3 *warmBackendS3) Remove(ctx context.Context, object string, rv remoteVersionID) error { ropts := minio.RemoveObjectOptions{} if rv != "" { ropts.VersionID = string(rv) } err := s3.client.RemoveObject(ctx, s3.Bucket, s3.getDest(object), ropts) return s3.ToObjectError(err, object) } func (s3 *warmBackendS3) InUse(ctx context.Context) (bool, error) {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 5.5K bytes - Viewed (0) -
cmd/sftp-server-driver.go
} for object := range clnt.ListObjects(cctx, bucket, opts) { if object.Err != nil { return } objectsCh <- object } }() // Call RemoveObjects API for err := range clnt.RemoveObjects(context.Background(), bucket, objectsCh, minio.RemoveObjectsOptions{}) { if err.Err != nil { return err.Err } } return err case "Remove":
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Apr 19 12:23:42 GMT 2024 - 12.9K bytes - Viewed (0) -
cmd/ftp-server-driver.go
Recursive: true, } for object := range clnt.ListObjects(cctx, bucket, opts) { if object.Err != nil { return } objectsCh <- object } }() // Call RemoveObjects API for err := range clnt.RemoveObjects(context.Background(), bucket, objectsCh, minio.RemoveObjectsOptions{}) { if err.Err != nil { return err.Err } } return nil } // DeleteFile implements ftpDriver
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Apr 19 12:23:42 GMT 2024 - 13.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/storage/AdminStorageAction.java
final MinioClient minioClient = createClient(fessConfig); final RemoveObjectArgs args = RemoveObjectArgs.builder().bucket(fessConfig.getStorageBucket()).object(objectName).build(); minioClient.removeObject(args); } catch (final Exception e) { throw new StorageException("Failed to delete " + objectName, e); } }
Java - Registered: Mon Apr 22 08:04:10 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 19.9K bytes - Viewed (0) -
cmd/admin-handlers-users_test.go
func (c *check) mustNotDelete(ctx context.Context, client *minio.Client, bucket string, vid string) { c.Helper() err := client.RemoveObject(ctx, bucket, "some-object", minio.RemoveObjectOptions{VersionID: vid}) if err == nil { c.Fatalf("user must not be allowed to delete") } err = client.RemoveObject(ctx, bucket, "some-object", minio.RemoveObjectOptions{}) if err != nil { c.Fatal("user must be able to create delete marker")
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Feb 12 16:36:16 GMT 2024 - 45.7K bytes - Viewed (0) -
cmd/bucket-replication.go
if !rinfo.VersionPurgeStatus.Empty() { rinfo.VersionPurgeStatus = Complete return } case isErrReadQuorum(serr), isErrWriteQuorum(serr): // destination has some quorum issues, perform removeObject() anyways // to complete the operation. default: if err != nil && minio.IsNetworkOrHostDown(err, true) && !globalBucketTargetSys.isOffline(tgt.EndpointURL()) {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sat Apr 20 09:05:54 GMT 2024 - 112K bytes - Viewed (1) -
cmd/batch-handlers.go
dmVersionID = srcObjInfo.VersionID } if r.Target.Type == BatchJobReplicateResourceS3 || r.Source.Type == BatchJobReplicateResourceS3 { dmVersionID = "" versionID = "" } return c.RemoveObject(ctx, tgtBucket, pathJoin(tgtPrefix, srcObject), miniogo.RemoveObjectOptions{ VersionID: versionID, Internal: miniogo.AdvancedRemoveOptions{ ReplicationDeleteMarker: dmVersionID != "",
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Apr 08 14:11:38 GMT 2024 - 55.2K bytes - Viewed (0) -
cmd/tier-sweeper.go
Versioned bool Suspended bool TransitionStatus string TransitionTier string TransitionVersionID string RemoteObject string } // newObjSweeper returns an objSweeper for a given bucket and object. // It initializes the versioning information using bucket name. func newObjSweeper(bucket, object string) *objSweeper {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 4.7K bytes - Viewed (0)