Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 212 for copts (0.04 sec)

  1. cmd/erasure-healing.go

    	if b > 0 && b == a {
    		opts.Error = fmt.Sprintf("unable to heal %d missing blocks on drives", b)
    	}
    
    	opts.Tags = map[string]string{
    		"healObject": auditObjectOp{
    			Name: opts.Object,
    			Pool: er.poolIndex + 1,
    			Set:  er.setIndex + 1,
    		}.String(),
    	}
    
    	auditLogInternal(ctx, opts)
    }
    
    // Heals an object by re-writing corrupt/missing erasure blocks.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Oct 02 17:50:41 UTC 2024
    - 34.4K bytes
    - Viewed (0)
  2. cmd/object-api-utils.go

    // not all run!).
    func NewGetObjectReader(rs *HTTPRangeSpec, oi ObjectInfo, opts ObjectOptions, h http.Header) (
    	fn ObjReaderFn, off, length int64, err error,
    ) {
    	if opts.CheckPrecondFn != nil && opts.CheckPrecondFn(oi) {
    		return nil, 0, 0, PreConditionFailed{}
    	}
    
    	if rs == nil && opts.PartNumber > 0 {
    		rs = partNumberToRangeSpec(oi, opts.PartNumber)
    	}
    
    	_, isEncrypted := crypto.IsEncrypted(oi.UserDefined)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Aug 08 15:29:58 UTC 2024
    - 37.1K bytes
    - Viewed (0)
  3. 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 Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Aug 31 18:25:48 UTC 2024
    - 39.2K bytes
    - Viewed (0)
  4. cmd/erasure-healing_test.go

    	data := bytes.Repeat([]byte("a"), 5*1024*1024)
    	var opts ObjectOptions
    
    	err = objLayer.MakeBucket(ctx, bucket, MakeBucketOptions{})
    	if err != nil {
    		t.Fatalf("Failed to make a bucket - %v", err)
    	}
    
    	// Create an object with multiple parts uploaded in decreasing
    	// part number.
    	res, err := objLayer.NewMultipartUpload(ctx, bucket, object, opts)
    	if err != nil {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 49K bytes
    - Viewed (0)
  5. .bazelrc

    build:windows --copt=/W0
    build:windows --host_copt=/W0
    
    # Suppress most C++ compiler warnings to reduce log size but allow
    # for specific warnings to still be present.
    build:linux --copt="-Wno-all"
    build:linux --copt="-Wno-extra"
    build:linux --copt="-Wno-deprecated"
    build:linux --copt="-Wno-deprecated-declarations"
    build:linux --copt="-Wno-ignored-attributes"
    build:linux --copt="-Wno-array-bounds"
    
    # Add unused-result as an error on Linux.
    Registered: Tue Oct 29 12:39:09 UTC 2024
    - Last Modified: Mon Oct 28 22:02:31 UTC 2024
    - 51.3K bytes
    - Viewed (0)
  6. cmd/notification.go

    		if report == nil || report.BucketStats == nil {
    			continue
    		}
    		for opts := range report.BucketStats {
    			d, ok := consolidatedReport.BucketStats[opts]
    			if !ok {
    				d = bandwidth.Details{
    					LimitInBytesPerSecond: report.BucketStats[opts].LimitInBytesPerSecond,
    				}
    			}
    			dt, ok := report.BucketStats[opts]
    			if ok {
    				d.CurrentBandwidthInBytesPerSecond += dt.CurrentBandwidthInBytesPerSecond
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 46.2K bytes
    - Viewed (0)
  7. cmd/object-api-options.go

    	opts, err = getDefaultOpts(hdr, false, metadata)
    	if err != nil {
    		return opts, err
    	}
    
    	opts.MTime = mtime
    	opts.ReplicationSourceLegalholdTimestamp = lholdtimestmp
    	opts.ReplicationSourceRetentionTimestamp = retaintimestmp
    	opts.ReplicationSourceTaggingTimestamp = taggingtimestmp
    	opts.PreserveETag = etag
    	opts.WantChecksum = wantCRC
    
    	return opts, nil
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Aug 21 21:13:59 UTC 2024
    - 14.4K bytes
    - Viewed (0)
  8. internal/event/target/nats_contrib_test.go

    	defer con.Close()
    }
    
    func TestNatsConnUserPass(t *testing.T) {
    	opts := natsserver.DefaultTestOptions
    	opts.Port = 14223
    	opts.Username = "testminio"
    	opts.Password = "miniotest"
    	s := natsserver.RunServer(&opts)
    	defer s.Shutdown()
    
    	clientConfig := &NATSArgs{
    		Enable: true,
    		Address: xnet.Host{
    			Name:      "localhost",
    			Port:      (xnet.Port(opts.Port)),
    			IsPortSet: true,
    		},
    		Subject:  "test",
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  9. cmd/metacache-walk.go

    		}
    		return nil
    	}
    
    	// Stream output.
    	return scanDir(opts.BaseDir)
    }
    
    func (p *xlStorageDiskIDCheck) WalkDir(ctx context.Context, opts WalkDirOptions, wr io.Writer) (err error) {
    	if err := p.checkID(opts.DiskID); err != nil {
    		return err
    	}
    	ctx, done, err := p.TrackDiskHealth(ctx, storageMetricWalkDir, opts.Bucket, opts.BaseDir)
    	if err != nil {
    		return err
    	}
    	defer done(0, &err)
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Jun 01 05:17:37 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  10. istioctl/pkg/xds/client.go

    				ServiceAccount: serviceAccount,
    				Namespace:      ns,
    				CloudrunAddr:   opts.IstiodAddr,
    			}.ToStruct(),
    			CertDir:            opts.CertDir,
    			InsecureSkipVerify: opts.InsecureSkipVerify,
    			XDSSAN:             opts.XDSSAN,
    			GrpcOpts:           grpcOpts,
    		},
    	}, nil)
    	if err != nil {
    		return nil, fmt.Errorf("could not dial: %w", err)
    	}
    	err = adscConn.Run()
    	if err != nil {
    Registered: Wed Oct 30 22:53:10 UTC 2024
    - Last Modified: Tue Dec 19 22:42:42 UTC 2023
    - 3.7K bytes
    - Viewed (0)
Back to top