Module: CDC::Sidekiq

Defined in:
lib/cdc/sidekiq.rb,
lib/cdc/sidekiq/errors.rb,
lib/cdc/sidekiq/runtime.rb,
lib/cdc/sidekiq/version.rb,
lib/cdc/sidekiq/configuration.rb,
lib/cdc/sidekiq/processor_job.rb

Overview

Integration layer between Sidekiq and CDC execution primitives.

Defined Under Namespace

Modules: ProcessorJob Classes: Configuration, Error, MissingProcessorError, ProcessorFailureError, Runtime, UnsupportedRuntimeError

Constant Summary collapse

VERSION =

Current cdc-sidekiq gem version.

"0.1.0"

Class Method Summary collapse

Class Method Details

.configuration ⇒ Configuration

Read the process-wide cdc-sidekiq configuration.

Returns:



16
17
18
 
# File 'lib/cdc/sidekiq.rb', line 16

def configuration
  @configuration ||= Configuration.new
end

.configure {|configuration| ... } ⇒ Configuration

Configure process-wide defaults for CDC-aware Sidekiq jobs.

Yield Parameters:

  • configuration (Configuration) —

    mutable configuration object.

Returns:



24
25
26
27
 
# File 'lib/cdc/sidekiq.rb', line 24

def configure
  yield configuration if block_given?
  configuration
end

.reset_configuration! ⇒ Configuration

Reset process-wide configuration to defaults.

Returns:



32
33
34
 
# File 'lib/cdc/sidekiq.rb', line 32

def reset_configuration!
  @configuration = Configuration.new
end