Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 253 for opus (0.03 sec)

  1. cmd/object-handlers-common.go

    			writeHeaders()
    			writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrPreconditionFailed), r.URL)
    			return true
    		}
    	}
    
    	etagMatch := opts.PreserveETag != "" && isETagEqual(objInfo.ETag, opts.PreserveETag)
    	vidMatch := opts.VersionID != "" && opts.VersionID == objInfo.VersionID
    	if etagMatch && vidMatch {
    		writeHeaders()
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrPreconditionFailed), r.URL)
    		return true
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 03 06:33:53 UTC 2024
    - 15.3K bytes
    - Viewed (0)
  2. cmd/object-api-multipart_test.go

    func testObjectNewMultipartUpload(obj ObjectLayer, instanceType string, t TestErrHandler) {
    	bucket := "minio-bucket"
    	object := "minio-object"
    	opts := ObjectOptions{}
    	_, err := obj.NewMultipartUpload(context.Background(), "--", object, opts)
    	if err == nil {
    		t.Fatalf("%s: Expected to fail since bucket name is invalid.", instanceType)
    	}
    
    	errMsg := "Bucket not found: minio-bucket"
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 09:42:21 UTC 2024
    - 88.8K bytes
    - Viewed (0)
  3. cmd/healthcheck-handler.go

    		return
    	}
    
    	ctx, cancel := context.WithTimeout(ctx, globalAPIConfig.getClusterDeadline())
    	defer cancel()
    
    	opts := HealthOptions{
    		Maintenance:    r.Form.Get("maintenance") == "true",
    		DeploymentType: r.Form.Get("deployment-type"),
    	}
    	result := objLayer.Health(ctx, opts)
    	w.Header().Set(xhttp.MinIOWriteQuorum, strconv.Itoa(result.WriteQuorum))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 26 07:44:34 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  4. cmd/storage-interface.go

    	WalkDir(ctx context.Context, opts WalkDirOptions, wr io.Writer) error
    
    	// Metadata operations
    	DeleteVersion(ctx context.Context, volume, path string, fi FileInfo, forceDelMarker bool, opts DeleteOptions) error
    	DeleteVersions(ctx context.Context, volume string, versions []FileInfoVersions, opts DeleteOptions) []error
    	DeleteBulk(ctx context.Context, volume string, paths ...string) error
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  5. cmd/dynamic-timeouts.go

    type dynamicTimeoutOpts struct {
    	timeout       time.Duration
    	minimum       time.Duration
    	retryInterval time.Duration
    }
    
    func newDynamicTimeoutWithOpts(opts dynamicTimeoutOpts) *dynamicTimeout {
    	dt := newDynamicTimeout(opts.timeout, opts.minimum)
    	dt.retryInterval = opts.retryInterval
    	return dt
    }
    
    // newDynamicTimeout returns a new dynamic timeout initialized with timeout value
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Aug 19 23:21:05 UTC 2022
    - 4.5K bytes
    - Viewed (0)
  6. cmd/object-multipart-handlers.go

    				idxCb = compressionIndexEncrypter(objectEncryptionKey, idxCb)
    			}
    			opts.EncryptFn = metadataEncrypter(objectEncryptionKey)
    		}
    	}
    	opts.IndexCB = idxCb
    
    	opts.ReplicationRequest = sourceReplReq
    	putObjectPart := objectAPI.PutObjectPart
    
    	partInfo, err := putObjectPart(ctx, bucket, object, uploadID, partID, pReader, opts)
    	if err != nil {
    		// Verify if the underlying error is signature mismatch.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Aug 31 18:25:48 UTC 2024
    - 39.2K bytes
    - Viewed (0)
  7. internal/grid/benchmark_test.go

    					n += got
    				}
    				atomic.AddInt64(&ops, int64(n))
    				atomic.AddInt64(&lat, latency)
    			})
    			spent := time.Since(t)
    			if spent > 0 && n > 0 {
    				// Since we are benchmarking n parallel servers we need to multiply by n.
    				// This will give an estimate of the total ops/s.
    				latency := float64(atomic.LoadInt64(&lat)) / float64(time.Millisecond)
    				b.ReportMetric(float64(n)*float64(ops)/spent.Seconds(), "vops/s")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  8. cmd/encryption-v1_test.go

    	for i, test := range getDefaultOptsTests {
    		opts, err := getDefaultOpts(test.headers, test.copySource, test.metadata)
    		if test.err != err {
    			t.Errorf("Case %d: expected err: %v , actual err: %v", i, test.err, err)
    		}
    		if err == nil {
    			if opts.ServerSideEncryption == nil && test.encryptionType != "" {
    				t.Errorf("Case %d: expected opts to be of %v encryption type", i, test.encryptionType)
    			}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Sep 24 04:17:08 UTC 2022
    - 19.9K bytes
    - Viewed (0)
  9. docs/debugging/s3-check-md5/main.go

    				continue
    			}
    
    			var partsMD5Sum [][]byte
    			var failedMD5 bool
    			for p := 1; p <= parts; p++ {
    				opts := minio.GetObjectOptions{
    					VersionID:  object.VersionID,
    					PartNumber: p,
    				}
    				obj, err := s3Client.GetObject(context.Background(), bucket, object.Key, opts)
    				if err != nil {
    					log.Println("FAILED: GET", objFullPath(object), "=>", err)
    					failedMD5 = true
    					break
    				}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Feb 17 01:15:57 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  10. internal/cachevalue/cache_test.go

    	select {
    	case <-sl.C:
    	case <-ctx.Done():
    		return ctx.Err()
    	}
    
    	return nil
    }
    
    func TestCacheCtx(t *testing.T) {
    	cache := New[time.Time]()
    	t.Parallel()
    	cache.InitOnce(2*time.Second, Opts{},
    		func(ctx context.Context) (time.Time, error) {
    			return time.Now(), slowCaller(ctx)
    		},
    	)
    
    	ctx, cancel := context.WithCancel(context.Background())
    	cancel() // cancel context to test.
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 09 00:51:34 UTC 2024
    - 2.7K bytes
    - Viewed (0)
Back to top