Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 253 for opus (0.03 sec)

  1. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  2. internal/bucket/replication/rule_test.go

    package replication
    
    import (
    	"bytes"
    	"fmt"
    	"testing"
    )
    
    func TestMetadataReplicate(t *testing.T) {
    	testCases := []struct {
    		inputConfig    string
    		opts           ObjectOpts
    		expectedResult bool
    	}{
    		// case 1 - rule with replica modification enabled; not a replica
    		{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 4.6K bytes
    - Viewed (0)
  3. cmd/config-common.go

    )
    
    var errConfigNotFound = errors.New("config file not found")
    
    func readConfigWithMetadata(ctx context.Context, store objectIO, configFile string, opts ObjectOptions) ([]byte, ObjectInfo, error) {
    	r, err := store.GetObjectNInfo(ctx, minioMetaBucket, configFile, nil, http.Header{}, opts)
    	if err != nil {
    		if isErrObjectNotFound(err) {
    			return nil, ObjectInfo{}, errConfigNotFound
    		}
    
    		return nil, ObjectInfo{}, err
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 18 17:00:54 UTC 2023
    - 3.1K bytes
    - Viewed (0)
  4. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  5. internal/logger/logrotate.go

    		return nil, fmt.Errorf("directory %v does not exist and could not be created: %w", opts.Directory, err)
    	}
    
    	if opts.FileNameFunc == nil {
    		opts.FileNameFunc = defaultFilenameFunc
    	}
    
    	pr, pw := xioutil.WaitPipe()
    
    	w := &Writer{
    		opts: opts,
    		pw:   pw,
    		pr:   pr,
    	}
    
    	if w.f == nil {
    		if err := w.rotate(); err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  6. docs/sts/custom-token-identity.go

    	// The credentials package in minio-go provides an interface to call the
    	// AssumeRoleWithCustomToken STS API.
    
    	var opts []cr.CustomTokenOpt
    	if expiryDuration != 0 {
    		opts = append(opts, cr.CustomTokenValidityOpt(expiryDuration))
    	}
    
    	// Initialize
    	li, err := cr.NewCustomTokenCredentials(stsEndpoint, token, roleArn, opts...)
    	if err != nil {
    		log.Fatalf("Error initializing CustomToken Identity: %v", err)
    	}
    
    	v, err := li.Get()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 27 00:58:09 UTC 2022
    - 3.4K bytes
    - Viewed (0)
  7. cmd/metrics-v3-cache.go

    	loadNodesUpDown := func(ctx context.Context) (v nodesOnline, err error) {
    		v.Online, v.Offline = globalNotificationSys.GetPeerOnlineCount()
    		return
    	}
    	return cachevalue.NewFromFunc(1*time.Minute,
    		cachevalue.Opts{ReturnLastGood: true},
    		loadNodesUpDown)
    }
    
    type driveIOStatMetrics struct {
    	readsPerSec    float64
    	readsKBPerSec  float64
    	readsAwait     float64
    	writesPerSec   float64
    	writesKBPerSec float64
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 09 00:51:34 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  8. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 05 05:16:15 UTC 2024
    - 117.4K bytes
    - Viewed (0)
  9. cmd/object-api-common.go

    func newStorageAPI(endpoint Endpoint, opts storageOpts) (storage StorageAPI, err error) {
    	if endpoint.IsLocal {
    		storage, err := newXLStorage(endpoint, opts.cleanUp)
    		if err != nil {
    			return nil, err
    		}
    		return newXLStorageDiskIDCheck(storage, opts.healthCheck), nil
    	}
    
    	return newStorageRESTClient(endpoint, opts.healthCheck, globalGrid.Load())
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Nov 21 01:09:35 UTC 2023
    - 2.1K bytes
    - Viewed (0)
  10. cmd/object-api-interface.go

    	// Bucket operations.
    	MakeBucket(ctx context.Context, bucket string, opts MakeBucketOptions) error
    	GetBucketInfo(ctx context.Context, bucket string, opts BucketOptions) (bucketInfo BucketInfo, err error)
    	ListBuckets(ctx context.Context, opts BucketOptions) (buckets []BucketInfo, err error)
    	DeleteBucket(ctx context.Context, bucket string, opts DeleteBucketOptions) error
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 22 21:57:20 UTC 2024
    - 17.3K bytes
    - Viewed (0)
Back to top