Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 131 - 140 of 228 for workers (0.06 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. internal/logger/target/kafka/kafka.go

    	sconfig.Metadata.Retry.Backoff = (10 * time.Second)
    	sconfig.Metadata.RefreshFrequency = (15 * time.Minute)
    
    	h.config = sconfig
    
    	var brokers []string
    	for _, broker := range h.kconfig.Brokers {
    		brokers = append(brokers, broker.String())
    	}
    
    	client, err := sarama.NewClient(brokers, sconfig)
    	if err != nil {
    		return err
    	}
    
    	producer, err := sarama.NewSyncProducerFromClient(client)
    	if err != nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 10.2K bytes
    - Click Count (0)
  2. cmd/metrics-v3-cluster-usage.go

    		"Total cluster objects count")
    	usageVersionsCountMD = NewGaugeMD(usageVersionsCount,
    		"Total cluster object versions (including delete markers) count")
    	usageDeleteMarkersCountMD = NewGaugeMD(usageDeleteMarkersCount,
    		"Total cluster delete markers count")
    	usageBucketsCountMD = NewGaugeMD(usageBucketsCount,
    		"Total cluster buckets count")
    	usageObjectsDistributionMD = NewGaugeMD(usageSizeDistribution,
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 6.5K bytes
    - Click Count (0)
  3. build-logic-commons/module-identity/src/main/kotlin/gradlebuild.module-identity.gradle.kts

        published = false
    
        requiredRuntimes {
            client = false
            daemon = false
            worker = false
        }
    
        computedRuntimes {
            client = false
            daemon = false
            worker = false
        }
    
        // TODO: Most of these properties are the same across projects. We should
        // compute these at the settings-level instead of the project-level.
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Wed Mar 11 22:46:35 GMT 2026
    - 5.8K bytes
    - Click Count (0)
  4. docs/pt/docs/_llm-test.md

    * a tarefa em segundo plano
    * a função da tarefa
    
    * o template
    * o mecanismo de template
    
    * a anotação de tipo
    * a anotação de tipo
    
    * o worker de servidor
    * o worker do Uvicorn
    * o Worker do Gunicorn
    * o processo worker
    * a classe de worker
    * a carga de trabalho
    
    * a implantação
    * implantar
    
    * o SDK
    * o kit de desenvolvimento de software
    
    * o `APIRouter`
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:20:43 GMT 2026
    - 12.1K bytes
    - Click Count (0)
  5. docs/ru/llm-prompt.md

    * code base: кодовая база
    * instantiate: создать экземпляр (avoid "инстанцировать")
    * load balancer: балансировщик нагрузки
    * load balance: балансировка нагрузки
    * worker process: воркер-процесс (or `процесс воркера`)
    * worker: воркер
    * lifespan: lifespan (do not translate when it's about lifespan events, but translate as `жизненный цикл` or `срок жизни` in other cases)
    * mount (verb): монтировать
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Jan 22 07:07:05 GMT 2026
    - 6.5K bytes
    - Click Count (0)
  6. build-tools-internal/src/main/groovy/elasticsearch.build-scan.gradle

        if (jenkinsUrl?.host?.endsWith('elastic.co') || jenkinsUrl?.host?.endsWith('elastic.dev')) {
          publishAlways()
          buildScan.server = 'https://gradle-enterprise.elastic.co'
        }
    
        // Link to Jenkins worker logs and system metrics
        if (nodeName) {
          link 'System logs', "https://infra-stats.elastic.co/app/infra#/logs?" +
            "&logFilter=(expression:'host.name:${nodeName}',kind:kuery)"
          buildFinished {
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Wed Jul 21 20:40:34 GMT 2021
    - 4.6K bytes
    - Click Count (0)
  7. tensorflow/c/c_api_experimental_test.cc

    namespace {
    
    TEST(CAPI_EXPERIMENTAL, GetServerDefTest) {
      const std::string expected_text_proto(R"(cluster {
      job {
        name: "worker"
        tasks {
          key: 0
          value: "tpuserver:0"
        }
        tasks {
          key: 1
          value: "localhost:1"
        }
      }
    }
    job_name: "worker"
    task_index: 1
    protocol: "grpc"
    )");
    
      TF_Status* status = TF_NewStatus();
    Created: Tue Apr 07 12:39:13 GMT 2026
    - Last Modified: Wed Jan 07 04:56:09 GMT 2026
    - 13.1K bytes
    - Click Count (0)
  8. internal/logger/config.go

    				break
    			}
    			brokers = append(brokers, *host)
    		}
    		if err != nil {
    			return cfg, err
    		}
    
    		clientAuthCfgVal := getCfgVal(EnvKafkaTLSClientAuth, k, kv.Get(KafkaTLSClientAuth))
    		clientAuth, err := strconv.Atoi(clientAuthCfgVal)
    		if err != nil {
    			return cfg, err
    		}
    
    		kafkaArgs := kafka.Config{
    			Enabled: enabled,
    			Brokers: brokers,
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 18.7K bytes
    - Click Count (0)
  9. okhttp/src/androidMain/assets/PublicSuffixDatabase.list

    wloclawek.pl
    wmcloud.org
    wme
    wmflabs.org
    wnext.app
    wodzislaw.pl
    wolomin.pl
    wolterskluwer
    woltlab-demo.com
    woodside
    worf.replit.dev
    work
    workers.dev
    workinggroup.aero
    workisboring.com
    works
    works.aero
    world
    worse-than.tv
    wow
    wp2.host
    wpdevcloud.com
    wpenginepowered.com
    wphostedmail.com
    wpmucdn.com
    wpmudev.host
    wpsquared.site
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Dec 31 14:50:53 GMT 2024
    - 129.6K bytes
    - Click Count (2)
  10. internal/config/notify/legacy.go

    			Key:   config.Enable,
    			Value: config.EnableOn,
    		},
    		config.KV{
    			Key: target.KafkaBrokers,
    			Value: func() string {
    				var brokers []string
    				for _, broker := range cfg.Brokers {
    					brokers = append(brokers, broker.String())
    				}
    				return strings.Join(brokers, config.ValueSeparator)
    			}(),
    		},
    		config.KV{
    			Key:   target.KafkaTopic,
    			Value: cfg.Topic,
    		},
    		config.KV{
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Apr 27 04:30:57 GMT 2025
    - 13.3K bytes
    - Click Count (0)
Back to Top