Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 659 for isobject (0.72 sec)

  1. cmd/metacache-entries.go

    func (e metaCacheEntry) isDir() bool {
    	return len(e.metadata) == 0 && strings.HasSuffix(e.name, slashSeparator)
    }
    
    // isObject returns if the entry is representing an object.
    func (e metaCacheEntry) isObject() bool {
    	return len(e.metadata) > 0
    }
    
    // isObjectDir returns if the entry is representing an object/
    func (e metaCacheEntry) isObjectDir() bool {
    	return len(e.metadata) > 0 && strings.HasSuffix(e.name, slashSeparator)
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:43:43 GMT 2024
    - 23.2K bytes
    - Viewed (0)
  2. cmd/metacache-stream.go

    	if !next.hasPrefix(prefix) {
    		return metaCacheEntriesSorted{}, io.EOF
    	}
    
    	if r.current.name != "" {
    		if (inclDeleted || !r.current.isLatestDeletemarker()) && r.current.hasPrefix(prefix) && (inclDirs || r.current.isObject()) {
    			res = append(res, r.current)
    		}
    		r.current.name = ""
    		r.current.metadata = nil
    	}
    
    	for n < 0 || len(res) < n {
    		if more, err := r.mr.ReadBool(); !more {
    			switch err {
    			case nil:
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 19.5K bytes
    - Viewed (0)
  3. cmd/metacache-set.go

    				continue
    			}
    			if !strings.HasPrefix(entry.name, o.Prefix) {
    				continue
    			}
    			if !o.Recursive && !entry.isInDir(o.Prefix, o.Separator) {
    				continue
    			}
    			if !o.InclDeleted && entry.isObject() && entry.isLatestDeletemarker() && !entry.isObjectDir() {
    				continue
    			}
    			if o.Lifecycle != nil || o.Replication.Config != nil {
    				if skipped := triggerExpiryAndRepl(ctx, *o, entry); skipped == true {
    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)
  4. cmd/erasure-server-pool-decom.go

    }
    
    func (p poolMeta) ResumeBucketObject(idx int) (bucket, object string) {
    	if p.Pools[idx].Decommission != nil {
    		bucket = p.Pools[idx].Decommission.Bucket
    		object = p.Pools[idx].Decommission.Object
    	}
    	return
    }
    
    func (p *poolMeta) TrackCurrentBucketObject(idx int, bucket string, object string) {
    	if p.Pools[idx].Decommission == nil {
    		// Decommission not in progress.
    		return
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 15:18:21 GMT 2024
    - 41.5K bytes
    - Viewed (1)
  5. cmd/object-handlers_test.go

    				// Read last byte of object
    				fmt.Sprintf("bytes=-%d", 1),
    				// Read all but first byte of object
    				"bytes=1-",
    				// Read first half of object
    				fmt.Sprintf("bytes=%d-%d", 0, objLen/2),
    				// Read last half of object
    				fmt.Sprintf("bytes=-%d", objLen/2),
    				// Read middle half of object
    				fmt.Sprintf("bytes=%d-%d", objLen/4, objLen*3/4),
    				// Read 100MiB of the object from the beginning
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 160K bytes
    - Viewed (0)
  6. cmd/object-handlers.go

    		// do an additional verification whether object exists when object is deletemarker and request
    		// is from replication
    		if opts.CheckDMReplicationReady {
    			topts := opts
    			topts.VersionID = ""
    			goi, gerr := getObjectInfo(ctx, bucket, object, topts)
    			if gerr == nil || goi.VersionID != "" { // object layer returned more info because object is deleted
    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)
  7. cmd/erasure-object.go

    	return online
    }
    
    // CopyObject - copy object source object to destination object.
    // if source object and destination object are same we only
    // update metadata.
    func (er erasureObjects) CopyObject(ctx context.Context, srcBucket, srcObject, dstBucket, dstObject string, srcInfo ObjectInfo, srcOpts, dstOpts ObjectOptions) (oi ObjectInfo, err error) {
    	if !dstOpts.NoAuditLog {
    		auditObjectErasureSet(ctx, dstObject, &er)
    	}
    
    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)
  8. cmd/object-multipart-handlers.go

    	if !globalTierConfigMgr.Empty() {
    		// Get appropriate object info to identify the remote object to delete
    		goiOpts := os.GetOpts()
    		if goi, gerr := objectAPI.GetObjectInfo(ctx, bucket, object, goiOpts); gerr == nil {
    			os.SetTransitionState(goi.TransitionedObject)
    		}
    	}
    
    	opts, err := completeMultipartOpts(ctx, r, bucket, object)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Mar 28 17:44:56 GMT 2024
    - 39K bytes
    - Viewed (0)
  9. cmd/object-api-datatypes.go

    	Versioning, ObjectLocking bool
    }
    
    // ObjectInfo - represents object metadata.
    type ObjectInfo struct {
    	// Name of the bucket.
    	Bucket string
    
    	// Name of the object.
    	Name string
    
    	// Date and time when the object was last modified.
    	ModTime time.Time
    
    	// Total object size.
    	Size int64
    
    	// Actual size is the real size of the object uploaded by client.
    	ActualSize *int64
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 20.8K bytes
    - Viewed (0)
  10. cmd/object-api-listobjects_test.go

    				VersionSuspended: globalBucketVersioningSys.PrefixSuspended(object.parentBucket, object.name),
    				UserDefined:      object.meta,
    			})
    		if err != nil {
    			t.Fatalf("%s : %s", instanceType, err)
    		}
    		obj, err := obj.DeleteObject(context.Background(), object.parentBucket, object.name, ObjectOptions{
    			Versioned:        globalBucketVersioningSys.PrefixEnabled(object.parentBucket, object.name),
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 11:07:40 GMT 2024
    - 73.1K bytes
    - Viewed (0)
Back to top