Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 317 for opts (0.04 sec)

  1. 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)
  2. cmd/object_api_suite_test.go

    	}
    
    	var bytesBuffer1 bytes.Buffer
    	var opts ObjectOptions
    	_, err = obj.PutObject(context.Background(), "bucket", "object", mustGetPutObjReader(t, readerEOF, length, "", ""), opts)
    	if err != nil {
    		t.Fatalf("%s: <ERROR> %s", instanceType, err)
    	}
    	err = GetObject(context.Background(), obj, "bucket", "object", 0, length, &bytesBuffer1, "", opts)
    	if err != nil {
    		t.Fatalf("%s: <ERROR> %s", instanceType, err)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 02 15:13:05 UTC 2024
    - 33.3K bytes
    - Viewed (0)
  3. cmd/naughty-disk_test.go

    func (d *naughtyDisk) UpdateMetadata(ctx context.Context, volume, path string, fi FileInfo, opts UpdateMetadataOpts) (err error) {
    	if err := d.calcError(); err != nil {
    		return err
    	}
    	return d.disk.UpdateMetadata(ctx, volume, path, fi, opts)
    }
    
    func (d *naughtyDisk) DeleteVersion(ctx context.Context, volume, path string, fi FileInfo, forceDelMarker bool, opts DeleteOptions) (err error) {
    	if err := d.calcError(); err != nil {
    		return err
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  4. tensorflow/c/eager/c_api_debug_test.cc

    #include "tensorflow/core/platform/test.h"
    
    TEST(CApiDebug, ScalarCPU) {
      TF_Status* status = TF_NewStatus();
      TFE_ContextOptions* opts = TFE_NewContextOptions();
      TFE_Context* ctx = TFE_NewContext(opts, status);
      CHECK_EQ(TF_OK, TF_GetCode(status)) << TF_Message(status);
      TFE_DeleteContextOptions(opts);
    
      TFE_TensorHandle* h = TestScalarTensorHandle(ctx, 1.0f);
      TFE_TensorDebugInfo* debug_info = TFE_TensorHandleTensorDebugInfo(h, status);
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Mon Apr 06 22:10:09 UTC 2020
    - 2.3K bytes
    - Viewed (0)
  5. cmd/background-heal-ops.go

    			case nopHeal:
    				err = errSkipFile
    			case SlashSeparator:
    				res, err = healDiskFormat(ctx, objAPI, task.opts)
    			default:
    				if task.object == "" {
    					res, err = objAPI.HealBucket(ctx, task.bucket, task.opts)
    				} else {
    					res, err = objAPI.HealObject(ctx, task.bucket, task.object, task.versionID, task.opts)
    				}
    			}
    
    			if task.respCh != nil {
    				task.respCh <- healResult{result: res, err: err}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. cmd/peer-s3-client.go

    	ListBuckets(ctx context.Context, opts BucketOptions) ([]BucketInfo, error)
    	HealBucket(ctx context.Context, bucket string, opts madmin.HealOpts) (madmin.HealResultItem, error)
    	GetBucketInfo(ctx context.Context, bucket string, opts BucketOptions) (BucketInfo, error)
    	MakeBucket(ctx context.Context, bucket string, opts MakeBucketOptions) error
    	DeleteBucket(ctx context.Context, bucket string, opts DeleteBucketOptions) error
    
    	GetHost() string
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:26:05 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  9. tensorflow/c/c_api_test.cc

    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Sat Oct 12 16:27:48 UTC 2024
    - 97K bytes
    - Viewed (0)
  10. tensorflow/c/c_api.cc

                                                 const char* oper_name, int index) {
      opts->tensor_id_data.push_back(oper_name);
      const string& oper_name_str = opts->tensor_id_data.back();
      opts->opts.return_tensors.emplace_back(oper_name_str, index);
    }
    
    int TF_ImportGraphDefOptionsNumReturnOutputs(
        const TF_ImportGraphDefOptions* opts) {
      return opts->opts.return_tensors.size();
    }
    
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Sat Oct 12 16:27:48 UTC 2024
    - 102.3K bytes
    - Viewed (0)
Back to top