Search Options

Results per page
Sort
Preferred Languages
Advance

Results 111 - 120 of 212 for copts (0.04 sec)

  1. cmd/os_windows.go

    			// filtering requested to return by caller.
    			return nil
    		}
    	}
    
    	return nil
    }
    
    // Return N entries at the directory dirPath.
    func readDirWithOpts(dirPath string, opts readDirOpts) (entries []string, err error) {
    	// Ensure we don't pick up files as directories.
    	globAll := filepath.Clean(dirPath) + `\*`
    	globAllP, err := syscall.UTF16PtrFromString(globAll)
    	if err != nil {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Oct 18 18:08:15 UTC 2023
    - 5.1K bytes
    - Viewed (0)
  2. interfaces.go

    	RollbackTo(tx *DB, name string) error
    }
    
    // TxBeginner tx beginner
    type TxBeginner interface {
    	BeginTx(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error)
    }
    
    // ConnPoolBeginner conn pool beginner
    type ConnPoolBeginner interface {
    	BeginTx(ctx context.Context, opts *sql.TxOptions) (ConnPool, error)
    }
    
    // TxCommitter tx committer
    type TxCommitter interface {
    	Commit() error
    	Rollback() error
    }
    
    Registered: Sun Oct 27 09:35:08 UTC 2024
    - Last Modified: Sat Aug 19 13:33:31 UTC 2023
    - 2.2K bytes
    - Viewed (0)
  3. internal/kms/config.go

    			return nil, err
    		}
    
    		key, err := kms.ParseAPIKey(env.Get(EnvKMSAPIKey, ""))
    		if err != nil {
    			return nil, err
    		}
    
    		var rootCAs *x509.CertPool
    		if opts != nil && opts.CADir != "" {
    			rootCAs, err = certs.GetRootCAs(opts.CADir)
    			if err != nil {
    				return nil, err
    			}
    		}
    
    		client, err := kms.NewClient(&kms.Config{
    			Endpoints: endpoints,
    			APIKey:    key,
    			TLS: &tls.Config{
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Aug 15 11:46:39 UTC 2024
    - 14.2K bytes
    - Viewed (0)
  4. cmd/tier-sweeper.go

    // overwritten or deleted depending on bucket versioning status.
    func (os *objSweeper) GetOpts() ObjectOptions {
    	opts := ObjectOptions{
    		VersionID:        os.VersionID,
    		Versioned:        os.Versioned,
    		VersionSuspended: os.Suspended,
    	}
    	if os.Suspended && os.VersionID == "" {
    		opts.VersionID = nullVersionID
    	}
    	return opts
    }
    
    // SetTransitionState sets ILM transition related information from given info.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Apr 17 05:09:58 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  5. cmd/warm-backend-azure.go

    }
    
    func (az *warmBackendAzure) Get(ctx context.Context, object string, rv remoteVersionID, opts WarmBackendGetOpts) (r io.ReadCloser, err error) {
    	if opts.startOffset < 0 {
    		return nil, InvalidRange{}
    	}
    	resp, err := az.clnt.DownloadStream(ctx, az.Bucket, az.getDest(object), &azblob.DownloadStreamOptions{
    		Range: blob.HTTPRange{Offset: opts.startOffset, Count: opts.length},
    	})
    	if err != nil {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Aug 13 18:21:34 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  6. cmd/api-headers.go

    			w.Header().Set(k, v)
    		}
    	}
    
    	var start, rangeLen int64
    	totalObjectSize, err := objInfo.GetActualSize()
    	if err != nil {
    		return err
    	}
    
    	if rs == nil && opts.PartNumber > 0 {
    		rs = partNumberToRangeSpec(objInfo, opts.PartNumber)
    	}
    
    	// For providing ranged content
    	start, rangeLen, err = rs.GetOffsetLength(totalObjectSize)
    	if err != nil {
    		return err
    	}
    
    	// Set content length.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue May 28 04:44:00 UTC 2024
    - 7K bytes
    - Viewed (0)
  7. cmd/iam-etcd-store.go

    	return ies.saveIAMConfig(ctx, mp, getMappedPolicyPath(name, userType, isGroup), opts...)
    }
    
    func (ies *IAMEtcdStore) saveUserIdentity(ctx context.Context, name string, userType IAMUserType, u UserIdentity, opts ...options) error {
    	return ies.saveIAMConfig(ctx, u, getUserIdentityPath(name, userType), opts...)
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Aug 15 01:29:20 UTC 2024
    - 14K bytes
    - Viewed (0)
  8. cmd/xl-storage-format-utils.go

    				Deleted:   true,
    				IsLatest:  true,
    				ModTime:   timeSentinel1970,
    			}, nil
    		}
    		inData = xlMeta.data
    		fi, err = xlMeta.ToFileInfo(volume, path, versionID, opts.InclFreeVersions, true)
    	}
    	if !opts.Data || err != nil {
    		return fi, err
    	}
    	versionID = fi.VersionID
    	if versionID == "" {
    		versionID = nullVersionID
    	}
    
    	fi.Data = inData.find(versionID)
    	if len(fi.Data) == 0 {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Aug 08 15:29:58 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  9. gorm.go

    }
    
    // Open initialize db session based on dialector
    func Open(dialector Dialector, opts ...Option) (db *DB, err error) {
    	config := &Config{}
    
    	sort.Slice(opts, func(i, j int) bool {
    		_, isConfig := opts[i].(*Config)
    		_, isConfig2 := opts[j].(*Config)
    		return isConfig && !isConfig2
    	})
    
    	for _, opt := range opts {
    		if opt != nil {
    			if applyErr := opt.Apply(config); applyErr != nil {
    Registered: Sun Oct 27 09:35:08 UTC 2024
    - Last Modified: Wed Oct 09 11:29:48 UTC 2024
    - 12.1K bytes
    - Viewed (0)
  10. cmd/ftp-server-driver.go

    	// Send object names that are needed to be removed to objectsCh
    	go func() {
    		defer xioutil.SafeClose(objectsCh)
    		opts := minio.ListObjectsOptions{
    			Prefix:    prefix,
    			Recursive: true,
    		}
    		for object := range clnt.ListObjects(cctx, bucket, opts) {
    			if object.Err != nil {
    				return
    			}
    			objectsCh <- object
    		}
    	}()
    
    	// Call RemoveObjects API
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 14K bytes
    - Viewed (0)
Back to top