Skip to content

Commit 48223e5

Browse files
committed
Align with cdc-core lifecycle and strengthen supervisor coverage
- start processors before shareablizing - propagate Runtime supervision options - add lifecycle and supervisor regression tests - cover worker failure edge cases - eliminate hanging tests - improve YARD documentation coverage
1 parent e61bdca commit 48223e5

13 files changed

Lines changed: 1156 additions & 77 deletions

lib/cdc/parallel.rb

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -12,6 +12,12 @@
1212
require_relative "parallel/router"
1313
require_relative "parallel/runtime"
1414

15+
# Namespace for Change Data Capture ecosystem components.
16+
#
17+
# The `cdc-parallel` gem adds the {CDC::Parallel} runtime namespace under
18+
# this shared ecosystem root.
19+
#
20+
# @api public
1521
module CDC
1622
# Optional parallel Change Data Capture runtime for `cdc-core` processors.
1723
#

lib/cdc/parallel/configuration.rb

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,10 @@
22

33
module CDC
44
module Parallel
5+
# :nodoc:
6+
ConfigurationData = Data.define(:size, :timeout)
7+
private_constant :ConfigurationData
8+
59
# Immutable configuration shared by cdc-parallel runtime objects.
610
#
711
# `Configuration` validates worker sizing and timeout values at construction
@@ -22,7 +26,7 @@ module Parallel
2226
# @!attribute [r] timeout
2327
# @return [Numeric, nil] Optional wait timeout in seconds.
2428
# @api public
25-
class Configuration < Data.define(:size, :timeout)
29+
class Configuration < ConfigurationData
2630
# Create a validated runtime configuration.
2731
#
2832
# @param size [Integer]

0 commit comments

Comments
 (0)