Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 183 for dopts (0.05 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. cmd/utils.go

    func auditLogInternal(ctx context.Context, opts AuditLogOptions) {
    	if len(logger.AuditTargets()) == 0 {
    		return
    	}
    
    	entry := audit.NewEntry(globalDeploymentID())
    	entry.Trigger = opts.Event
    	entry.Event = opts.Event
    	entry.Error = opts.Error
    	entry.API.Name = opts.APIName
    	entry.API.Bucket = opts.Bucket
    	entry.API.Objects = []xaudit.ObjectVersion{{ObjectName: opts.Object, VersionID: opts.VersionID}}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Aug 13 22:22:04 UTC 2024
    - 31.9K bytes
    - Viewed (0)
  6. cmd/update.go

    		return errors.New("update already in progress")
    	}
    	defer updateInProgress.Store(0)
    
    	transport := getUpdateTransport(30 * time.Second)
    	opts := selfupdate.Options{
    		Hash:     crypto.SHA256,
    		Checksum: sha256Sum,
    	}
    
    	if err := opts.CheckPermissions(); err != nil {
    		return AdminError{
    			Code:       AdminUpdateApplyFailure,
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 18.7K bytes
    - Viewed (0)
  7. 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)
  8. cmd/warm-backend-gcs.go

    	// Calling ReadCompressed with true accomplishes that.
    	object := gcs.client.Bucket(gcs.Bucket).Object(gcs.getDest(key)).ReadCompressed(true)
    
    	r, err = object.NewRangeReader(ctx, opts.startOffset, opts.length)
    	if err != nil {
    		return nil, gcsToObjectError(err, gcs.Bucket, key)
    	}
    	return r, nil
    }
    
    func (gcs *warmBackendGCS) Remove(ctx context.Context, key string, rv remoteVersionID) error {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Jun 22 05:26:45 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  9. cmd/bucket-handlers.go

    		}
    
    		if !globalTierConfigMgr.Empty() {
    			oss[index] = newObjSweeper(bucket, object.ObjectName).WithVersion(opts.VersionID).WithVersioning(opts.Versioned, opts.VersionSuspended)
    			oss[index].SetTransitionState(goi.TransitionedObject)
    		}
    
    		// All deletes on directory objects needs to be for `nullVersionID`
    		if isDirObject(object.ObjectName) && object.VersionID == "" {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Sep 12 12:24:04 UTC 2024
    - 63.4K bytes
    - Viewed (0)
  10. tensorflow/c/c_api.h

    TF_CAPI_EXPORT extern void TF_DeleteImportGraphDefOptions(
        TF_ImportGraphDefOptions* opts);
    
    // Set the prefix to be prepended to the names of nodes in `graph_def` that will
    // be imported into `graph`. `prefix` is copied and has no lifetime
    // requirements.
    TF_CAPI_EXPORT extern void TF_ImportGraphDefOptionsSetPrefix(
        TF_ImportGraphDefOptions* opts, const char* prefix);
    
    // Set the execution device for nodes in `graph_def`.
    Registered: Tue Oct 29 12:39:09 UTC 2024
    - Last Modified: Thu Oct 26 21:08:15 UTC 2023
    - 82.3K bytes
    - Viewed (0)
Back to top