kcenon::network::utils::compression_pipeline::impl Class Reference

Collaboration diagram for kcenon::network::utils::compression_pipeline::impl:

Public Member Functions
	impl (compression_algorithm algo, size_t threshold)
auto	compress (std::span< const uint8_t > input) -> Result< std::vector< uint8_t > >
auto	decompress (std::span< const uint8_t > input) -> Result< std::vector< uint8_t > >
auto	set_compression_threshold (size_t bytes) -> void
auto	get_compression_threshold () const -> size_t
auto	get_algorithm () const -> compression_algorithm

Private Attributes
compression_algorithm	algorithm_
size_t	compression_threshold_

Detailed Description

Definition at line 22 of file compression_pipeline.cpp.

Constructor & Destructor Documentation

impl()

kcenon::network::utils::compression_pipeline::impl::impl ( compression_algorithm algo, size_t threshold )

inlineexplicit

Definition at line 25 of file compression_pipeline.cpp.

            : algorithm_(algo), compression_threshold_(threshold)
        {
            NETWORK_LOG_DEBUG("[compression_pipeline] Created with algorithm=" +
                              std::to_string(static_cast<int>(algo)) +
                              ", threshold=" + std::to_string(threshold));
        }

References NETWORK_LOG_DEBUG.

Member Function Documentation

compress()

auto kcenon::network::utils::compression_pipeline::impl::compress ( std::span< const uint8_t > input ) -> Result<std::vector<uint8_t>>

inline

Definition at line 33 of file compression_pipeline.cpp.

        {
            // If below threshold, return uncompressed
            if (input.size() < compression_threshold_)
            {
                NETWORK_LOG_TRACE("[compression_pipeline] Size below threshold, skipping compression");
                std::vector<uint8_t> result(input.begin(), input.end());
                return ok<std::vector<uint8_t>>(std::move(result));
            }
 
            if (algorithm_ == compression_algorithm::none)
            {
                std::vector<uint8_t> result(input.begin(), input.end());
                return ok<std::vector<uint8_t>>(std::move(result));
            }
 
#ifdef BUILD_LZ4_COMPRESSION
            if (algorithm_ == compression_algorithm::lz4)
            {
                return compress_lz4(input);
            }
#endif
 
#ifdef BUILD_ZLIB_COMPRESSION
            if (algorithm_ == compression_algorithm::gzip)
            {
                return compress_gzip(input);
            }
            if (algorithm_ == compression_algorithm::deflate)
            {
                return compress_deflate(input);
            }
#endif
 
            // Fallback: return uncompressed if algorithm not available
            NETWORK_LOG_WARN("[compression_pipeline] Compression algorithm not available, returning uncompressed");
            std::vector<uint8_t> result(input.begin(), input.end());
            return ok<std::vector<uint8_t>>(std::move(result));
        }

References algorithm_, compression_threshold_, kcenon::network::utils::deflate, kcenon::network::utils::gzip, kcenon::network::utils::lz4, NETWORK_LOG_TRACE, NETWORK_LOG_WARN, and kcenon::network::utils::none.

decompress()

auto kcenon::network::utils::compression_pipeline::impl::decompress ( std::span< const uint8_t > input ) -> Result<std::vector<uint8_t>>

inline

Definition at line 73 of file compression_pipeline.cpp.

        {
            if (input.empty())
            {
                return error<std::vector<uint8_t>>(
                    error_codes::common_errors::invalid_argument,
                    "Input data is empty");
            }
 
            if (algorithm_ == compression_algorithm::none)
            {
                std::vector<uint8_t> result(input.begin(), input.end());
                return ok<std::vector<uint8_t>>(std::move(result));
            }
 
#ifdef BUILD_LZ4_COMPRESSION
            if (algorithm_ == compression_algorithm::lz4)
            {
                return decompress_lz4(input);
            }
#endif
 
#ifdef BUILD_ZLIB_COMPRESSION
            if (algorithm_ == compression_algorithm::gzip)
            {
                return decompress_gzip(input);
            }
            if (algorithm_ == compression_algorithm::deflate)
            {
                return decompress_deflate(input);
            }
#endif
 
            // Fallback: assume uncompressed
            NETWORK_LOG_WARN("[compression_pipeline] Decompression algorithm not available, returning as-is");
            std::vector<uint8_t> result(input.begin(), input.end());
            return ok<std::vector<uint8_t>>(std::move(result));
        }

References algorithm_, kcenon::network::utils::deflate, kcenon::network::error, kcenon::network::utils::gzip, kcenon::network::error_codes::common_errors::invalid_argument, kcenon::network::utils::lz4, NETWORK_LOG_WARN, and kcenon::network::utils::none.

get_algorithm()

auto kcenon::network::utils::compression_pipeline::impl::get_algorithm ( ) const -> compression_algorithm

inline

Definition at line 120 of file compression_pipeline.cpp.

{ return algorithm_; }

References algorithm_.

Referenced by kcenon::network::utils::compression_pipeline::get_algorithm().

Here is the caller graph for this function:

get_compression_threshold()

auto kcenon::network::utils::compression_pipeline::impl::get_compression_threshold ( ) const -> size_t

inline

Definition at line 118 of file compression_pipeline.cpp.

{ return compression_threshold_; }

References compression_threshold_.

Referenced by kcenon::network::utils::compression_pipeline::get_compression_threshold().

Here is the caller graph for this function:

set_compression_threshold()

auto kcenon::network::utils::compression_pipeline::impl::set_compression_threshold ( size_t bytes ) -> void

inline

Definition at line 112 of file compression_pipeline.cpp.

        {
            compression_threshold_ = bytes;
            NETWORK_LOG_DEBUG("[compression_pipeline] Set threshold=" + std::to_string(bytes));
        }

References compression_threshold_, and NETWORK_LOG_DEBUG.

Member Data Documentation

algorithm_

compression_algorithm kcenon::network::utils::compression_pipeline::impl::algorithm_

private

Definition at line 444 of file compression_pipeline.cpp.

Referenced by compress(), decompress(), and get_algorithm().

compression_threshold_

size_t kcenon::network::utils::compression_pipeline::impl::compression_threshold_

private

Definition at line 445 of file compression_pipeline.cpp.

Referenced by compress(), get_compression_threshold(), and set_compression_threshold().

---

The documentation for this class was generated from the following file:

• src/internal/utils/compression_pipeline.cpp