Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1681 - 1690 of 1,918 for fluent (0.08 seconds)

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Address.kt

      val url: HttpUrl =
        HttpUrl
          .Builder()
          .scheme(if (sslSocketFactory != null) "https" else "http")
          .host(uriHost)
          .port(uriPort)
          .build()
    
      /**
       * The protocols the client supports. This method always returns a non-null list that
       * contains minimally [Protocol.HTTP_1_1].
       */
      @get:JvmName("protocols")
      val protocols: List<Protocol> = protocols.toImmutableList()
    
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 7.3K bytes
    - Click Count (0)
  2. src/main/java/org/codelibs/fess/timer/SystemMonitorTarget.java

    import org.apache.commons.text.StringEscapeUtils;
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.fess.Constants;
    import org.codelibs.fess.opensearch.client.SearchEngineClient;
    import org.codelibs.fess.util.ComponentUtil;
    import org.opensearch.action.admin.cluster.node.stats.NodesStatsResponse;
    import org.opensearch.common.xcontent.XContentFactory;
    Created: Sat Dec 20 09:19:18 GMT 2025
    - Last Modified: Thu Jul 17 08:28:31 GMT 2025
    - 7.8K bytes
    - Click Count (0)
  3. cmd/bucket-policy-handlers.go

    		return
    	}
    
    	configData, err := json.Marshal(config)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	// Write to client.
    	writeSuccessResponseJSON(w, configData)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri May 24 23:05:23 GMT 2024
    - 6.1K bytes
    - Click Count (0)
  4. architecture/platforms.md

    It is made up of 3 architecture modules:
    
    - **core-runtime**: Provides the runtimes or "containers" in which code runs. These runtimes include the Gradle client, the daemon and the worker processes. This is the base module on which all other architecture modules depend.
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Thu May 02 06:42:46 GMT 2024
    - 5.4K bytes
    - Click Count (0)
  5. docs/en/docs/tutorial/background-tasks.md

    # Background Tasks { #background-tasks }
    
    You can define background tasks to be run *after* returning a response.
    
    This is useful for operations that need to happen after a request, but that the client doesn't really have to be waiting for the operation to complete before receiving the response.
    
    This includes, for example:
    
    * Email notifications sent after performing an action:
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Wed Dec 17 20:41:43 GMT 2025
    - 4.8K bytes
    - Click Count (0)
  6. cmd/listen-notification-handlers.go

    			return
    		}
    	}
    
    	rulesMap := event.NewRulesMap(eventNames, pattern, event.TargetID{ID: mustGetUUID()})
    
    	setEventStreamHeaders(w)
    
    	// Listen Publisher and peer-listen-client uses nonblocking send and hence does not wait for slow receivers.
    	// Use buffered channel to take care of burst sends or slow w.Write()
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 6K bytes
    - Click Count (0)
  7. cmd/server-startup-msg.go

    	cred := globalActiveCred
    
    	const mcQuickStartGuide = "https://docs.min.io/community/minio-object-store/reference/minio-mc.html#quickstart"
    
    	// Configure 'mc', following block prints platform specific information for minio client.
    	if color.IsTerminal() && (!globalServerCtxt.Anonymous && globalAPIConfig.permitRootAccess()) {
    		logger.Startup(color.Blue("\nCLI: ") + mcQuickStartGuide)
    		mcMessage := fmt.Sprintf("$ mc alias set '%s' '%s' '%s' '%s'", alias,
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 6.2K bytes
    - Click Count (0)
  8. cmd/bucket-replication.go

    	}
    
    	req, err := http.NewRequestWithContext(ctx, http.MethodGet, reqURL.String(), nil)
    	if err != nil {
    		return err
    	}
    
    	client := &http.Client{
    		Transport: globalRemoteTargetTransport,
    		Timeout:   10 * time.Second,
    	}
    
    	resp, err := client.Do(req)
    	if err != nil {
    		return err
    	}
    	if err == nil {
    		// Drain the connection.
    		xhttp.DrainBody(resp.Body)
    	}
    	if resp != nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 118.2K bytes
    - Click Count (0)
  9. guava/src/com/google/common/net/MediaType.java

      /**
       * NaCl applications. For more information see <a
       * href="https://developer.chrome.com/native-client/devguide/coding/application-structure">the
       * Developer Guide for Native Client Application Structure</a>.
       *
       * @since 20.0
       */
      public static final MediaType NACL_APPLICATION = createConstant(APPLICATION_TYPE, "x-nacl");
    
      /**
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Oct 02 01:46:40 GMT 2025
    - 48K bytes
    - Click Count (0)
  10. src/main/java/jcifs/smb1/smb1/SmbFile.java

                logger.error("Failed to load jcifs.smb1.Config class", cnfe);
            }
            attrExpirationPeriod = Config.getLong("jcifs.smb1.smb.client.attrExpirationPeriod", DEFAULT_ATTR_EXPIRATION_PERIOD);
            ignoreCopyToException = Config.getBoolean("jcifs.smb1.smb.client.ignoreCopyToException", true);
            dfs = new Dfs();
        }
    
        /**
         * Returned by {@link #getType()} if the resource this {@code SmbFile}
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 112.2K bytes
    - Click Count (0)
Back to Top