Search Options

Results per page
Sort
Preferred Languages
Advance

Results 521 - 530 of 849 for upstream (0.06 sec)

  1. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlFilterService.java

    import java.util.HashSet;
    import java.util.List;
    import java.util.Set;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.TimeUnit;
    import java.util.regex.Pattern;
    import java.util.stream.Collectors;
    
    import org.codelibs.fess.crawler.entity.OpenSearchUrlFilter;
    import org.codelibs.fess.crawler.exception.CrawlerSystemException;
    import org.codelibs.fess.crawler.service.UrlFilterService;
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Nov 07 04:44:10 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt

     * layer primitives: connections, requests, responses, and streams.
     *
     * This class supports [asynchronous canceling][cancel]. This is intended to have the smallest
     * blast radius possible. If an HTTP/2 stream is active, canceling will cancel that stream but not
     * the other streams sharing its connection. But if the TLS handshake is still in progress then
     * canceling may break the entire connection.
     */
    class RealCall(
      val client: OkHttpClient,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  3. istioctl/pkg/writer/envoy/configdump/testdata/routes/istio-gateway-http-route-prefix/configdump.json

              },
              "route": {
               "cluster": "outbound|8000||httpbin.default.svc.cluster.local",
               "timeout": "0s",
               "retry_policy": {
                "retry_on": "connect-failure,refused-stream,unavailable,cancelled,retriable-status-codes",
                "num_retries": 2,
                "retry_host_predicate": [
                 {
                  "name": "envoy.retry_host_predicates.previous_hosts",
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 08 20:44:50 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  4. src/test/java/org/codelibs/opensearch/extension/analysis/SynonymLoader.java

                    final Tokenizer tokenizer = new KeywordTokenizer();
                    final TokenStream stream = ignoreCase ? new LowerCaseFilter(tokenizer) : tokenizer;
                    return new TokenStreamComponents(tokenizer, stream);
                }
            };
        }
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:54 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  5. src/main/java/jcifs/https/Handler.java

    
    /**
     * A <code>URLStreamHandler</code> used to provide NTLM authentication
     * capabilities to the default HTTPS handler. This acts as a wrapper,
     * handling authentication and passing control to the underlying
     * stream handler.
     * 
     * @deprecated {@link NtlmHttpURLConnection} is broken by design.
     */
    @Deprecated
    public class Handler extends jcifs.http.Handler {
    
        /**
         * The default HTTPS port (<code>443</code>).
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 1.8K bytes
    - Viewed (0)
  6. docs/en/docs/reference/responses.md

    There are several custom response classes you can use to create an instance and return them directly from your *path operations*.
    
    Read more about it in the [FastAPI docs for Custom Response - HTML, Stream, File, others](https://fastapi.tiangolo.com/advanced/custom-response/).
    
    You can import them directly from `fastapi.responses`:
    
    ```python
    from fastapi.responses import (
        FileResponse,
        HTMLResponse,
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Thu Apr 18 19:53:19 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  7. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueService.java

    import java.util.ArrayList;
    import java.util.List;
    import java.util.Map;
    import java.util.Queue;
    import java.util.concurrent.ConcurrentHashMap;
    import java.util.concurrent.ConcurrentLinkedQueue;
    import java.util.stream.Collectors;
    
    import org.codelibs.core.lang.StringUtil;
    import org.codelibs.fess.crawler.Constants;
    import org.codelibs.fess.crawler.entity.AccessResult;
    import org.codelibs.fess.crawler.entity.OpenSearchUrlQueue;
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Nov 07 04:44:10 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  8. cmd/metacache-walk.go

    }
    
    // supported FS for Nlink optimization in readdir.
    const (
    	xfs  = "XFS"
    	ext4 = "EXT4"
    )
    
    // WalkDir will traverse a directory and return all entries found.
    // On success a sorted meta cache stream will be returned.
    // Metadata has data stripped, if any.
    func (s *xlStorage) WalkDir(ctx context.Context, opts WalkDirOptions, wr io.Writer) (err error) {
    	legacyFS := !(s.fsType == xfs || s.fsType == ext4)
    
    	s.RLock()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Jun 01 05:17:37 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/io/TestCharSink.java

      }
    
      @Override
      public boolean wasStreamClosed() {
        return byteSink.wasStreamClosed();
      }
    
      @Override
      public Writer openStream() throws IOException {
        // using TestByteSink's output stream to get option behavior, so flush to it on every write
        return new FilterWriter(new OutputStreamWriter(byteSink.openStream(), UTF_8)) {
          @Override
          public void write(int c) throws IOException {
            super.write(c);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 23 14:22:54 UTC 2024
    - 2K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/app/web/api/admin/stats/ApiAdminStatsAction.java

            stats.put("fs", getFsObj());
            return asJson(new ApiStatsResponse().stats(stats).status(ApiResult.Status.OK).result());
        }
    
        private FsObj[] getFsObj() {
            return Arrays.stream(File.listRoots()).map(f -> {
                final FsObj fsObj = new FsObj();
                fsObj.path = f.getAbsolutePath();
                fsObj.free = f.getFreeSpace();
                fsObj.total = f.getTotalSpace();
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 12.1K bytes
    - Viewed (0)
Back to top