Sha256: f55d0b33d2834e8b8d28e955e81f7df389a27ac22cb4e1424085c23750c3ecfe

Contents?: true

Size: 498 Bytes

Versions: 10

Compression:

Stored size: 498 Bytes

Contents

require 'adrian/directory_queue'
require 'fileutils'

module Adrian

  class RotatingDirectoryQueue < DirectoryQueue
    attr_reader :time_format

    def initialize(options = {})
      super
      @time_format = options.fetch(:time_format, '%Y-%m-%d')
    end

    def available_path
      path = "#{super}/#{Time.now.strftime(time_format)}"

      if path != @previous_avaliable_path
        FileUtils.mkdir_p(path)
        @previous_avaliable_path = path
      end

      path
    end
  end
end

Version data entries

10 entries across 10 versions & 1 rubygems

Version Path
adrian-2.0.2 lib/adrian/rotating_directory_queue.rb
adrian-2.0.1 lib/adrian/rotating_directory_queue.rb
adrian-2.0.0 lib/adrian/rotating_directory_queue.rb
adrian-1.5.0 lib/adrian/rotating_directory_queue.rb
adrian-1.4.0 lib/adrian/rotating_directory_queue.rb
adrian-1.3.3 lib/adrian/rotating_directory_queue.rb
adrian-1.3.2 lib/adrian/rotating_directory_queue.rb
adrian-1.3.1 lib/adrian/rotating_directory_queue.rb
adrian-1.3.0 lib/adrian/rotating_directory_queue.rb
adrian-1.2.0 lib/adrian/rotating_directory_queue.rb