Class: Pgoutput::SourceAdapter::Cdc::StreamEvent

Inherits:
Object
  • Object
show all
Defined in:
lib/pgoutput/source_adapter/cdc.rb

Overview

A decoded event paired with its transport-level source position.

Source integrations use this value object to preserve WAL position metadata without teaching downstream applications about pgoutput transaction boundaries.

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(event, source_position) ⇒ void

Parameters:

  • event (Object) —

    decoded pgoutput event

  • source_position (String, nil) —

    transport WAL position



60
61
62
63
64
 
# File 'lib/pgoutput/source_adapter/cdc.rb', line 60

def initialize(event, source_position)
  @event = event
  @source_position = source_position
  freeze
end

Instance Attribute Details

#event ⇒ Object (readonly)

Returns decoded pgoutput event.

Returns:

  • (Object) —

    decoded pgoutput event



53
54
55
 
# File 'lib/pgoutput/source_adapter/cdc.rb', line 53

def event
  @event
end

#source_position ⇒ String? (readonly)

Returns transport WAL position.

Returns:

  • (String, nil) —

    transport WAL position



55
56
57
 
# File 'lib/pgoutput/source_adapter/cdc.rb', line 55

def source_position
  @source_position
end