Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 148 for dopts (0.05 sec)

  1. cmd/object-api-utils.go

    				}
    				oi.Size = decLength
    			}
    			// Decompression reader.
    			var dopts []s2.ReaderOption
    			if off > 0 || decOff > 0 {
    				// We are not starting at the beginning, so ignore stream identifiers.
    				dopts = append(dopts, s2.ReaderIgnoreStreamIdentifier())
    			}
    			s2Reader := s2.NewReader(inputReader, dopts...)
    			// Apply the skipLen and limit on the decompressed stream.
    			if decOff > 0 {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Aug 08 15:29:58 UTC 2024
    - 37.1K bytes
    - Viewed (0)
  2. cmd/bucket-replication.go

    			TargetArn: opts.arn,
    		})
    	if len(tgtArns) != 1 {
    		replLogIf(ctx, fmt.Errorf("replication resync failed for %s - arn specified %s is missing in the replication config", opts.bucket, opts.arn))
    		return
    	}
    	tgt := globalBucketTargetSys.GetRemoteTargetClient(opts.bucket, opts.arn)
    	if tgt == nil {
    		replLogIf(ctx, fmt.Errorf("replication resync failed for %s - target could not be created for arn %s", opts.bucket, opts.arn))
    		return
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
  3. cmd/warm-backend-s3.go

    }
    
    func (s3 *warmBackendS3) Get(ctx context.Context, object string, rv remoteVersionID, opts WarmBackendGetOpts) (io.ReadCloser, error) {
    	gopts := minio.GetObjectOptions{}
    
    	if rv != "" {
    		gopts.VersionID = string(rv)
    	}
    	if opts.startOffset >= 0 && opts.length > 0 {
    		if err := gopts.SetRange(opts.startOffset, opts.startOffset+opts.length-1); err != nil {
    			return nil, s3.ToObjectError(err, object)
    		}
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sun Apr 21 11:43:18 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  4. cmd/perf-tests.go

    	downloadsCtx, downloadsCancel := context.WithTimeout(ctx, opts.duration)
    	defer downloadsCancel()
    
    	gopts := minio.GetObjectOptions{}
    	gopts.Set(globalObjectPerfUserMetadata, "true") // Bypass S3 API freeze
    
    	var downloadTimes madmin.TimeDurations
    	var downloadTTFB madmin.TimeDurations
    	wg.Add(opts.concurrency)
    
    	c := minio.Core{Client: clnt}
    	for i := 0; i < opts.concurrency; i++ {
    		go func(i int) {
    			defer wg.Done()
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  5. internal/config/heal/heal.go

    func (opts Config) GetWorkers() int {
    	configMutex.RLock()
    	defer configMutex.RUnlock()
    	return opts.DriveWorkers
    }
    
    // Update updates opts with nopts
    func (opts *Config) Update(nopts Config) {
    	configMutex.Lock()
    	defer configMutex.Unlock()
    
    	opts.Bitrot = nopts.Bitrot
    	opts.IOCount = nopts.IOCount
    	opts.Sleep = nopts.Sleep
    	opts.DriveWorkers = nopts.DriveWorkers
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  6. cmd/object-handlers.go

    		}
    
    		return nil
    	}
    
    	var opts untarOptions
    	opts.ignoreDirs = strings.EqualFold(r.Header.Get(xhttp.MinIOSnowballIgnoreDirs), "true")
    	opts.ignoreErrs = strings.EqualFold(r.Header.Get(xhttp.MinIOSnowballIgnoreErrors), "true")
    	opts.prefixAll = r.Header.Get(xhttp.MinIOSnowballPrefix)
    	if opts.prefixAll != "" {
    		opts.prefixAll = trimLeadingSlash(pathJoin(opts.prefixAll, slashSeparator))
    	}
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Oct 05 05:16:15 UTC 2024
    - 117.4K bytes
    - Viewed (0)
  7. internal/config/batch/batch.go

    		ReplicationWorkersWait: opts.ReplicationWorkersWait,
    		KeyRotationWorkersWait: opts.KeyRotationWorkersWait,
    		ExpirationWorkersWait:  opts.ExpirationWorkersWait,
    	}
    }
    
    // Update updates opts with nopts
    func (opts *Config) Update(nopts Config) {
    	configMu.Lock()
    	defer configMu.Unlock()
    
    	opts.ReplicationWorkersWait = nopts.ReplicationWorkersWait
    	opts.KeyRotationWorkersWait = nopts.KeyRotationWorkersWait
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  8. cmd/speedtest.go

    				return
    			default:
    			}
    
    			sopts := speedTestOpts{
    				objectSize:      opts.objectSize,
    				concurrency:     concurrency,
    				duration:        opts.duration,
    				storageClass:    opts.storageClass,
    				bucketName:      opts.bucketName,
    				enableSha256:    opts.enableSha256,
    				enableMultipart: opts.enableMultipart,
    				creds:           opts.creds,
    			}
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon May 06 09:45:10 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  9. cmd/post-policy-fan-out.go

    			for k, v := range req.UserMetadata {
    				userDefined[k] = v
    			}
    			userDefined[xhttp.AmzObjectTagging] = s3utils.TagEncode(req.UserTags)
    
    			if opts.Kind != nil {
    				encrd, objectEncryptionKey, err := newEncryptReader(ctx, hr, opts.Kind, opts.KeyID, opts.Key, bucket, req.Key, userDefined, opts.KmsCtx)
    				if err != nil {
    					errs[idx] = err
    					return
    				}
    
    				// do not try to verify encrypted content/
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  10. 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 {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Oct 18 15:32:09 UTC 2024
    - 62.2K bytes
    - Viewed (0)
Back to top