Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 527 for broken (0.13 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 Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  2. internal/event/target/mqtt.go

    		SetKeepAlive(args.KeepAlive).
    		SetTLSConfig(&tls.Config{RootCAs: args.RootCAs}).
    		AddBroker(args.Broker.String())
    
    	target.client = mqtt.NewClient(options)
    
    	token := target.client.Connect()
    	ok := token.WaitTimeout(reconnectInterval)
    	if !ok {
    		return store.ErrNotConnected
    	}
    	if token.Error() != nil {
    		return token.Error()
    	}
    
    	yes, err := target.isActive()
    	if err != nil {
    		return err
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  3. 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 Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  4. internal/logger/help.go

    			Optional:    true,
    			Type:        "sentence",
    		},
    	}
    
    	HelpKafka = config.HelpKVS{
    		config.HelpKV{
    			Key:         KafkaBrokers,
    			Description: "comma separated list of Kafka broker addresses",
    			Type:        "csv",
    		},
    		config.HelpKV{
    			Key:         KafkaTopic,
    			Description: "Kafka topic used for bucket notifications",
    			Optional:    true,
    			Type:        "string",
    		},
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Sep 11 22:20:42 UTC 2024
    - 7.4K bytes
    - Viewed (0)
  5. doc/go_spec.html

    a number of productions. Go programs may omit most of these semicolons
    using the following two rules:
    </p>
    
    <ol>
    <li>
    When the input is broken into tokens, a semicolon is automatically inserted
    into the token stream immediately after a line's final token if that token is
    <ul>
    	<li>an
    	    <a href="#Identifiers">identifier</a>
    	</li>
    
    	<li>an
    	    <a href="#Integer_literals">integer</a>,
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Wed Oct 02 00:58:01 UTC 2024
    - 282.5K bytes
    - Viewed (1)
  6. internal/config/notify/help.go

    			Optional:    true,
    			Type:        "on|off",
    		},
    		config.HelpKV{
    			Key:         target.AmqpDurable,
    			Description: "persist queue across broker restarts when set to 'on', default is 'off'",
    			Optional:    true,
    			Type:        "on|off",
    		},
    		config.HelpKV{
    			Key:         target.AmqpNoWait,
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 19.2K bytes
    - Viewed (0)
  7. 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 Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 47K bytes
    - Viewed (0)
  8. tests/test_tutorial/test_bigger_applications/test_main.py

        response = client.put(
            "/items/bar?token=jessica", headers={"X-Token": "fake-super-secret-token"}
        )
        assert response.status_code == 403, response.text
        assert response.json() == {"detail": "You can only update the item: plumbus"}
    
    
    def test_admin(client: TestClient):
        response = client.post(
            "/admin/?token=jessica", headers={"X-Token": "fake-super-secret-token"}
        )
    Registered: Sun Oct 27 07:19:11 UTC 2024
    - Last Modified: Thu Apr 18 19:40:57 UTC 2024
    - 24.6K bytes
    - Viewed (0)
  9. tests/test_tutorial/test_websockets/test_tutorial002_an_py310.py

        with pytest.raises(WebSocketDisconnect):
            with client.websocket_connect("/items/bar/ws?token=some-token") as websocket:
                message = "Message one"
                websocket.send_text(message)
                data = websocket.receive_text()
                assert data == "Session cookie or query token value is: some-token"
                data = websocket.receive_text()
    Registered: Sun Oct 27 07:19:11 UTC 2024
    - Last Modified: Sat Mar 18 12:29:59 UTC 2023
    - 3.9K bytes
    - Viewed (0)
  10. tests/test_tutorial/test_bigger_applications/test_main_an.py

        response = client.put(
            "/items/bar?token=jessica", headers={"X-Token": "fake-super-secret-token"}
        )
        assert response.status_code == 403, response.text
        assert response.json() == {"detail": "You can only update the item: plumbus"}
    
    
    def test_admin(client: TestClient):
        response = client.post(
            "/admin/?token=jessica", headers={"X-Token": "fake-super-secret-token"}
        )
    Registered: Sun Oct 27 07:19:11 UTC 2024
    - Last Modified: Thu Apr 18 19:40:57 UTC 2024
    - 24.6K bytes
    - Viewed (0)
Back to top