Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for brokers (0.11 sec)

  1. docs/bucket/notifications/README.md

    ```
    KEY:
    notify_kafka[:name]  publish bucket notifications to Kafka endpoints
    
    ARGS:
    brokers*         (csv)       comma separated list of Kafka broker addresses
    topic            (string)    Kafka topic used for bucket notifications
    sasl_username    (string)    username for SASL/PLAIN or SASL/SCRAM authentication
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 84K bytes
    - Viewed (0)
  2. .teamcity/test-buckets.json

    					"problems-api",
    					"plugins-java-base",
    					"build-cache"
    				]
    			},
    			{
    				"parallelizationMethod":{
    					"name":"TestDistribution"
    				},
    				"subprojects":[
    					"workers",
    					"wrapper-main",
    					"testing-base-infrastructure",
    					"messaging",
    					"war",
    					"instrumentation-agent-services",
    					"build-profile",
    					"resources-gcs",
    					"ear",
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Tue Oct 08 11:14:16 UTC 2024
    - 87.8K bytes
    - Viewed (0)
  3. cmd/batch-handlers.go

    // newBatchJobPool creates a pool of job manifest workers of specified size
    func newBatchJobPool(ctx context.Context, o ObjectLayer, workers int) *BatchJobPool {
    	jpool := &BatchJobPool{
    		ctx:          ctx,
    		objLayer:     o,
    		jobCh:        make(chan *BatchJobRequest, 10000),
    		workerKillCh: make(chan struct{}, workers),
    		jobCancelers: make(map[string]context.CancelFunc),
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 18 15:32:09 UTC 2024
    - 62.2K bytes
    - Viewed (0)
  4. docs/changelogs/changelog_3x.md

        commitment was originally through December 31, 2020; we have since extended it.)
    
     *  **TLSv1 and TLSv1.1 are no longer enabled by default.** Major web browsers are working towards
        removing these versions altogether in early 2020. If your servers aren't ready yet you can
        configure OkHttp 3.13 to allow TLSv1 and TLSv1.1 connections:
    
        ```
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 06 14:55:54 UTC 2022
    - 50.8K bytes
    - Viewed (0)
  5. docs/metrics/prometheus/grafana/replication/minio-replication-node.json

              "interval": "1m",
              "intervalFactor": 2,
              "legendFormat": "{{server}}",
              "refId": "A"
            }
          ],
          "title": "Avg. Active Workers",
          "type": "timeseries"
        },
        {
          "datasource": {
            "type": "prometheus",
            "uid": "${DS_PROMETHEUS}"
          },
          "fieldConfig": {
            "defaults": {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jun 13 22:26:54 UTC 2024
    - 57.4K bytes
    - Viewed (0)
  6. okhttp/src/test/java/okhttp3/HttpUrlTest.kt

        assertThat(parse("http://host/\ufffd").encodedPath).isEqualTo("/%EF%BF%BD")
      }
    
      @Test
      fun usernameCharacters() {
        if (!isJvm) return // TODO: this test is broken on non-JVM platforms.
        UrlComponentEncodingTester.newInstance()
          .override(
            Encoding.PERCENT,
            '['.code,
            ']'.code,
            '{'.code,
            '}'.code,
            '|'.code,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 67.9K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/collect/Sets.java

              return false;
            }
            i++;
          }
          return true;
        }
    
        @Override
        public boolean equals(@CheckForNull Object object) {
          // Warning: this is broken if size() == 0, so it is critical that we
          // substitute an empty ImmutableSet to the user in place of this
          if (object instanceof CartesianSet) {
            CartesianSet<?> that = (CartesianSet<?>) object;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 78.8K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/HttpUrl.kt

     * forgiving: it will automatically percent-encode the `|'` yielding `http://example.com/abc%7Cdef`.
     * This kind behavior is consistent with web browsers. `HttpUrl` prefers consistency with major web
     * browsers over consistency with obsolete specifications.
     *
     * ### Paths and Queries should decompose
     *
     * Neither of the built-in URL models offer direct access to path segments or query parameters.
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Tue Jan 09 12:33:05 UTC 2024
    - 63.5K bytes
    - Viewed (0)
  9. tensorflow/BUILD

    # instead depend on the dummy plugins in @local_tsl//tsl/platform/default/build_config
    # and use header only targets.
    # TODO(ddunleavy): This seems completely broken. :tensorflow_cc depends on
    # cuda_platform from tf_additional_binary_deps and this doesn't break.
    check_deps(
        name = "cuda_plugins_check_deps",
        disallowed_deps = if_static(
            [],
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Wed Oct 16 05:28:35 UTC 2024
    - 53.5K bytes
    - Viewed (0)
  10. docs/ru/docs/deployment/docker.md

    Я подготовил для вас Docker-образ, в который включён Gunicorn управляющий процессами (воркерами) Uvicorn, в соответствии с концепциями рассмотренными в предыдущей главе: [Рабочие процессы сервера (воркеры) - Gunicorn совместно с Uvicorn](server-workers.md){.internal-link target=_blank}.
    
    Этот образ может быть полезен для ситуаций описанных тут: [Множество процессов внутри контейнера для особых случаев](#_11).
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Mon Aug 12 21:47:53 UTC 2024
    - 57.6K bytes
    - Viewed (0)
Back to top