- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for compression_level (0.44 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 {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Jun 01 15:02:59 UTC 2024 - 13.1K bytes - Viewed (0) -
src/compress/flate/deflate.go
hashSize = 1 << hashBits hashMask = (1 << hashBits) - 1 maxHashOffset = 1 << 24 skipNever = math.MaxInt32 ) type compressionLevel struct { level, good, lazy, nice, chain, fastSkipHashing int } var levels = []compressionLevel{ {0, 0, 0, 0, 0, 0}, // NoCompression. {1, 0, 0, 0, 0, 0}, // BestSpeed uses a custom algorithm; see deflatefast.go.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 13:32:40 UTC 2024 - 20.3K bytes - Viewed (0) -
cmd/kms-router.go
kmsAPI := kmsAPIHandlers{} kmsRouter := router.PathPrefix(kmsPathPrefix).Subrouter() KMSVersions := []string{ kmsAPIVersionPrefix, } 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") } for _, version := range KMSVersions { // KMS Status APIs
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue May 07 23:55:37 UTC 2024 - 2.7K bytes - Viewed (0) -
cmd/testdata/undeleteable-object.tgz
"key":"tls","value":"off"},{"key":"tls_skip_verify","value":"off"},{"key":"queue_limit","value":"0"},{"key":"queue_dir","value":""},{"key":"version","value":""},{"key":"batch_size","value":"0"},{"key":"compression_codec","value":""},{"key":"compression_level","value":""}]},"notify_mqtt":{"_":[{"key":"enable","value":"o multisitea/data/disterasure/xl9/.minio.sys/pool.bin/xl.meta XL2 Æ w Ä$•Ä Ó ÉŸþ¥¹ °Ä ºHØH Å Kƒ¤Type ¥V2ObjÞ ¢IDÄ ¤DDirÄ 5 A·DoCÁ§slÂ0RÿŦEcAlgo £EcM £EcN §EcBSizeÒ §EcIndex ¦EcDistœ...
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Apr 26 00:31:12 UTC 2024 - 8.7M 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 }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 46.4K bytes - Viewed (0)