Search Options

Results per page
Sort
Preferred Languages
Advance

Results 121 - 130 of 220 for workers (0.15 sec)

  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 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  2. 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,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 20 16:02:50 UTC 2024
    - 18.3K bytes
    - Viewed (0)
  3. tensorflow/c/c_api_experimental_test.cc

    namespace {
    
    TEST(CAPI_EXPERIMENTAL, GetServerDefTest) {
      const 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();
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Tue Jan 17 22:27:52 UTC 2023
    - 13.1K bytes
    - Viewed (0)
  4. docs/de/docs/deployment/concepts.md

    Hier sind einige mögliche Kombinationen und Strategien:
    
    * **Gunicorn**, welches **Uvicorn-Worker** managt
        * Gunicorn wäre der **Prozessmanager**, der die **IP** und den **Port** überwacht, die Replikation würde durch **mehrere Uvicorn-Workerprozesse** erfolgen
    * **Uvicorn**, welches **Uvicorn-Worker** managt
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Aug 06 04:48:30 UTC 2024
    - 20.6K bytes
    - Viewed (0)
  5. docs/fr/docs/deployment/manually.md

    ```console
    $ pip install "hypercorn[trio]"
    ---> 100%
    ```
    
    </div>
    
    ### Exécuter avec Trio
    
    Ensuite, vous pouvez passer l'option de ligne de commande `--worker-class` avec la valeur `trio` :
    
    <div class="termy">
    
    ```console
    $ hypercorn main:app --worker-class trio
    ```
    
    </div>
    
    Et cela démarrera Hypercorn avec votre application en utilisant Trio comme backend.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Aug 06 04:48:30 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  6. docs/de/docs/deployment/manually.md

    ```console
    $ pip install "hypercorn[trio]"
    ---> 100%
    ```
    
    </div>
    
    ### Mit Trio ausführen
    
    Dann können Sie die Befehlszeilenoption `--worker-class` mit dem Wert `trio` übergeben:
    
    <div class="termy">
    
    ```console
    $ hypercorn main:app --worker-class trio
    ```
    
    </div>
    
    Und das startet Hypercorn mit Ihrer Anwendung und verwendet Trio als Backend.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Aug 06 04:48:30 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  7. CHANGELOG/CHANGELOG-1.10.md

    ### AWS
    
    * Add AWS cloud provider option to use an assumed IAM role. For example, this allows running Controller Manager in a account separate from the worker nodes, but still allows all resources created to interact with the workers. ELBs created would be in the same account as the worker nodes for instance.([#59668](https://github.com/kubernetes/kubernetes/pull/59668), [@brycecarman](https://github.com/brycecarman))
    
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Thu May 05 13:44:43 UTC 2022
    - 341.8K bytes
    - Viewed (0)
  8. 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{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Mar 19 04:37:54 UTC 2024
    - 13.1K bytes
    - Viewed (0)
  9. tensorflow/c/eager/parallel_device/parallel_device_remote_test.cc

          TF_NewStatus(), TF_DeleteStatus);
      std::unique_ptr<TFE_Context, decltype(&TFE_DeleteContext)> context(
          TFE_NewContext(opts.get(), status.get()), TFE_DeleteContext);
      tensorflow::ServerDef server_def = GetServerDef("worker", 3);
    
      // This server def has the task index set to 0.
      std::string serialized = server_def.SerializeAsString();
    
      server_def.set_task_index(1);
      std::unique_ptr<tensorflow::GrpcServer> worker_server1;
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Wed Jul 10 07:18:05 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  10. CHANGELOG/CHANGELOG-1.15.md

        - Windows kube-proxy will wait for HNS network creation on start ([#78612](https://github.com/kubernetes/kubernetes/pull/78612), [@ksubrmnn](https://github.com/ksubrmnn))
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Thu May 05 13:44:43 UTC 2022
    - 278.9K bytes
    - Viewed (0)
Back to top