- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for StorageClient (0.08 sec)
-
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/storage/StorageClient.java
* </ul> * * <p>The client handles timeout management for access operations and includes proper * resource cleanup mechanisms. * */ public class StorageClient extends AbstractCrawlerClient { private static final Logger logger = LogManager.getLogger(StorageClient.class); /** * The character encoding to use for content. Defaults to UTF-8. */ protected String charset = Constants.UTF_8; /**Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Mon Nov 24 03:59:47 UTC 2025 - 20K bytes - Viewed (2) -
src/main/java/org/codelibs/fess/storage/StorageClient.java
import java.util.List; import java.util.Map; /** * Interface for cloud storage operations. * Implementations provide access to S3-compatible storage, GCS, or other cloud storage systems. */ public interface StorageClient extends AutoCloseable { /** * Uploads an object to storage. * * @param objectName the name/path for the object * @param inputStream the input stream of data to uploadRegistered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Sat Dec 13 02:21:17 UTC 2025 - 2.8K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/client/storage/StorageClientTest.java
.singleton("storageClient", StorageClient.class); storageClient = container.getComponent("storageClient"); Map<String, Object> params = new HashMap<>(); params.put("endpoint", endpoint); params.put("accessKey", ACCESS_KEY); params.put("secretKey", SECRET_KEY); storageClient.setInitParameterMap(params); for (int i = 0; i < 10; i++) {
Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Mon Nov 24 03:59:47 UTC 2025 - 20.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/storage/StorageClientFactory.java
// Default to S3-compatible (MinIO, etc.) return StorageType.S3_COMPAT; } /** * Creates a StorageClient based on FessConfig. * * @param fessConfig the Fess configuration * @return configured StorageClient */ public static StorageClient createClient(final FessConfig fessConfig) { final String endpoint = fessConfig.getStorageEndpoint();Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Sat Dec 20 05:56:45 UTC 2025 - 4.2K bytes - Viewed (0) -
fess-crawler-lasta/src/main/resources/crawler/client.xml
<component name="ftpClient" class="org.codelibs.fess.crawler.client.ftp.FtpClient" instance="prototype"> <property name="charset">"UTF-8"</property> </component> <component name="storageClient" class="org.codelibs.fess.crawler.client.storage.StorageClient" instance="prototype"> <property name="charset">"UTF-8"</property> </component> <component name="s3Client"
Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Thu Dec 11 08:38:29 UTC 2025 - 3.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/storage/AdminStorageAction.java
import org.codelibs.fess.crawler.Constants; import org.codelibs.fess.exception.StorageException; import org.codelibs.fess.mylasta.direction.FessConfig; import org.codelibs.fess.storage.StorageClient; import org.codelibs.fess.storage.StorageClientFactory; import org.codelibs.fess.storage.StorageItem; import org.codelibs.fess.util.ComponentUtil; import org.codelibs.fess.util.RenderDataUtil;
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Sat Dec 13 02:21:17 UTC 2025 - 22.1K bytes - Viewed (0) -
CLAUDE.md
**Standard Patterns**: ```java "^https?://.*" → httpClient "^file:.*" → fileSystemClient "^ftp://.*" → ftpClient "^smb://.*" → smbClient "^storage://.*" → storageClient ``` ### Services **UrlQueueService**: URL queue management (FIFO), duplicate detection via `visited()` **DataService**: Access result persistence, iteration **Implementations**:
Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Fri Nov 28 17:31:34 UTC 2025 - 10.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/storage/S3StorageClient.java
/** * S3-compatible storage client implementation using AWS SDK v2. * Supports Amazon S3, MinIO, and other S3-compatible storage systems. */ public class S3StorageClient implements StorageClient { private static final Logger logger = LogManager.getLogger(S3StorageClient.class); private final S3Client s3Client; private final String bucket; /**Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Sat Dec 13 02:21:17 UTC 2025 - 10.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/storage/GcsStorageClient.java
import com.google.cloud.storage.Storage.BlobListOption; import com.google.cloud.storage.StorageOptions; /** * Google Cloud Storage client implementation. */ public class GcsStorageClient implements StorageClient { private static final Logger logger = LogManager.getLogger(GcsStorageClient.class); private final Storage storage; private final String bucket; /**Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Sat Dec 13 02:21:17 UTC 2025 - 10.3K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/client/s3/S3ClientTest.java
assertTrue(e.getCause() instanceof InterruptedException); } } public void test_temp_file_creation() { // Test that temp file uses correct prefix "S3Client" not "StorageClient" S3Client client = new S3Client() { @Override protected java.io.File createTempFile(String prefix, String suffix, java.io.File directory) { // Verify the prefix is correct
Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Thu Dec 11 07:57:44 UTC 2025 - 20.5K bytes - Viewed (0)