Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 131 for uploadIds (0.06 sec)

  1. docs/select/README.md

    ## Enabling Parquet Format
    
    Parquet is DISABLED by default since hostile crafted input can easily crash the server.
    
    If you are in a controlled environment where it is safe to assume no hostile content can be uploaded to your cluster you can safely enable Parquet.
    To enable Parquet set the environment variable `MINIO_API_SELECT_PARQUET=on`.
    
    ## Example using Python API
    
    ### 1. Prerequisites
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 6.6K bytes
    - Viewed (0)
  2. cmd/global-heal.go

    				}
    
    				send(result)
    				return
    			}
    
    			var versionNotFound int
    			for _, version := range fivs.Versions {
    				// Ignore healing a version if:
    				// - It is uploaded after the drive healing is started
    				// - An object that is already expired by ILM rule.
    				if !started.IsZero() && version.ModTime.After(started) || filterLifecycle(bucket, version.Name, version) {
    					versionNotFound++
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Apr 04 13:49:12 UTC 2025
    - 16.2K bytes
    - Viewed (0)
  3. cmd/bucket-replication.go

    	opts.Internal.SourceMTime = time.Time{} // this value is saved properly in CompleteMultipartUpload()
    	var uploadID string
    	attempts := 1
    	for attempts <= 3 {
    		nctx, cancel := context.WithTimeout(ctx, time.Minute)
    		uploadID, err = c.NewMultipartUpload(nctx, bucket, object, opts)
    		cancel()
    		if err == nil {
    			break
    		}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 118K bytes
    - Viewed (0)
  4. cmd/notification.go

    // given uploadID from cache
    func (sys *NotificationSys) DeleteUploadID(ctx context.Context, uploadID string) {
    	ng := WithNPeers(len(sys.peerClients))
    	for idx, client := range sys.peerClients {
    		if client == nil {
    			continue
    		}
    		client := client
    		ng.Go(ctx, func() error {
    			return client.DeleteUploadID(ctx, uploadID)
    		}, idx, *client.host)
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 45.9K bytes
    - Viewed (0)
  5. cmd/peer-rest-server.go

    	}
    
    	pools, ok := objAPI.(*erasureServerPools)
    	if !ok {
    		return
    	}
    
    	// No need to return errors, this is not a highly strict operation.
    	uploadID := mss.Get(peerRESTUploadID)
    	if uploadID != "" {
    		pools.ClearUploadID(uploadID)
    	}
    
    	return
    }
    
    func (s *peerRESTServer) StopRebalanceHandler(mss *grid.MSS) (np grid.NoPayload, nerr *grid.RemoteErr) {
    	objAPI := newObjectLayerFn()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 53.4K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/app/web/api/admin/dict/stemmeroverride/ApiAdminDictStemmeroverrideAction.java

            });
            return asJson(new ApiResult.ApiUpdateResponse().id(String.valueOf(id)).created(false).status(ApiResult.Status.OK).result());
        }
    
        /**
         * Uploads stemmer override dictionary file.
         *
         * @param dictId the dictionary ID
         * @param form the upload form containing the dictionary file
         * @return JSON response with result status
         */
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 9.8K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/app/web/admin/storage/AdminStorageAction.java

            saveToken();
            return id.filter(StringUtil::isNotBlank).map(s -> asListHtml(decodePath(s))).orElse(redirect(getClass()));
        }
    
        /**
         * Uploads a file to the storage system.
         *
         * @param form the item form containing file and path information
         * @return HTML response redirecting to the storage list after upload
         */
        @Execute
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 25.1K bytes
    - Viewed (0)
  8. cmd/erasure-server-pool-decom.go

    			SrcPoolIdx:   idx,
    			DataMovement: true,
    		})
    		if err != nil {
    			return fmt.Errorf("decommissionObject: NewMultipartUpload() %w", err)
    		}
    		defer z.AbortMultipartUpload(ctx, bucket, objInfo.Name, res.UploadID, ObjectOptions{NoAuditLog: true})
    		parts := make([]CompletePart, len(objInfo.Parts))
    		for i, part := range objInfo.Parts {
    			hr, err := hash.NewReader(ctx, io.LimitReader(gr, part.Size), part.Size, "", "", part.ActualSize)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 42.1K bytes
    - Viewed (1)
  9. src/main/java/org/codelibs/fess/app/web/api/admin/elevateword/ApiAdminElevatewordAction.java

            }
            return asJson(new ApiResult.ApiUpdateResponse().id(id).created(false).status(ApiResult.Status.OK).result());
        }
    
        // PUT /api/admin/elevateword/upload
        /**
         * Uploads and imports elevate words from a CSV file.
         * Processes the file asynchronously and updates the suggest helper.
         *
         * @param body upload form containing the CSV file
         * @return JSON response with upload status
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 12.8K bytes
    - Viewed (0)
  10. docs/security/README.md

    More details about supported KMS implementations and configuration can be found at the [KMS guide](https://github.com/minio/minio/blob/master/docs/kms/README.md).
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Feb 26 09:25:50 UTC 2025
    - 13.8K bytes
    - Viewed (0)
Back to top