Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 91 - 100 of 125 for copts (0.02 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. cmd/bucket-quota.go

    }
    
    var bucketStorageCache = cachevalue.New[DataUsageInfo]()
    
    // Init initialize bucket quota.
    func (sys *BucketQuotaSys) Init(objAPI ObjectLayer) {
    	bucketStorageCache.InitOnce(10*time.Second,
    		cachevalue.Opts{ReturnLastGood: true, NoWait: true},
    		func(ctx context.Context) (DataUsageInfo, error) {
    			if objAPI == nil {
    				return DataUsageInfo{}, errServerNotInitialized
    			}
    			ctx, done := context.WithTimeout(ctx, 2*time.Second)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 4.4K bytes
    - Click Count (0)
  2. internal/s3select/sql/record.go

    type Record interface {
    	Get(name string) (*Value, error)
    
    	// Set a value.
    	// Can return a different record type.
    	Set(name string, value *Value) (Record, error)
    	WriteCSV(writer io.Writer, opts WriteCSVOpts) error
    	WriteJSON(writer io.Writer) error
    
    	// Clone the record and if possible use the destination provided.
    	Clone(dst Record) Record
    	Reset()
    
    	// Returns underlying representation
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 3.4K bytes
    - Click Count (0)
  3. cmd/object-multipart-handlers.go

    	}
    
    	opts, err := putOptsFromReq(ctx, r, bucket, object, metadata)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	if r.Header.Get(xhttp.IfMatch) != "" {
    		opts.HasIfMatch = true
    	}
    	if opts.PreserveETag != "" ||
    		r.Header.Get(xhttp.IfMatch) != "" ||
    		r.Header.Get(xhttp.IfNoneMatch) != "" {
    		opts.CheckPrecondFn = func(oi ObjectInfo) bool {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 07 16:13:09 GMT 2025
    - 39.5K bytes
    - Click Count (1)
  4. apache-maven/src/main/appended-resources/licenses/EPL-1.0.txt

    such Contributor ("Commercial Contributor") hereby agrees to defend and indemnify
    every other Contributor ("Indemnified Contributor") against any losses, damages
    and costs (collectively "Losses") arising from claims, lawsuits and other
    legal actions brought by a third party against the Indemnified Contributor
    to the extent caused by the acts or omissions of such Commercial Contributor
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Mon Sep 17 05:50:12 GMT 2018
    - 11.1K bytes
    - Click Count (0)
  5. cmd/erasure-metadata-utils.go

    func readAllFileInfo(ctx context.Context, disks []StorageAPI, origbucket string, bucket, object, versionID string, readData, healing bool) ([]FileInfo, []error) {
    	metadataArray := make([]FileInfo, len(disks))
    
    	opts := ReadOptions{
    		ReadData: readData,
    		Healing:  healing,
    	}
    
    	g := errgroup.WithNErrs(len(disks))
    	// Read `xl.meta` in parallel across disks.
    	for index := range disks {
    		g.Go(func() (err error) {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 11.7K bytes
    - Click Count (0)
  6. cmd/warm-backend.go

    	PutWithMeta(ctx context.Context, object string, r io.Reader, length int64, meta map[string]string) (remoteVersionID, error)
    	Get(ctx context.Context, object string, rv remoteVersionID, opts WarmBackendGetOpts) (io.ReadCloser, error)
    	Remove(ctx context.Context, object string, rv remoteVersionID) error
    	InUse(ctx context.Context) (bool, error)
    }
    
    const probeObject = "probeobject"
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Oct 31 22:10:24 GMT 2024
    - 4K bytes
    - Click Count (0)
  7. migrator/migrator.go

    		).Row().Scan(&count)
    	})
    
    	return count > 0
    }
    
    // BuildIndexOptions build index options
    func (m Migrator) BuildIndexOptions(opts []schema.IndexOption, stmt *gorm.Statement) (results []interface{}) {
    	for _, opt := range opts {
    		str := stmt.Quote(opt.DBName)
    		if opt.Expression != "" {
    			str = opt.Expression
    		} else if opt.Length > 0 {
    			str += fmt.Sprintf("(%d)", opt.Length)
    		}
    
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Sun Oct 26 12:31:09 GMT 2025
    - 29.7K bytes
    - Click Count (0)
  8. cmd/post-policy_test.go

    	if err := newTestConfig(globalMinioDefaultRegion, obj); err != nil {
    		t.Fatalf("Initializing config.json failed")
    	}
    
    	// get random bucket name.
    	bucketName := getRandomBucketName()
    
    	var opts ObjectOptions
    	// Register the API end points with Erasure/FS object layer.
    	apiRouter := initTestAPIEndPoints(obj, []string{"PostPolicy"})
    
    	credentials := globalActiveCred
    
    	curTime := UTCNow()
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 30.6K bytes
    - Click Count (0)
  9. cmd/data-usage.go

    		// Prefix usage is empty
    		return map[string]uint64{}, nil
    	}
    
    	cache := dataUsageCache{}
    
    	prefixUsageCache.InitOnce(30*time.Second,
    		// No need to fail upon Update() error, fallback to old value.
    		cachevalue.Opts{ReturnLastGood: true, NoWait: true},
    		func(ctx context.Context) (map[string]uint64, error) {
    			m := make(map[string]uint64)
    			for _, pool := range z.serverPools {
    				for _, er := range pool.sets {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu May 09 00:51:34 GMT 2024
    - 5.6K bytes
    - Click Count (0)
  10. cmd/batch-rotate.go

    	if err != nil {
    		return err
    	}
    	ctx = lkctx.Context()
    	defer lock.Unlock(lkctx)
    
    	opts := ObjectOptions{
    		VersionID:        objInfo.VersionID,
    		Versioned:        versioned,
    		VersionSuspended: versionSuspended,
    		NoLock:           true,
    	}
    	obj, err := api.GetObjectInfo(ctx, r.Bucket, objInfo.Name, opts)
    	if err != nil {
    		return err
    	}
    	oi := obj.Clone()
    	var (
    		newKeyID      string
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 14.7K bytes
    - Click Count (0)
Back to Top