Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 151 - 160 of 361 for walkers (0.05 seconds)

  1. docs/ko/docs/deployment/docker.md

    그런 경우에는 `--workers` 커맨드 라인 옵션을 사용해 실행할 워커 수를 설정할 수 있습니다:
    
    ```{ .dockerfile .annotate }
    FROM python:3.14
    
    WORKDIR /code
    
    COPY ./requirements.txt /code/requirements.txt
    
    RUN pip install --no-cache-dir --upgrade -r /code/requirements.txt
    
    COPY ./app /code/app
    
    # (1)!
    CMD ["fastapi", "run", "app/main.py", "--port", "80", "--workers", "4"]
    ```
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Fri Mar 20 14:06:26 GMT 2026
    - 32.6K bytes
    - Click Count (0)
  2. cmd/erasure-server-pool.go

    	xioutil "github.com/minio/minio/internal/ioutil"
    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/pkg/v3/sync/errgroup"
    	"github.com/minio/pkg/v3/wildcard"
    	"github.com/minio/pkg/v3/workers"
    	"github.com/puzpuzpuz/xsync/v3"
    )
    
    type erasureServerPools struct {
    	poolMetaMutex sync.RWMutex
    	poolMeta      poolMeta
    
    	rebalMu     sync.RWMutex
    	rebalMeta   *rebalanceMeta
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 89.2K bytes
    - Click Count (0)
  3. okhttp-testing-support/src/main/kotlin/okhttp3/TestValueFactory.kt

     * it easy to get sample values to use in such tests.
     *
     * This class is pretty fast and loose with default values: it attempts to provide values that are
     * well-formed, but doesn't guarantee values are internally consistent. Callers must take care to
     * configure the factory when sample values impact the correctness of the test.
     */
    class TestValueFactory : Closeable {
      var taskFaker: TaskFaker = TaskFaker()
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Jan 11 12:06:21 GMT 2026
    - 6.6K bytes
    - Click Count (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RoutePlanner.kt

       * certificate pin checks.
       */
      fun sameHostAndPort(url: HttpUrl): Boolean
    
      /**
       * A plan holds either an immediately-usable connection, or one that must be connected first.
       * These steps are split so callers can call [connectTcp] on a background thread if attempting
       * multiple plans concurrently.
       */
      interface Plan {
        val isReady: Boolean
    
        fun connectTcp(): ConnectResult
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue May 27 14:58:02 GMT 2025
    - 4.2K bytes
    - Click Count (0)
  5. internal/config/heal/heal.go

    func (opts Config) Clone() (int, time.Duration, string) {
    	configMutex.RLock()
    	defer configMutex.RUnlock()
    	return opts.IOCount, opts.Sleep, opts.Bitrot
    }
    
    // GetWorkers returns the number of workers, -1 is none configured
    func (opts Config) GetWorkers() int {
    	configMutex.RLock()
    	defer configMutex.RUnlock()
    	return opts.DriveWorkers
    }
    
    // Update updates opts with nopts
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Nov 04 19:06:02 GMT 2024
    - 4.9K bytes
    - Click Count (0)
  6. guava/src/com/google/common/collect/ImmutableList.java

             * requireNonNull is safe because the callers promise to put non-null objects in the first
             * `length` array elements.
             */
            @SuppressWarnings("unchecked") // our callers put only E instances into the array
            E onlyElement = (E) requireNonNull(elements[0]);
            return of(onlyElement);
          default:
            /*
             * The suppression is safe because the callers promise to put non-null objects in the first
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Mar 08 16:16:42 GMT 2026
    - 30.6K bytes
    - Click Count (0)
  7. cmd/erasure-server-pool-decom.go

    	if err != nil {
    		decomLogIf(ctx, fmt.Errorf("invalid workers value err: %v, defaulting to %d", err, len(pool.sets)))
    		workerSize = len(pool.sets)
    	}
    
    	// Each decom worker needs one List() goroutine/worker
    	// add that many extra workers.
    	workerSize += len(pool.sets)
    
    	wk, err := workers.New(workerSize)
    	if err != nil {
    		return err
    	}
    
    	var vc *versioning.Versioning
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 42.2K bytes
    - Click Count (1)
  8. android/guava/src/com/google/common/io/Closeables.java

       *
       * - It might be preferable to be consistent with the JDK precedent (which they stuck with even
       *   for "UncheckedIOException").
       *
       * - If we change the name, some of our callers break because our Android Lint ParameterName check
       *   doesn't make the exception for com.google.common that internal Error Prone does: b/386402967.
       */
      @SuppressWarnings("IdentifierName")
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 17 20:26:29 GMT 2025
    - 5.1K bytes
    - Click Count (0)
  9. cmd/data-usage-utils.go

    	// Objects total count across all buckets
    	ObjectsTotalCount uint64 `json:"objectsCount"`
    
    	// Versions total count across all buckets
    	VersionsTotalCount uint64 `json:"versionsCount"`
    
    	// Delete markers total count across all buckets
    	DeleteMarkersTotalCount uint64 `json:"deleteMarkersCount"`
    
    	// Objects total size across all buckets
    	ObjectsTotalSize uint64                           `json:"objectsTotalSize"`
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Mar 10 09:15:15 GMT 2024
    - 6.4K bytes
    - Click Count (0)
  10. internal/kms/conn.go

    	// not exist.
    	//
    	// The context is associated and tied to the generated DEK.
    	// The same context must be provided when the generated key
    	// should be decrypted. Therefore, it is the callers
    	// responsibility to remember the corresponding context for
    	// a particular DEK. The context may be nil.
    	GenerateKey(context.Context, *GenerateKeyRequest) (DEK, error)
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Aug 18 06:43:03 GMT 2024
    - 5K bytes
    - Click Count (0)
Back to Top