Contents

module Fluent
  class AzureStorageGen2Output
    class GzipCommandCompressor < Compressor
      AzureStorageGen2Output.register_compressor('gzip_command', self)

      config_param :command_parameter, :string, :default => ''

      def configure(conf)
        super
        check_command('gzip')
      end

      def ext
        'gz'.freeze
      end

      def content_type
        'application/x-gzip'.freeze
      end

      def compress(chunk, tmp)
        chunk_is_file = @buffer_type == 'file'
        path = if chunk_is_file
                 chunk.path
               else
                 w = Tempfile.new("chunk-gzip-tmp")
                 chunk.write_to(w)
                 w.close
                 w.path
               end

        res = system "gzip #{@command_parameter} -c #{path} > #{tmp.path}"
        unless res
          log.warn "failed to execute gzip command. Fallback to GzipWriter. status = #{$?}"
          begin
            tmp.truncate(0)
            gw = Zlib::GzipWriter.new(tmp)
            chunk.write_to(gw)
            gw.close
          ensure
            gw.close rescue nil
          end
        end
      ensure
        unless chunk_is_file
          w.close(true) rescue nil
        end
      end
    end
  end
end

Version data entries

7 entries across 7 versions & 1 rubygems

Version	Path
fluent-plugin-azurestorage-gen2-0.2.1	lib/fluent/plugin/azurestorage_gen2_compressor_gzip_command.rb
fluent-plugin-azurestorage-gen2-0.2.0	lib/fluent/plugin/azurestorage_gen2_compressor_gzip_command.rb
fluent-plugin-azurestorage-gen2-0.1.6	lib/fluent/plugin/azurestorage_gen2_compressor_gzip_command.rb
fluent-plugin-azurestorage-gen2-0.1.5	lib/fluent/plugin/azurestorage_gen2_compressor_gzip_command.rb
fluent-plugin-azurestorage-gen2-0.1.4	lib/fluent/plugin/azurestorage_gen2_compressor_gzip_command.rb
fluent-plugin-azurestorage-gen2-0.1.3	lib/fluent/plugin/azurestorage_gen2_compressor_gzip_command.rb
fluent-plugin-azurestorage-gen2-0.1.2	lib/fluent/plugin/azurestorage_gen2_compressor_gzip_command.rb