- Sort Score
- Result 10 results
- Languages All
Results 551 - 560 of 1,175 for fiction (0.16 sec)
-
src/main/java/org/codelibs/fess/es/config/bsbhv/BsKeyMatchBhv.java
import org.dbflute.exception.IllegalBehaviorStateException; import org.dbflute.optional.OptionalEntity; import org.dbflute.util.DfTypeUtil; import org.opensearch.action.bulk.BulkRequestBuilder; import org.opensearch.action.delete.DeleteRequestBuilder; import org.opensearch.action.index.IndexRequestBuilder; /** * @author ESFlute (using FreeGen) */ public abstract class BsKeyMatchBhv extends EsAbstractBehavior<KeyMatch, KeyMatchCB> {
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 9.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/config/bsbhv/BsRequestHeaderBhv.java
import org.dbflute.exception.IllegalBehaviorStateException; import org.dbflute.optional.OptionalEntity; import org.dbflute.util.DfTypeUtil; import org.opensearch.action.bulk.BulkRequestBuilder; import org.opensearch.action.delete.DeleteRequestBuilder; import org.opensearch.action.index.IndexRequestBuilder; /** * @author ESFlute (using FreeGen) */
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 9.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/user/bsbhv/BsGroupBhv.java
import org.dbflute.exception.IllegalBehaviorStateException; import org.dbflute.optional.OptionalEntity; import org.dbflute.util.DfTypeUtil; import org.opensearch.action.bulk.BulkRequestBuilder; import org.opensearch.action.delete.DeleteRequestBuilder; import org.opensearch.action.index.IndexRequestBuilder; /** * @author ESFlute (using FreeGen) */ public abstract class BsGroupBhv extends EsAbstractBehavior<Group, GroupCB> {
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 8.9K bytes - Viewed (0) -
build-logic-commons/gradle-plugin/src/main/kotlin/gradlebuild/AbstractBuildScanInfoCollectingService.kt
} val taskPath = event.descriptor.taskPath if (shouldInclude(taskPath)) { action(taskPath, event.result) } } protected open fun shouldInclude(taskPath: String): Boolean = parameters.monitoredTaskPaths.get().contains(taskPath) abstract fun action(taskPath: String, taskResult: TaskOperationResult)
Registered: Wed Oct 30 11:36:09 UTC 2024 - Last Modified: Thu Aug 11 07:01:27 UTC 2022 - 2.3K bytes - Viewed (0) -
src/main/java/org/codelibs/curl/CurlRequest.java
import java.net.Proxy; import java.net.URL; import java.net.URLEncoder; import java.util.ArrayList; import java.util.List; import java.util.concurrent.ForkJoinPool; import java.util.function.BiConsumer; import java.util.function.Consumer; import java.util.function.Supplier; import java.util.logging.Logger; import java.util.zip.GZIPInputStream; import javax.net.ssl.HttpsURLConnection; import javax.net.ssl.SSLSocketFactory;
Registered: Sun Oct 27 04:35:21 UTC 2024 - Last Modified: Sun Feb 12 12:21:25 UTC 2023 - 12.3K bytes - Viewed (0) -
cmd/signals.go
go func() { globalMRFState.shutdown() close(finished) }() select { case <-time.After(shutdownTimeout): case <-finished: } } func handleSignals() { // Custom exit function exit := func(success bool) { if globalLoggerOutput != nil { globalLoggerOutput.Close() } // If global profiler is set stop before we exit. globalProfilerMu.Lock() defer globalProfilerMu.Unlock()
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Wed Sep 04 17:02:39 UTC 2024 - 3.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/config/bsbhv/BsWebConfigBhv.java
import org.dbflute.exception.IllegalBehaviorStateException; import org.dbflute.optional.OptionalEntity; import org.dbflute.util.DfTypeUtil; import org.opensearch.action.bulk.BulkRequestBuilder; import org.opensearch.action.delete.DeleteRequestBuilder; import org.opensearch.action.index.IndexRequestBuilder; /** * @author ESFlute (using FreeGen) */ public abstract class BsWebConfigBhv extends EsAbstractBehavior<WebConfig, WebConfigCB> {
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 10.8K bytes - Viewed (0) -
fastapi/cli.py
try: from fastapi_cli.cli import main as cli_main except ImportError: # pragma: no cover cli_main = None # type: ignore def main() -> None: if not cli_main: # type: ignore[truthy-function] message = 'To use the fastapi command, please install "fastapi[standard]":\n\n\tpip install "fastapi[standard]"\n' print(message) raise RuntimeError(message) # noqa: B904
Registered: Sun Oct 27 07:19:11 UTC 2024 - Last Modified: Fri Aug 02 06:03:05 UTC 2024 - 418 bytes - Viewed (0) -
dockerscripts/download-static-curl.sh
#!/bin/bash function download_arch_specific_executable { curl -f -L -s -q \ https://github.com/moparisthebest/static-curl/releases/latest/download/curl-$1 \ -o /go/bin/curl || exit 1 chmod +x /go/bin/curl } case $TARGETARCH in "arm64") download_arch_specific_executable aarch64 ;; "s390x") echo "Not downloading static cURL because it does not exist for the $TARGETARCH architecture." ;; *)
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Sep 12 15:45:19 UTC 2024 - 461 bytes - Viewed (0) -
internal/config/lambda/target/lazyinit.go
package target import ( "sync" "sync/atomic" ) // Inspired from Golang sync.Once but it is only marked // initialized when the provided function returns nil. type lazyInit struct { done uint32 m sync.Mutex } func (l *lazyInit) Do(f func() error) error { if atomic.LoadUint32(&l.done) == 0 { return l.doSlow(f) } return nil }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Mar 07 16:12:41 UTC 2023 - 1.3K bytes - Viewed (0)