Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 54 of 54 for getObjects (0.04 sec)

  1. cmd/erasure-object.go

    func (er erasureObjects) GetObjectNInfo(ctx context.Context, bucket, object string, rs *HTTPRangeSpec, h http.Header, opts ObjectOptions) (gr *GetObjectReader, err error) {
    	if !opts.NoAuditLog {
    		auditObjectErasureSet(ctx, "GetObject", object, &er)
    	}
    
    	var unlockOnDefer bool
    	nsUnlocker := func() {}
    	defer func() {
    		if unlockOnDefer {
    			nsUnlocker()
    		}
    	}()
    
    	// Acquire lock
    	if !opts.NoLock {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 80.4K bytes
    - Viewed (0)
  2. cmd/erasure-server-pool.go

    // is present in-case there were duplicate writes to both pools, this function also returns the
    // additional index where the latest object exists, that is used to start the GetObject stream.
    func (z *erasureServerPools) getLatestObjectInfoWithIdx(ctx context.Context, bucket, object string, opts ObjectOptions) (ObjectInfo, int, error) {
    	object = encodeDirObject(object)
    	results := make([]struct {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 89.1K bytes
    - Viewed (0)
  3. cmd/bucket-replication.go

    	}
    	// Make sure to match ETag when proxying.
    	if err = gopts.SetMatchETag(oi.ETag); err != nil {
    		return nil, proxy, err
    	}
    	c := minio.Core{Client: tgt.Client}
    	obj, _, h, err := c.GetObject(ctx, tgt.Bucket, object, gopts)
    	if err != nil {
    		return nil, proxy, err
    	}
    	closeReader := func() { obj.Close() }
    	reader, err := fn(obj, h, closeReader)
    	if err != nil {
    		return nil, proxy, err
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 118K bytes
    - Viewed (0)
  4. cmd/object-handlers.go

    // This implementation of the GET operation retrieves object. To use GET,
    // you must have READ access to the object.
    func (api objectAPIHandlers) GetObjectHandler(w http.ResponseWriter, r *http.Request) {
    	ctx := newContext(r, w, "GetObject")
    
    	defer logger.AuditLog(ctx, w, r, mustGetClaimsFromToken(r))
    
    	objectAPI := api.ObjectAPI()
    	if objectAPI == nil {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrServerNotInitialized), r.URL)
    		return
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 120.6K bytes
    - Viewed (0)
Back to top