Module: Jiggler

Defined in:
lib/jiggler/core.rb,
lib/jiggler/cli.rb,
lib/jiggler/job.rb,
lib/jiggler/web.rb,
lib/jiggler/config.rb,
lib/jiggler/errors.rb,
lib/jiggler/worker.rb,
lib/jiggler/cleaner.rb,
lib/jiggler/manager.rb,
lib/jiggler/retrier.rb,
lib/jiggler/summary.rb,
lib/jiggler/version.rb,
lib/jiggler/launcher.rb,
lib/jiggler/redis_store.rb,
lib/jiggler/redis_store.rb,
lib/jiggler/base_fetcher.rb,
lib/jiggler/stats/monitor.rb,
lib/jiggler/support/helper.rb,
lib/jiggler/scheduled/poller.rb,
lib/jiggler/stats/collection.rb,
lib/jiggler/base_acknowledger.rb,
lib/jiggler/scheduled/enqueuer.rb,
lib/jiggler/scheduled/requeuer.rb,
lib/jiggler/at_most_once/fetcher.rb,
lib/jiggler/at_least_once/fetcher.rb,
lib/jiggler/at_most_once/acknowledger.rb,
lib/jiggler/at_least_once/acknowledger.rb

Overview

The Poller checks Redis every N seconds for jobs in the retry or scheduled set have passed their timestamp and should be enqueued.

Defined Under Namespace

Modules: AtLeastOnce, AtMostOnce, Job, Scheduled, Stats, Support Classes: BaseAcknowledger, BaseFetcher, CLI, Cleaner, Config, Launcher, Manager, RedisClient, RedisStore, Retrier, Summary, UnknownJobError, Web, Worker

Constant Summary collapse

VERSION =
'0.1.0'

Class Method Summary collapse

Class Method Details

.configObject



8
9
10
# File 'lib/jiggler/core.rb', line 8

def self.config
  @config ||= Jiggler::Config.new
end

.configure(&block) ⇒ Object



16
17
18
# File 'lib/jiggler/core.rb', line 16

def self.configure(&block)
  block.call(config)
end

.loggerObject



12
13
14
# File 'lib/jiggler/core.rb', line 12

def self.logger
  config.logger
end

.summaryObject



20
21
22
# File 'lib/jiggler/core.rb', line 20

def self.summary
  config.summary.all
end