PROTOBUF_GET_WRAPPED_OR_DEFAULT(zstd, compression_level, ZSTD_CLEVEL_DEFAULT)),

      enable_checksum_(zstd.enable_checksum()), strategy_(zstd.strategy()),

      chunk_size_(PROTOBUF_GET_WRAPPED_OR_DEFAULT(zstd, chunk_size, ZSTD_CStreamOutSize())) {

  if (zstd.has_dictionary()) {

    Protobuf::RepeatedPtrField<envoy::config::core::v3::DataSource> dictionaries;

    dictionaries.Add()->CopyFrom(zstd.dictionary());

    cdict_manager_ = std::make_unique<ZstdCDictManager>(

        dictionaries, dispatcher, api, tls, true,

        [this](const void* dict_buffer, size_t dict_size) -> ZSTD_CDict* {

          return ZSTD_createCDict(dict_buffer, dict_size, compression_level_);

        });

  }

}

Envoy::Compression::Compressor::CompressorPtr ZstdCompressorFactory::createCompressor() {

  return std::make_unique<ZstdCompressorImpl>(compression_level_, enable_checksum_, strategy_,

                                              cdict_manager_, chunk_size_);

}

    Server::Configuration::GenericFactoryContext& context) {

  auto& server_context = context.serverFactoryContext();

  return std::make_unique<ZstdCompressorFactory>(

      proto_config, server_context.mainThreadDispatcher(), server_context.api(),

      server_context.threadLocal());

}