Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 80 of 541 for versionid (0.1 sec)

  1. cmd/erasure-healing_test.go

    	if err != nil {
    		t.Fatal(err)
    	}
    
    	if fileInfoPostHeal.NumVersions != 2 {
    		t.Fatalf("Expected versions 2, got %d", fileInfoPreHeal.NumVersions)
    	}
    
    	if objInfo.DeleteMarker {
    		if _, err = objLayer.DeleteObject(ctx, bucket, object, ObjectOptions{
    			Versioned: true,
    			VersionID: objInfo.VersionID,
    		}); err != nil {
    			t.Fatal(err)
    		}
    	}
    
    	setDisks(nil, nil, nil, nil)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 49K bytes
    - Viewed (0)
  2. cmd/mrf.go

    			if u.Object == "" {
    				healBucket(u.Bucket, scan)
    			} else {
    				if len(u.Versions) > 0 {
    					vers := len(u.Versions) / 16
    					if vers > 0 {
    						for i := 0; i < vers; i++ {
    							healObject(u.Bucket, u.Object, uuid.UUID(u.Versions[16*i:]).String(), scan)
    						}
    					}
    				} else {
    					healObject(u.Bucket, u.Object, u.VersionID, scan)
    				}
    			}
    
    			wait()
    		}
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:26:05 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  3. docs/debugging/xl-meta/main.go

    	}
    	if x.metaVer > xlMetaVersion {
    		return x, buf, fmt.Errorf("decodeXLHeaders: Unknown xl meta version %d", x.metaVer)
    	}
    	x.versions, buf, err = msgp.ReadIntBytes(buf)
    	if err != nil {
    		return x, buf, err
    	}
    	if x.versions < 0 {
    		return x, buf, fmt.Errorf("decodeXLHeaders: Negative version count %d", x.versions)
    	}
    	return x, buf, nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 05 11:57:44 UTC 2024
    - 40.3K bytes
    - Viewed (0)
  4. cmd/warm-backend-azure.go

    		AccessTier:  az.tier(), // set tier if specified
    		Metadata:    azMeta,
    	})
    	if err != nil {
    		return "", azureToObjectError(err, az.Bucket, az.getDest(object))
    	}
    	vid := ""
    	if resp.VersionID != nil {
    		vid = *resp.VersionID
    	}
    	return remoteVersionID(vid), nil
    }
    
    func (az *warmBackendAzure) Put(ctx context.Context, object string, r io.Reader, length int64) (remoteVersionID, error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 7K bytes
    - Viewed (0)
  5. cmd/bucket-replication-handlers.go

    			return
    		}
    		// fake a versioned delete - to ensure deny policies are not in place
    		err = c.RemoveObject(ctx, clnt.Bucket, obj, minio.RemoveObjectOptions{
    			VersionID: ui.VersionID,
    			Internal: minio.AdvancedRemoveOptions{
    				ReplicationDeleteMarker:  false,
    				ReplicationMTime:         time.Now(),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 23.3K bytes
    - Viewed (0)
  6. internal/bucket/lifecycle/lifecycle_test.go

    				DeleteMarker:     tc.isDelMarker,
    				IsLatest:         !tc.isNoncurrent,
    				SuccessorModTime: tc.objectSuccessorModTime,
    				VersionID:        tc.versionID,
    			}
    			opts.NumVersions = 1
    			if tc.hasManyVersions {
    				opts.NumVersions = 2 // at least one noncurrent version
    			}
    			if res := lc.Eval(opts); res.Action != tc.expectedAction {
    				t.Fatalf("Expected action: `%v`, got: `%v`", tc.expectedAction, res.Action)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 23 01:12:48 UTC 2024
    - 55.1K bytes
    - Viewed (0)
  7. cmd/storage-rest-client.go

    }
    
    // DeleteVersions - deletes list of specified versions if present
    func (client *storageRESTClient) DeleteVersions(ctx context.Context, volume string, versions []FileInfoVersions, opts DeleteOptions) (errs []error) {
    	if len(versions) == 0 {
    		return errs
    	}
    
    	values := make(url.Values)
    	values.Set(storageRESTVolume, volume)
    	values.Set(storageRESTTotalVersions, strconv.Itoa(len(versions)))
    
    	var buffer bytes.Buffer
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:07:21 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  8. internal/http/headers.go

    	SubnetAPIKey = "x-subnet-api-key"
    )
    
    // Common http query params S3 API
    const (
    	VersionID = "versionId"
    
    	PartNumber = "partNumber"
    
    	UploadID = "uploadId"
    )
    
    // http headers sent to webhook targets
    const (
    	// Reports the version of MinIO server
    	MinIOVersion             = "x-minio-version"
    	WebhookEventPayloadCount = "x-minio-webhook-payload-count"
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:31:56 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  9. cmd/warm-backend-minio.go

    //
    // This program is free software: you can redistribute it and/or modify
    // it under the terms of the GNU Affero General Public License as published by
    // the Free Software Foundation, either version 3 of the License, or
    // (at your option) any later version.
    //
    // This program is distributed in the hope that it will be useful
    // but WITHOUT ANY WARRANTY; without even the implied warranty of
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 4K bytes
    - Viewed (0)
  10. cmd/erasure-metadata-utils.go

    // be achieved and disks have too many inconsistent versions.
    func reduceCommonVersions(diskVersions [][]byte, writeQuorum int) (versions []byte) {
    	diskVersionsCount := make(map[uint64]int)
    	for _, versions := range diskVersions {
    		if len(versions) > 0 {
    			diskVersionsCount[binary.BigEndian.Uint64(versions)]++
    		}
    	}
    
    	var commonVersions uint64
    	max := 0
    	for versions, count := range diskVersionsCount {
    		if max < count {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 11.7K bytes
    - Viewed (0)
Back to top