- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 16 for fsClient (0.07 seconds)
-
fess-crawler-lasta/src/main/resources/crawler/client.xml
<property name="hc4Client">internalHc4HttpClient</property> <property name="maxRetryCount">5</property> <property name="retryInterval">500</property> <postConstruct name="init" /> </component> <component name="fsClient" class="org.codelibs.fess.crawler.client.fs.FileSystemClient" instance="prototype"> <property name="charset">"UTF-8"</property> </component>
Created: Sun Apr 12 03:50:13 GMT 2026 - Last Modified: Thu Jan 08 04:17:06 GMT 2026 - 3.7K bytes - Click Count (0) -
README.md
} } ``` ### File System Crawling ```java import org.codelibs.fess.crawler.client.fs.FileSystemClient; // Configure for file system crawling container.singleton("fsClient", FileSystemClient.class); // Add file URL crawler.addUrl("file:///path/to/directory"); crawler.urlFilter.addInclude("file:///path/to/directory/.*"); ``` ## Configuration ### XML Configuration
Created: Sun Apr 12 03:50:13 GMT 2026 - Last Modified: Sun Aug 31 05:32:52 GMT 2025 - 15.3K bytes - Click Count (0) -
src/main/resources/esclient.xml
Shinsuke Sugaya <******@****.***> 1774681159 +0900
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 28 06:59:19 GMT 2026 - 16.2K bytes - Click Count (0) -
dbflute_fess/dfprop/esfluteMap.dfprop
; esclientDiFile = esclient.xml ; esfluteDiFile = esflute_user.xml } ; fess_user.role = map:{ ; package = user ; esclientDiFile = esclient.xml ; esfluteDiFile = esflute_user.xml } ; fess_user.user = map:{ ; package = user ; esclientDiFile = esclient.xml ; esfluteDiFile = esflute_user.xmlCreated: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Wed Nov 06 13:45:02 GMT 2024 - 6.3K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/WebSocketWriter.kt
private var messageDeflater: MessageDeflater? = null // Masks are only a concern for client writers. private val maskKey: ByteArray? = if (isClient) ByteArray(4) else null private val maskCursor: Buffer.UnsafeCursor? = if (isClient) Buffer.UnsafeCursor() else null /** Send a ping with the supplied [payload]. */ @Throws(IOException::class) fun writePing(payload: ByteString) {
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 6K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/WebSocketReader.kt
private var messageInflater: MessageInflater? = null // Masks are only a concern for server writers. private val maskKey: ByteArray? = if (isClient) null else ByteArray(4) private val maskCursor: Buffer.UnsafeCursor? = if (isClient) null else Buffer.UnsafeCursor() interface FrameCallback { @Throws(IOException::class) fun onReadMessage(text: String) @Throws(IOException::class)
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 10K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/timer/HotThreadMonitorTarget.java
final String type = fessConfig.getCrawlerHotthreadType(); try { final SearchEngineClient esClient = ComponentUtil.getSearchEngineClient(); final NodesHotThreadsResponse response = esClient.admin() .cluster() .prepareNodesHotThreads() .setIgnoreIdleThreads(ignoreIdleThreads)
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Aug 07 03:06:29 GMT 2025 - 3.7K bytes - Click Count (0) -
src/main/resources/esflute_user.xml
<?xml version="1.0" encoding="UTF-8"?> <!DOCTYPE components PUBLIC "-//DBFLUTE//DTD LastaDi 1.0//EN" "http://dbflute.org/meta/lastadi10.dtd"> <components> <include path="esclient.xml"/> <!-- The components of DBFlute Runtime. --> <component name="invokerAssistant" class="org.codelibs.fess.opensearch.common.ImplementedInvokerAssistant"/> <component name="behaviorCommandInvoker" class="org.dbflute.bhv.core.BehaviorCommandInvoker"/>
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Wed Nov 06 13:45:02 GMT 2024 - 750 bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/WebSocketReaderTest.kt
private val serverReader = WebSocketReader( isClient = false, source = data, frameCallback = callback.asFrameCallback(), perMessageDeflate = false, noContextTakeover = false, ) private val serverReaderWithCompression = WebSocketReader( isClient = false, source = data, frameCallback = callback.asFrameCallback(),Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Nov 04 16:11:23 GMT 2025 - 14.4K bytes - Click Count (0) -
src/main/resources/esflute_log.xml
<?xml version="1.0" encoding="UTF-8"?> <!DOCTYPE components PUBLIC "-//DBFLUTE//DTD LastaDi 1.0//EN" "http://dbflute.org/meta/lastadi10.dtd"> <components> <include path="esclient.xml"/> <!-- The components of DBFlute Runtime. --> <component name="invokerAssistant" class="org.codelibs.fess.opensearch.common.ImplementedInvokerAssistant"/> <component name="behaviorCommandInvoker" class="org.dbflute.bhv.core.BehaviorCommandInvoker"/>
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Wed Nov 06 13:45:02 GMT 2024 - 869 bytes - Click Count (0)