- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 41 for compression (0.24 sec)
-
internal/event/target/kafka.go
config.Producer.Return.Errors = true config.Producer.RequiredAcks = 1 config.Producer.Timeout = (5 * time.Second) // Set Producer Compression cc, ok := codecs[strings.ToLower(args.Producer.Compression)] if ok { config.Producer.Compression = cc config.Producer.CompressionLevel = args.Producer.CompressionLevel } config.Net.ReadTimeout = (5 * time.Second)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 20 08:16:35 GMT 2024 - 13K bytes - Viewed (0) -
cmd/object-multipart-handlers.go
return } _, isEncrypted := crypto.IsEncrypted(mi.UserDefined) // Read compression metadata preserved in the init multipart for the decision. _, isCompressed := mi.UserDefined[ReservedMetadataPrefix+"compression"] // Compress only if the compression is enabled during initial multipart. var idxCb func() []byte if isCompressed {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 17:44:56 GMT 2024 - 39K bytes - Viewed (0) -
internal/crypto/error.go
// ErrIncompatibleEncryptionWithCompression indicates that both data compression and SSE-C not allowed at the same time ErrIncompatibleEncryptionWithCompression = Errorf("Server side encryption specified with SSE-C with compression not allowed") // ErrInvalidEncryptionKeyID returns error when KMS key id contains invalid characters
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 17:44:56 GMT 2024 - 4.4K bytes - Viewed (0) -
internal/config/compress/compress.go
MimeTypes = "mime_types" EnvCompressState = "MINIO_COMPRESSION_ENABLE" EnvCompressAllowEncryption = "MINIO_COMPRESSION_ALLOW_ENCRYPTION" EnvCompressExtensions = "MINIO_COMPRESSION_EXTENSIONS" EnvCompressMimeTypes = "MINIO_COMPRESSION_MIME_TYPES" // Include-list for compression. DefaultExtensions = ".txt,.log,.csv,.json,.tar,.xml,.bin" DefaultMimeTypes = "text/*,application/json,application/xml,binary/octet-stream" )
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 04 19:57:37 GMT 2023 - 5K bytes - Viewed (0) -
cmd/globals.go
// into an SSE-S3 request. If enabled a valid, non-empty KMS // configuration must be present. globalAutoEncryption bool // Is compression enabled? globalCompressConfigMu sync.Mutex globalCompressConfig compress.Config // Some standard object extensions which we strictly dis-allow for compression. standardExcludeCompressExtensions = []string{".gz", ".bz2", ".rar", ".zip", ".7z", ".xz", ".mp4", ".mkv", ".mov", ".jpg", ".png", ".gif"}
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 16.5K bytes - Viewed (0) -
internal/s3select/select.go
parsedType = noneType } switch parsedType { case noneType, gzipType, bzip2Type, snappyType, s2Type, zstdType, lz4Type: default: return errInvalidCompressionFormat(fmt.Errorf("invalid compression format '%v'", s)) } *c = parsedType return nil } // InputSerialization - represents elements inside <InputSerialization/> in request XML. type InputSerialization struct {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 06 22:26:08 GMT 2023 - 21K bytes - Viewed (0) -
cmd/object-api-utils.go
func (o *ObjectInfo) IsCompressed() bool { _, ok := o.UserDefined[ReservedMetadataPrefix+"compression"] return ok } // IsCompressedOK returns whether the object is compressed and can be decompressed. func (o *ObjectInfo) IsCompressedOK() (bool, error) { scheme, ok := o.UserDefined[ReservedMetadataPrefix+"compression"] if !ok { return false, nil } switch scheme {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 11 11:55:34 GMT 2024 - 35.6K bytes - Viewed (1) -
cmd/object-handlers.go
// Storing the compression metadata. metadata[ReservedMetadataPrefix+"compression"] = compressionAlgorithmV2 metadata[ReservedMetadataPrefix+"actual-size"] = strconv.FormatInt(size, 10) actualReader, err := hash.NewReader(ctx, reader, size, "", "", actualSize) if err != nil { return err } // Set compression metrics. wantEncryption := crypto.Requested(r.Header)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 20:15:54 GMT 2024 - 125.2K bytes - Viewed (0) -
internal/s3select/errors.go
statusCode: 400, cause: err, } } func errInvalidCompressionFormat(err error) *s3Error { return &s3Error{ code: "InvalidCompressionFormat", message: "The file is not in a supported compression format. GZIP, BZIP2, ZSTD, LZ4, S2 and SNAPPY are supported.", statusCode: 400, cause: err, } } func errInvalidCompression(err error, t CompressionType) *s3Error { return &s3Error{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 14 16:48:36 GMT 2022 - 4.3K bytes - Viewed (0) -
internal/http/transports.go
// // if a response to Ping is not received. // trhttp2.PingTimeout = dialTimeout // // DisableCompression, if true, prevents the Transport from // // requesting compression with an "Accept-Encoding: gzip" // trhttp2.DisableCompression = true // } // } return tr } // NewInternodeHTTPTransport returns transport for internode MinIO connections.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 5.9K bytes - Viewed (0)