module Upperkut::Worker::ClassMethods

Public Instance Methods

fetch_items() click to toggle source
# File lib/upperkut/worker.rb, line 24
def fetch_items
  strategy.fetch_items
end
push_items(items) click to toggle source
# File lib/upperkut/worker.rb, line 18
def push_items(items)
  client_middlewares.invoke(self, items) do
    strategy.push_items(items)
  end
end
setup() click to toggle source
# File lib/upperkut/worker.rb, line 32
def setup
  @config ||=
    begin
      config = Upperkut::Configuration.default.clone
      config.strategy ||= Upperkut::Strategies::BufferedQueue.new(self)
      config
    end
end
setup_upperkut() { |setup| ... } click to toggle source
# File lib/upperkut/worker.rb, line 28
def setup_upperkut
  yield(setup) if block_given?
end