Module: CDC::Concurrent

Defined in:
lib/cdc/concurrent.rb,
lib/cdc/concurrent/errors.rb,
lib/cdc/concurrent/router.rb,
lib/cdc/concurrent/runtime.rb,
lib/cdc/concurrent/version.rb,
lib/cdc/concurrent/configuration.rb,
lib/cdc/concurrent/processor_pool.rb,
lib/cdc/concurrent/result_collector.rb,
lib/cdc/concurrent/transaction_pool.rb,
lib/cdc/concurrent/processor_extensions.rb

Overview

Optional concurrent runtime adapter for cdc-core processors.

Defined Under Namespace

Modules: ProcessorExtensions Classes: Configuration, Error, ProcessorPool, ResultCollector, Router, Runtime, ShutdownError, TimeoutError, TransactionPool, UnsafeProcessorError, UnsupportedWorkItemError

Constant Summary collapse

VERSION =

Current cdc-concurrent version.

"0.1.0"

Class Method Summary collapse

Class Method Details

.install_processor_extensions! ⇒ void

This method returns an undefined value.

Installs concurrent-safe declarations on CDC::Core::Processor.



30
31
32
33
 
# File 'lib/cdc/concurrent/processor_extensions.rb', line 30

def self.install_processor_extensions!
  CDC::Core::Processor.extend(ProcessorExtensions::ClassMethods)
  CDC::Core::Processor.include(ProcessorExtensions)
end