createEncoderFor() — netty Function Reference

Architecture documentation for the createEncoderFor() function in HttpContentCompressor.java from the netty codebase.

Function java ProtocolCodecs HTTP called by 1

Entity Profile

ProtocolCodecs→ HTTP→ createEncoderFor() — netty Function Reference

Dependency Diagram

graph TD
  93c84887_466a_4f4a_7fbd_608fea920e34["createEncoderFor()"]
  1a373d52_2146_2610_7650_6b487cdcefae["HttpContentCompressor"]
  93c84887_466a_4f4a_7fbd_608fea920e34 -->|defined in| 1a373d52_2146_2610_7650_6b487cdcefae
  058c003d_0fca_6751_f708_16e9fee143d4["Result()"]
  058c003d_0fca_6751_f708_16e9fee143d4 -->|calls| 93c84887_466a_4f4a_7fbd_608fea920e34
  style 93c84887_466a_4f4a_7fbd_608fea920e34 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-http/src/main/java/io/netty/handler/codec/http/HttpContentCompressor.java lines 282–326

    private MessageToByteEncoder<ByteBuf> createEncoderFor(String targetContentEncoding) {
        switch (targetContentEncoding) {
            case "br":
                if (brotliOptions == null || !Brotli.isAvailable()) {
                    throw new IllegalStateException("Brotli not configured");
                }
                return new BrotliEncoder(brotliOptions.parameters());
            case "zstd":
                if (zstdOptions == null) {
                    throw new IllegalStateException("Zstd not configured");
                }
                return new ZstdEncoder(
                        zstdOptions.compressionLevel(),
                        zstdOptions.blockSize(),
                        zstdOptions.maxEncodeSize()
                );
            case "snappy":
                if (snappyOptions == null) {
                    throw new IllegalStateException("Snappy not configured");
                }
                return new SnappyFrameEncoder();
            case "gzip":
                if (gzipOptions == null) {
                    throw new IllegalStateException("Gzip not configured");
                }
                return ZlibCodecFactory.newZlibEncoder(
                        ZlibWrapper.GZIP,
                        gzipOptions.compressionLevel(),
                        gzipOptions.windowBits(),
                        gzipOptions.memLevel()
                );
            case "deflate":
                if (deflateOptions == null) {
                    throw new IllegalStateException("Deflate not configured");
                }
                return ZlibCodecFactory.newZlibEncoder(
                        ZlibWrapper.ZLIB,
                        deflateOptions.compressionLevel(),
                        deflateOptions.windowBits(),
                        deflateOptions.memLevel()
                );
            default:
                throw new IllegalStateException("Unknown encoding: " + targetContentEncoding);
        }
    }