Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 9 of 9 for tbroyer (0.07 seconds)

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

  1. 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"`
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Sep 06 23:06:30 GMT 2024
    - 8.2K bytes
    - Click Count (0)
  2. docs/bucket/notifications/README.md

    MINIO_NOTIFY_AMQP_COMMENT        (sentence)  optionally add a comment to this setting
    ```
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 84.2K bytes
    - Click Count (0)
  3. internal/config/notify/legacy.go

    		config.KV{
    			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)
  4. 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)
    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)
  5. 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,
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Sep 06 23:06:30 GMT 2024
    - 19.2K bytes
    - Click Count (0)
  6. internal/config/notify/parse.go

    		}
    
    		queueDirEnv := target.EnvMQTTQueueDir
    		if k != config.Default {
    			queueDirEnv = queueDirEnv + config.Default + k
    		}
    
    		mqttArgs := target.MQTTArgs{
    			Enable:               enabled,
    			Broker:               *brokerURL,
    			Topic:                env.Get(topicEnv, kv.Get(target.MqttTopic)),
    			QoS:                  byte(qos),
    			User:                 env.Get(usernameEnv, kv.Get(target.MqttUsername)),
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 47.5K bytes
    - Click Count (0)
  7. okhttp/src/jvmTest/resources/okhttp3/internal/publicsuffix/public_suffix_list.dat

    bridgestone
    
    // broadway : Celebrate Broadway, Inc.
    // https://www.iana.org/domains/root/db/broadway.html
    broadway
    
    // broker : Dog Beach, LLC
    // https://www.iana.org/domains/root/db/broker.html
    broker
    
    // brother : Brother Industries, Ltd.
    // https://www.iana.org/domains/root/db/brother.html
    brother
    
    // brussels : DNS.be vzw
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Fri Dec 27 13:39:56 GMT 2024
    - 309.7K bytes
    - Click Count (1)
  8. okhttp/src/androidMain/assets/PublicSuffixDatabase.list

    bplaced.com
    bplaced.de
    bplaced.net
    br
    br.com
    br.it
    bradesco
    brand.se
    brasilia.me
    bremanger.no
    brescia.it
    bridgestone
    brindisi.it
    broadway
    broke-it.net
    broker
    broker.aero
    bronnoy.no
    bronnoysund.no
    brother
    browsersafetymark.io
    brumunddal.no
    brussels
    bryansk.su
    bryne.no
    brønnøy.no
    brønnøysund.no
    bs
    bs.it
    bsb.br
    bss.design
    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)
  9. cmd/testdata/undeleteable-object.tgz

    ¨CSumAlgo ¨PartNums‘ ©PartETagsÀ©PartSizes‘Ñ$CªPartASizes‘Ñ$C¤SizeÑ$C¥MTimeÓ É ¸Åñ€§MetaSys ¼x-minio-internal-inline-dataÄ true§MetaUsr‚¤etagÙ d6566afb36d109141150¬content-type°application/json¡v ΄‰S ¤nullÅ , fÿ+ÛM¸" x[- Òc‰0Hûð 9Ê(#ñ´{ Dff"},{"key":"broker","value":""},{"key":"topic","value":""},{"key":"password","value":""},{"key":"username","value":""},{"key":"qos","value":"0"},{"key":"keep_alive_interval","value":"0s"},{"key":"reconnect_interval","value":"0s"},{"key":"queue_dir","value":""},{"ke...
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Apr 26 00:31:12 GMT 2024
    - 8.7M bytes
    - Click Count (0)
Back to Top