Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for vnopts (0.26 sec)

  1. cmd/erasure-server-pool.go

    		return ObjectInfo{}, err
    	}
    	ctx = lkctx.Context()
    	defer lk.Unlock(lkctx)
    
    	if opts.DeletePrefix {
    		return ObjectInfo{}, z.deletePrefix(ctx, bucket, object)
    	}
    
    	gopts := opts
    	gopts.NoLock = true
    
    	pinfo, noReadQuorumPools, err := z.getPoolInfoExistingWithOpts(ctx, bucket, object, gopts)
    	if err != nil {
    		if _, ok := err.(InsufficientReadQuorum); ok {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (0)
  2. cmd/erasure-object.go

    		if err != nil {
    			return ObjectInfo{}, err
    		}
    		if dsc.ReplicateAny() {
    			opts.SetDeleteReplicationState(dsc, opts.VersionID)
    			goi.replicationDecision = opts.DeleteReplication.ReplicateDecisionStr
    		}
    	}
    
    	if opts.EvalRetentionBypassFn != nil {
    		if err := opts.EvalRetentionBypassFn(goi, gerr); err != nil {
    			return ObjectInfo{}, err
    		}
    	}
    
    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)
  3. cmd/iam.go

    	}
    	if len(opts.secretKey) > 0 && len(opts.accessKey) == 0 {
    		return auth.Credentials{}, time.Time{}, auth.ErrNoAccessKeyWithSecretKey
    	}
    
    	var policyBuf []byte
    	if opts.sessionPolicy != nil {
    		err := opts.sessionPolicy.Validate()
    		if err != nil {
    			return auth.Credentials{}, time.Time{}, err
    		}
    		policyBuf, err = json.Marshal(opts.sessionPolicy)
    		if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 21:28:16 GMT 2024
    - 71.1K bytes
    - Viewed (1)
  4. cmd/iam-store.go

    			return updatedAt, auth.ErrInvalidSecretKeyLength
    		}
    		cr.SecretKey = opts.secretKey
    	}
    
    	if opts.name != "" {
    		cr.Name = opts.name
    	}
    
    	if opts.description != "" {
    		cr.Description = opts.description
    	}
    
    	if opts.expiration != nil {
    		expirationInUTC := opts.expiration.UTC()
    		if err := validateSvcExpirationInUTC(expirationInUTC); err != nil {
    			return updatedAt, err
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Apr 27 10:04:10 GMT 2024
    - 75.2K bytes
    - Viewed (2)
  5. cmd/xl-storage.go

    		defer metaDataPoolPut(buf)
    		if err != nil {
    			return err
    		}
    
    		return s.WriteAll(ctx, volume, pathJoin(path, xlStorageFormatFile), buf)
    	}
    
    	if opts.UndoWrite && opts.OldDataDir != "" {
    		return renameAll(pathJoin(filePath, opts.OldDataDir, xlStorageFormatFileBackup), pathJoin(filePath, xlStorageFormatFile), filePath)
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 84.7K bytes
    - Viewed (0)
  6. cmd/peer-rest-server.go

    		globalBucketTargetSys.UpdateAllTargets(bucketName, meta.bucketTargetConfig)
    	}
    
    	return
    }
    
    func (s *peerRESTServer) GetMetacacheListingHandler(opts *listPathOptions) (*metacache, *grid.RemoteErr) {
    	resp := localMetacacheMgr.getBucket(context.Background(), opts.Bucket).findCache(*opts)
    	return &resp, nil
    }
    
    func (s *peerRESTServer) UpdateMetacacheListingHandler(req *metacache) (*metacache, *grid.RemoteErr) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 51.8K bytes
    - Viewed (0)
  7. cmd/batch-handlers.go

    			return err
    		}
    		return r.copyWithMultipartfromSource(ctx, api, core, srcObjInfo, opts, partsCount)
    	}
    	gopts := miniogo.GetObjectOptions{
    		VersionID: srcObjInfo.VersionID,
    	}
    	if err := gopts.SetMatchETag(srcObjInfo.ETag); err != nil {
    		return err
    	}
    	rd, objInfo, _, err := core.GetObject(ctx, srcBucket, srcObject, gopts)
    	if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 55.2K bytes
    - Viewed (0)
  8. cmd/bucket-handlers.go

    		}
    
    		if !globalTierConfigMgr.Empty() {
    			oss[index] = newObjSweeper(bucket, object.ObjectName).WithVersion(opts.VersionID).WithVersioning(opts.Versioned, opts.VersionSuspended)
    			oss[index].SetTransitionState(goi.TransitionedObject)
    		}
    
    		// All deletes on directory objects needs to be for `nullVersionID`
    		if isDirObject(object.ObjectName) && object.VersionID == "" {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 16:27:27 GMT 2024
    - 61.6K bytes
    - Viewed (0)
  9. internal/bucket/lifecycle/lifecycle_test.go

    				t.Fatalf("Got unexpected error: %v", err)
    			}
    			opts := ObjectOpts{
    				Name:             tc.objectName,
    				UserTags:         tc.objectTags,
    				ModTime:          tc.objectModTime,
    				DeleteMarker:     tc.isDelMarker,
    				IsLatest:         !tc.isNoncurrent,
    				SuccessorModTime: tc.objectSuccessorModTime,
    				VersionID:        tc.versionID,
    			}
    			opts.NumVersions = 1
    			if tc.hasManyVersions {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:11:10 GMT 2024
    - 53.2K bytes
    - Viewed (0)
  10. cmd/admin-handlers-users.go

    			Type: madmin.SRIAMItemSvcAcc,
    			SvcAccChange: &madmin.SRSvcAccChange{
    				Update: &madmin.SRSvcAccUpdate{
    					AccessKey:     accessKey,
    					SecretKey:     opts.secretKey,
    					Status:        opts.status,
    					Name:          opts.name,
    					Description:   opts.description,
    					SessionPolicy: updateReq.NewPolicy,
    					Expiration:    updateReq.NewExpiration,
    				},
    			},
    			UpdatedAt: updatedAt,
    		}))
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 12:41:13 GMT 2024
    - 77.5K bytes
    - Viewed (0)
Back to top