Module: CDC::Core

Defined in:

lib/cdc/core.rb,
lib/cdc/core/errors.rb,
lib/cdc/core/filter.rb,
lib/cdc/core/router.rb,
lib/cdc/core/version.rb,
lib/cdc/core/observer.rb,
lib/cdc/core/pipeline.rb,
lib/cdc/core/operation.rb,
lib/cdc/core/processor.rb,
lib/cdc/core/change_event.rb,
lib/cdc/core/ordering_key.rb,
lib/cdc/core/column_change.rb,
lib/cdc/core/null_observer.rb,
lib/cdc/core/event_metadata.rb,
lib/cdc/core/event_position.rb,
lib/cdc/core/ordering_scope.rb,
lib/cdc/core/source_adapter.rb,
lib/cdc/core/ordering_policy.rb,
lib/cdc/core/processor_result.rb,
lib/cdc/core/composite_processor.rb,
lib/cdc/core/transaction_envelope.rb

Overview

Database-agnostic Change Data Capture domain primitives.

CDC::Core intentionally contains only lightweight runtime abstractions: events, metadata, source adapters, processors, filters, pipelines, and processor results. Transport, PostgreSQL protocol parsing, and value decoding live in sibling gems so this layer can remain independently useful.

Defined Under Namespace

Modules: Operation, OrderingScope Classes: ChangeEvent, ColumnChange, CompositeProcessor, Error, EventMetadata, EventPosition, Filter, InvalidOperationError, InvalidOrderingPositionError, InvalidOrderingScopeError, NullObserver, Observer, OrderingKey, OrderingPolicy, Pipeline, Processor, ProcessorError, ProcessorResult, Router, SourceAdapter, TransactionEnvelope, UnsupportedWorkItemError

Constant Summary

VERSION =

Current gem version.

'0.1.1'