Module: Reqless

Defined in:: lib/reqless.rb,
lib/reqless.rb,
lib/reqless/job.rb,
lib/reqless/queue.rb,
lib/reqless/config.rb,
lib/reqless/server.rb,
lib/reqless/version.rb,
lib/reqless/throttle.rb,
lib/reqless/lua_script.rb,
lib/reqless/subscriber.rb,
lib/reqless/worker/base.rb,
lib/reqless/worker/serial.rb,
lib/reqless/worker/forking.rb,
lib/reqless/failure_formatter.rb,
lib/reqless/middleware/sentry.rb,
lib/reqless/middleware/timeout.rb,
lib/reqless/job_reservers/ordered.rb,
lib/reqless/queue_patterns_helper.rb,
lib/reqless/queue_priority_pattern.rb,
lib/reqless/job_reservers/round_robin.rb,
lib/reqless/middleware/retry_exceptions.rb,
lib/reqless/test_helpers/worker_helpers.rb,
lib/reqless/middleware/requeue_exceptions.rb,
lib/reqless/job_reservers/strategies/sources.rb,
lib/reqless/job_reservers/strategies/ordering.rb,
lib/reqless/job_reservers/shuffled_round_robin.rb,
lib/reqless/job_reservers/strategies/filtering.rb

Defined Under Namespace

Modules: JobReservers, Middleware, QueuePatternsHelper, RetryExceptions, WorkerHelpers, Workers Classes: BaseJob, Client, ClientEvents, ClientJobs, ClientQueuePatterns, ClientQueues, ClientThrottles, ClientWorkers, Config, FailureFormatter, Job, LuaPlugin, LuaScript, Queue, QueueJobs, QueuePriorityPattern, RecurringJob, Server, Subscriber, Throttle

Constant Summary collapse

Error = Define our error base class before requiring the other files so they can define subclasses.

Class.new(StandardError)

UnsupportedRedisVersionError =

Class.new(Error)

VERSION = VERSION is overwritten dynamically as part of the release process.

'0.0.5'

LuaScriptError =

Class.new(Reqless::Error)

JobTimedoutError = Unique error class used when a job is timed out by this middleware. Allows us to differentiate this timeout from others caused by ‘::Timeout::Erorr`

Class.new(StandardError)

InvalidTimeoutError =

Class.new(ArgumentError)

Class Method Summary collapse

Class Method Details

.failure_formatter ⇒ `Object`



36
37
38

# File 'lib/reqless.rb', line 36

def failure_formatter
  @failure_formatter ||= FailureFormatter.new
end

.generate_jid ⇒ `Object`



26
27
28

# File 'lib/reqless.rb', line 26

def generate_jid
  SecureRandom.uuid.gsub('-', '')
end

.stringify_hash_keys(hash) ⇒ `Object`

# File 'lib/reqless.rb', line 30

def stringify_hash_keys(hash)
  hash.each_with_object({}) do |(key, value), result|
    result[key.to_s] = value
  end
end