Module: Sidekiq

Defined in:
lib/wurk/compat.rb,
lib/wurk/active_job/wrapper.rb

Overview

Defined under the ‘Sidekiq::ActiveJob` namespace (not `Wurk::ActiveJob`) so the canonical `class` string written to Redis stays `“Sidekiq::ActiveJob::Wrapper”` — the exact wire shape Sidekiq emits. Mixed Sidekiq/Wurk worker pools can read the same payloads either way. Wire-compat is sacred.

‘Wurk::ActiveJob::Wrapper` and `ActiveJob::QueueAdapters::SidekiqAdapter::JobWrapper` both resolve here so legacy enqueued payloads load on the gem swap.

Spec: docs/target/sidekiq-free.md §28.

Defined Under Namespace

Modules: ActiveJob, Enterprise, Pro

Constant Summary collapse

NAME =

Version stamps mirror Sidekiq’s OSS release Wurk targets for compat. Third-party gems version-gate on these; raise the MAJOR only when the upstream Sidekiq major bumps and Wurk has matching surface.

'Sidekiq'
LICENSE = 
'See LICENSE'
VERSION = 
'8.1.5'
MAJOR = 
8
BasicFetch = 
Wurk::Fetcher::Reliable
Batch = 
Wurk::Batch
BatchSet = 
Wurk::BatchSet
Capsule = 
Wurk::Capsule
CLI = 
Wurk::CLI
Client = 
Wurk::Client
Component = 
Wurk::Component
Config = 
Wurk::Configuration
Context = 
Wurk::Context
Cron = 
Wurk::Cron
Periodic = 
Wurk::Cron
DeadSet = 
Wurk::DeadSet
Deploy = 
Wurk::Deploy
Embedded = 
Wurk::Embedded
Encryption = 
Wurk::Encryption
IterableJob = 
Wurk::IterableJob
Job = 
Wurk::Job
JobLogger = 
Wurk::JobLogger
JobRecord = 
Wurk::JobRecord
JobRetry = 
Wurk::JobRetry
JobUtil = 
Wurk::JobUtil
Keys = 
Wurk::Keys
Launcher = 
Wurk::Launcher
Limiter = 
Wurk::Limiter
Logger = 
Wurk::Logger
Manager = 
Wurk::Manager
Metrics = 
Wurk::Metrics
Middleware = 
Wurk::Middleware
ServerMiddleware = 
Wurk::Middleware::ServerMiddleware
ClientMiddleware = 
Wurk::Middleware::ClientMiddleware
Process = 
Wurk::Process
ProcessSet = 
Wurk::ProcessSet
Processor = 
Wurk::Processor
Queue = 
Wurk::Queue
RetrySet = 
Wurk::RetrySet
Scheduled = 
Wurk::Scheduled
ScheduledSet = 
Wurk::ScheduledSet
Shutdown = 
Wurk::Shutdown
Stats = 
Wurk::Stats
Testing = 
Wurk::Testing
Queues = 
Wurk::Queues
EmptyQueueError = 
Wurk::Testing::EmptyQueueError
Web = 
Wurk::Web
Work = 
Wurk::Work
Worker = 
Wurk::Worker
Workers = 
Wurk::Workers
WorkSet = 
Wurk::WorkSet

Class Method Summary collapse

Class Method Details

.configure_client ⇒ Object 



115
 
# File 'lib/wurk/compat.rb', line 115

def configure_client(&) = Wurk.configure_client(&)

.configure_embed ⇒ Object 



116
 
# File 'lib/wurk/compat.rb', line 116

def configure_embed(&) = Wurk.configure_embed(&)

.configure_server ⇒ Object 



114
 
# File 'lib/wurk/compat.rb', line 114

def configure_server(&) = Wurk.configure_server(&)

.default_configuration ⇒ Object 



117
 
# File 'lib/wurk/compat.rb', line 117

def default_configuration = Wurk.default_configuration

.default_job_options ⇒ Object 



124
 
# File 'lib/wurk/compat.rb', line 124

def default_job_options = Wurk.default_job_options

.default_job_options=(hash) ⇒ Object 



126
127
128
 
# File 'lib/wurk/compat.rb', line 126

def default_job_options=(hash)
  Wurk.default_job_options = hash
end

.dump_json(obj) ⇒ Object 



134
 
# File 'lib/wurk/compat.rb', line 134

def dump_json(obj) = Wurk.dump_json(obj)

.ent? ⇒ Boolean

Returns:

  • (Boolean) 


123
 
# File 'lib/wurk/compat.rb', line 123

def ent? = Wurk.ent?

.load_json(str) ⇒ Object 



133
 
# File 'lib/wurk/compat.rb', line 133

def load_json(str) = Wurk.load_json(str)

.logger ⇒ Object 



120
 
# File 'lib/wurk/compat.rb', line 120

def logger = Wurk.logger

.pro? ⇒ Boolean

Returns:

  • (Boolean) 


122
 
# File 'lib/wurk/compat.rb', line 122

def pro? = Wurk.pro?

.redis ⇒ Object 



118
 
# File 'lib/wurk/compat.rb', line 118

def redis(&) = Wurk.redis(&)

.redis_pool ⇒ Object 



119
 
# File 'lib/wurk/compat.rb', line 119

def redis_pool = Wurk.redis_pool

.server? ⇒ Boolean

Returns:

  • (Boolean) 


121
 
# File 'lib/wurk/compat.rb', line 121

def server? = Wurk.server?

.strict_args!(mode = :raise) ⇒ Object 



130
 
# File 'lib/wurk/compat.rb', line 130

def strict_args!(mode = :raise) = Wurk.strict_args!(mode)

.testing!(mode = :fake) ⇒ Object 



131
 
# File 'lib/wurk/compat.rb', line 131

def testing!(mode = :fake, &) = Wurk.testing!(mode, &)

.testing? ⇒ Boolean

Returns:

  • (Boolean) 


132
 
# File 'lib/wurk/compat.rb', line 132

def testing? = Wurk.testing?