Sha256: 626d73e85deb05d431a7d7949b2c01e7bb5f61ae63b54930128cc55bdf6ccb0d

Contents?: true

Size: 529 Bytes

Versions: 11

Compression:

Stored size: 529 Bytes

Contents

# encoding: utf-8
module LogStash
  module Outputs
    class S3
      class TimeRotationPolicy
        attr_reader :time_file

        def initialize(time_file)
          if time_file <= 0
            raise LogStash::ConfigurationError, "`time_file` need to be greater than 0"
          end

          @time_file = time_file * 60
        end

        def rotate?(file)
          file.size > 0 && (Time.now - file.ctime) >= time_file
        end

        def needs_periodic?
          true
        end
      end
    end
  end
end

Version data entries

11 entries across 11 versions & 1 rubygems

Version Path
logstash-integration-aws-7.2.1-java lib/logstash/outputs/s3/time_rotation_policy.rb
logstash-integration-aws-7.2.0-java lib/logstash/outputs/s3/time_rotation_policy.rb
logstash-integration-aws-7.1.8-java lib/logstash/outputs/s3/time_rotation_policy.rb
logstash-integration-aws-7.1.7-java lib/logstash/outputs/s3/time_rotation_policy.rb
logstash-integration-aws-7.1.6-java lib/logstash/outputs/s3/time_rotation_policy.rb
logstash-integration-aws-7.1.5-java lib/logstash/outputs/s3/time_rotation_policy.rb
logstash-integration-aws-7.1.4-java lib/logstash/outputs/s3/time_rotation_policy.rb
logstash-integration-aws-7.1.3-java lib/logstash/outputs/s3/time_rotation_policy.rb
logstash-integration-aws-7.1.2-java lib/logstash/outputs/s3/time_rotation_policy.rb
logstash-integration-aws-7.1.1-java lib/logstash/outputs/s3/time_rotation_policy.rb
logstash-integration-aws-7.1.0 lib/logstash/outputs/s3/time_rotation_policy.rb