Sha256: bb9bc77ceb1287e8d7b1ba1d185eec05ccdae1eae2fcc9ba33c483801ce9590d

Contents?: true

Size: 576 Bytes

Versions: 4

Compression:

Stored size: 576 Bytes

Contents

# frozen_string_literal: true

module Wayfarer
  class Task
    include Stringify

    attr_reader :url,
                :batch,
                :metadata

    attr_accessor :job

    stringify :url,
              :batch

    def initialize(url, batch)
      @url = url
      @batch = batch
      @metadata = OpenStruct.new
    end

    def ==(other)
      [url, batch] == [other.url, other.batch]
    end

    def barrier
      @barrier ||= Wayfarer::Redis::Barrier.new(batch)
    end

    def counter
      @counter ||= Wayfarer::Redis::Counter.new(batch)
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version Path
wayfarer-0.4.3 lib/wayfarer/task.rb
wayfarer-0.4.2 lib/wayfarer/task.rb
wayfarer-0.4.1 lib/wayfarer/task.rb
wayfarer-0.4.0 lib/wayfarer/task.rb