- Sort Score
- Num 10 results
- Language All
Results 131 - 140 of 228 for workers (0.06 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)