Class: EventSource::Postgres::Write
- Inherits:
-
Object
- Object
- EventSource::Postgres::Write
- Includes:
- Write
- Defined in:
- lib/event_source/postgres/write.rb
Instance Method Summary collapse
- #configure(session: nil) ⇒ Object
- #write(batch, stream_name, expected_version: nil) ⇒ Object
- #write_event_data(event_data, stream_name, expected_version: nil) ⇒ Object
Instance Method Details
#configure(session: nil) ⇒ Object
8 9 10 |
# File 'lib/event_source/postgres/write.rb', line 8 def configure(session: nil) Put.configure(self, session: session) end |
#write(batch, stream_name, expected_version: nil) ⇒ Object
12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 |
# File 'lib/event_source/postgres/write.rb', line 12 def write(batch, stream_name, expected_version: nil) logger.trace(tag: :write) { "Writing batch (Stream Name: #{stream_name}, Number of Events: #{batch.length}, Expected Version: #{expected_version.inspect})" } unless expected_version.nil? expected_version = ExpectedVersion.canonize(expected_version) end last_position = nil put.session.transaction do batch.each do |event_data| last_position = write_event_data(event_data, stream_name, expected_version: expected_version) unless expected_version.nil? expected_version += 1 end end end logger.debug(tag: :write) { "Wrote batch (Stream Name: #{stream_name}, Number of Events: #{batch.length}, Expected Version: #{expected_version.inspect})" } last_position end |
#write_event_data(event_data, stream_name, expected_version: nil) ⇒ Object
35 36 37 38 39 40 41 42 43 |
# File 'lib/event_source/postgres/write.rb', line 35 def write_event_data(event_data, stream_name, expected_version: nil) logger.trace(tag: :write) { "Writing event data (Stream Name: #{stream_name}, Type: #{event_data.type}, Expected Version: #{expected_version.inspect})" } logger.trace(tags: [:data, :event_data, :write]) { event_data.pretty_inspect } put.(event_data, stream_name, expected_version: expected_version).tap do logger.debug(tag: :write) { "Wrote event data (Stream Name: #{stream_name}, Type: #{event_data.type}, Expected Version: #{expected_version.inspect})" } logger.debug(tags: [:data, :event_data, :write]) { event_data.pretty_inspect } end end |