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