Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 92 for brokers (0.19 sec)

  1. internal/event/target/kafka.go

    	config.Metadata.Retry.Backoff = (1 * time.Second)
    	config.Metadata.RefreshFrequency = (15 * time.Minute)
    
    	target.config = config
    
    	brokers := []string{}
    	for _, broker := range args.Brokers {
    		brokers = append(brokers, broker.String())
    	}
    
    	client, err := sarama.NewClient(brokers, config)
    	if err != nil {
    		if !errors.Is(err, sarama.ErrOutOfBrokers) {
    			target.loggerOnce(context.Background(), err, target.ID().String())
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. internal/config/notify/parse.go

    			return nil, err
    		}
    		if !enabled {
    			continue
    		}
    		var brokers []xnet.Host
    		brokersEnv := target.EnvKafkaBrokers
    		if k != config.Default {
    			brokersEnv = brokersEnv + config.Default + k
    		}
    		kafkaBrokers := env.Get(brokersEnv, kv.Get(target.KafkaBrokers))
    		if len(kafkaBrokers) == 0 {
    			return nil, config.Errorf("kafka 'brokers' cannot be empty")
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 47K bytes
    - Viewed (0)
  5. docs/en/docs/deployment/server-workers.md

    In particular, when running on **Kubernetes** you will probably **not** want to use workers and instead run **a single Uvicorn process per container**, but I'll tell you about it later in that chapter.
    
    ///
    
    ## Multiple Workers
    
    You can start multiple workers with the `--workers` command line option:
    
    //// tab | `fastapi`
    
    If you use the `fastapi` command:
    
    <div class="termy">
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Wed Sep 18 16:09:57 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  6. docs/pt/docs/deployment/server-workers.md

    ///
    
    ## Vários trabalhadores
    
    Você pode iniciar vários trabalhadores com a opção de linha de comando `--workers`:
    
    //// tab | `fastapi`
    
    Se você usar o comando `fastapi`:
    
    <div class="termy">
    
    ```console
    $ <pre> <font color="#4E9A06">fastapi</font> run --workers 4 <u style="text-decoration-style:single">main.py</u>
    <font color="#3465A4">INFO    </font> Using path <font color="#3465A4">main.py</font>
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Fri Sep 20 11:01:03 UTC 2024
    - 9K bytes
    - Viewed (0)
  7. internal/event/target/mqtt.go

    	EnvMQTTQueueLimit        = "MINIO_NOTIFY_MQTT_QUEUE_LIMIT"
    )
    
    // MQTTArgs - MQTT target arguments.
    type MQTTArgs struct {
    	Enable               bool           `json:"enable"`
    	Broker               xnet.URL       `json:"broker"`
    	Topic                string         `json:"topic"`
    	QoS                  byte           `json:"qos"`
    	User                 string         `json:"username"`
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  8. docs/en/docs/deployment/concepts.md

    Here are some possible combinations and strategies:
    
    * **Uvicorn** with `--workers`
        * One Uvicorn **process manager** would listen on the **IP** and **port**, and it would start **multiple Uvicorn worker processes**.
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Wed Sep 18 16:09:57 UTC 2024
    - 17.8K bytes
    - Viewed (0)
  9. cmd/bucket-lifecycle.go

    	es.mu.Lock()
    	defer es.mu.Unlock()
    	var workers []chan expiryOp
    	if v := es.workers.Load(); v != nil {
    		// Copy to new array.
    		workers = append(workers, *v...)
    	}
    
    	if n == len(workers) || n < 1 {
    		return
    	}
    
    	for len(workers) < n {
    		input := make(chan expiryOp, 10000)
    		workers = append(workers, input)
    		go es.Worker(input)
    		es.stats.workers.Add(1)
    	}
    
    	for len(workers) > n {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 23 15:35:37 UTC 2024
    - 33.7K bytes
    - Viewed (0)
  10. cmd/bucket-replication.go

    	if (checkOld > 0 && len(p.workers) != checkOld) || n == len(p.workers) || n < 1 {
    		// Either already satisfied or worker count changed while we waited for the lock.
    		return
    	}
    	for len(p.workers) < n {
    		input := make(chan ReplicationWorkerOperation, 10000)
    		p.workers = append(p.workers, input)
    
    		go p.AddWorker(input, &p.activeWorkers)
    	}
    	for len(p.workers) > n {
    		worker := p.workers[len(p.workers)-1]
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
Back to top