Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for upstream (0.09 sec)

  1. cmd/object-multipart-handlers.go

    	case authTypeStreamingSigned, authTypeStreamingSignedTrailer:
    		// Initialize stream signature verifier.
    		reader, s3Error = newSignV4ChunkedReader(r, rAuthType == authTypeStreamingSignedTrailer)
    		if s3Error != ErrNone {
    			writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL)
    			return
    		}
    	case authTypeStreamingUnsignedTrailer:
    		// Initialize stream signature verifier.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 39.5K bytes
    - Viewed (0)
  2. fess-crawler/src/test/java/org/codelibs/fess/crawler/client/smb/SmbClientTest.java

            }
    
            try {
                smbClient.doGet(baseUrl);
                fail();
            } catch (final ChildUrlsException e) {
                String[] urls = e.getChildUrlList().stream().map(r -> r.getUrl()).sorted().toArray(String[]::new);
                assertEquals(3, urls.length);
                assertEquals(baseUrl + "dir1/", urls[0]);
                assertEquals(baseUrl + "dir3/", urls[1]);
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Sep 06 04:15:37 UTC 2025
    - 13.7K bytes
    - Viewed (0)
  3. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/AbstractCrawlerClient.java

        private static final Logger logger = LogManager.getLogger(AbstractCrawlerClient.class);
    
        /** The MIME type for application/octet-stream. */
        protected static final String APPLICATION_OCTET_STREAM = "application/octet-stream";
    
        /** The property name for access timeout. */
        public static final String ACCESS_TIMEOUT_PROPERTY = "accessTimeout";
    
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Sep 06 04:15:37 UTC 2025
    - 9.7K bytes
    - Viewed (0)
  4. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/smb/SmbClient.java

                logger.debug("Initializing SmbClient...");
            }
    
            super.init();
    
            final Properties props = new Properties();
            System.getProperties().entrySet().stream().filter(e -> e.getKey().toString().startsWith("jcifs.")).forEach(e -> {
                props.setProperty((String) e.getKey(), (String) e.getValue());
            });
            try {
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Sep 18 09:30:45 UTC 2025
    - 22.5K bytes
    - Viewed (0)
  5. cmd/erasure-multipart.go

    	// We can safely allow RenameFile errors up to len(er.getDisks()) - writeQuorum
    	// otherwise return failure. Cleanup successful renames.
    	return evalDisks(disks, errs), err
    }
    
    // PutObjectPart - reads incoming stream and internally erasure codes
    // them. This call is similar to single put operation but it is part
    // of the multipart transaction.
    //
    // Implements S3 compatible Upload Part API.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 47.3K bytes
    - Viewed (0)
  6. fess-crawler/src/test/java/org/codelibs/fess/crawler/client/ftp/FtpClientTest.java

                fail();
            } catch (final ChildUrlsException e) {
                final Set<RequestData> urlSet = e.getChildUrlList();
                assertEquals(5, urlSet.size());
                final List<String> urlList = urlSet.stream().map(x -> x.getUrl()).sorted().toList();
                assertEquals("ftp://localhost:10021/dir1", urlList.get(0));
                assertEquals("ftp://localhost:10021/dir2", urlList.get(1));
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Sep 06 04:15:37 UTC 2025
    - 18K bytes
    - Viewed (0)
  7. cmd/object-handlers.go

    	case authTypeStreamingSigned, authTypeStreamingSignedTrailer:
    		// Initialize stream signature verifier.
    		rd, s3Err = newSignV4ChunkedReader(r, rAuthType == authTypeStreamingSignedTrailer)
    		if s3Err != ErrNone {
    			writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Err), r.URL)
    			return
    		}
    	case authTypeStreamingUnsignedTrailer:
    		// Initialize stream chunked reader with optional trailers.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 120.6K bytes
    - Viewed (0)
  8. cmd/erasure-object.go

    	}
    
    	return fi.ToObjectInfo(minioMetaBucket, key, opts.Versioned || opts.VersionSuspended), nil
    }
    
    // PutObject - creates an object upon reading from the input stream
    // until EOF, erasure codes the data across all disk and additionally
    // writes `xl.meta` which carries the necessary metadata for future
    // object operations.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 80.4K bytes
    - Viewed (0)
  9. cmd/object-api-interface.go

    	WantServerSideChecksumType hash.ChecksumType // if set, we compute a server-side checksum of this type
    
    	NoDecryption                        bool      // indicates if the stream must be decrypted.
    	PreserveETag                        string    // preserves this etag during a PUT call.
    	NoLock                              bool      // indicates to lower layers if the caller is expecting to hold locks.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 17.5K bytes
    - Viewed (0)
  10. docs/en/docs/release-notes.md

    ## 0.66.0
    
    ### Features
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Fri Sep 05 12:48:45 UTC 2025
    - 544.1K bytes
    - Viewed (0)
Back to top