Module: CDC::SolidQueue

Defined in:
lib/cdc/solid_queue.rb,
lib/cdc/solid_queue/cli.rb,
lib/cdc/solid_queue/error.rb,
lib/cdc/solid_queue/runner.rb,
lib/cdc/solid_queue/railtie.rb,
lib/cdc/solid_queue/version.rb,
lib/cdc/solid_queue/enqueuer.rb,
lib/cdc/solid_queue/checkpoint.rb,
lib/cdc/solid_queue/configuration.rb,
lib/cdc/solid_queue/processor_job.rb,
lib/cdc/solid_queue/event_serializer.rb,
lib/cdc/solid_queue/postgresql_stream.rb,
lib/cdc/solid_queue/downstream_processor.rb

Overview

Rails-native durable CDC job backend built on Solid Queue.

Defined Under Namespace

Modules: CLI, ProcessorJob Classes: Checkpoint, Configuration, ConfigurationError, DownstreamProcessor, Enqueuer, Error, EventSerializer, PostgresqlStream, Railtie, Runner, SerializationError, UnsupportedSourceError

Constant Summary collapse

VERSION =

Current cdc-solid-queue gem version.

'0.3.0'

Class Method Summary collapse

Class Method Details

.configuration ⇒ Configuration

Return the global configuration.

Returns:



23
24
25
 
# File 'lib/cdc/solid_queue.rb', line 23

def configuration
  @configuration ||= Configuration.new
end

.configure {|config| ... } ⇒ Configuration

Configure cdc-solid-queue.

Yield Parameters:

Returns:



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

def configure
  yield configuration
  configuration
end

.reset_configuration! ⇒ Configuration

Reset configuration. Intended for tests and console experiments.

Returns:



39
40
41
 
# File 'lib/cdc/solid_queue.rb', line 39

def reset_configuration!
  @configuration = Configuration.new
end