- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for CompressionLevel (0.18 sec)
-
internal/event/target/kafka.go
Password string `json:"password"` Mechanism string `json:"mechanism"` } `json:"sasl"` Producer struct { Compression string `json:"compression"` CompressionLevel int `json:"compressionLevel"` } `json:"producer"` } // Validate KafkaArgs fields func (k KafkaArgs) Validate() error { if !k.Enable { return nil } if len(k.Brokers) == 0 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 20 08:16:35 GMT 2024 - 13K bytes - Viewed (0) -
api/go1.4.txt
pkg image/png, const BestCompression = -3 pkg image/png, const BestCompression CompressionLevel pkg image/png, const BestSpeed = -2 pkg image/png, const BestSpeed CompressionLevel pkg image/png, const DefaultCompression = 0 pkg image/png, const DefaultCompression CompressionLevel pkg image/png, const NoCompression = -1 pkg image/png, const NoCompression CompressionLevel pkg image/png, method (*Encoder) Encode(io.Writer, image.Image) error
Plain Text - Registered: Tue May 07 11:14:38 GMT 2024 - Last Modified: Fri Dec 12 03:01:01 GMT 2014 - 34K bytes - Viewed (0) -
internal/config/notify/legacy.go
}, config.KV{ Key: target.KafkaCompressionCodec, Value: cfg.Producer.Compression, }, config.KV{ Key: target.KafkaCompressionLevel, Value: strconv.Itoa(cfg.Producer.CompressionLevel), }, } return nil } // SetNotifyAMQP - helper for config migration from older config. func SetNotifyAMQP(s config.Config, amqpName string, cfg target.AMQPArgs) error { if !cfg.Enable {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 19 04:37:54 GMT 2024 - 13.1K bytes - Viewed (0) -
internal/config/notify/parse.go
if k != config.Default { compressionLevelEnv = compressionLevelEnv + config.Default + k } compressionLevel, _ := strconv.Atoi(env.Get(compressionLevelEnv, kv.Get(target.KafkaCompressionLevel))) kafkaArgs.Producer.CompressionLevel = compressionLevel saslEnableEnv := target.EnvKafkaSASLEnable if k != config.Default { saslEnableEnv = saslEnableEnv + config.Default + k }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 46.4K bytes - Viewed (0) -
cmd/admin-router.go
adminAPIClientDevExtraTime = "/speedtest/client/devnull/extratime" ) var gzipHandler = func() func(http.Handler) http.HandlerFunc { gz, err := gzhttp.NewWrapper(gzhttp.MinSize(1000), gzhttp.CompressionLevel(gzip.BestSpeed)) if err != nil { // Static params, so this is very unlikely. logger.Fatal(err, "Unable to initialize server") } return gz }() // Set of handler options as bit flags
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 10 21:09:36 GMT 2024 - 25.5K bytes - Viewed (0)