Method: EventSource::Postgres::Put#insert_event

Defined in:
lib/event_source/postgres/put.rb

#insert_event(id, stream_name, type, data, metadata, expected_version) ⇒ Object 



60
61
62
63
64
65
 
# File 'lib/event_source/postgres/put.rb', line 60

def insert_event(id, stream_name, type, data, metadata, expected_version)
  serialized_data = serialized_data(data)
  serialized_metadata = serialized_metadata(metadata)
  records = execute_query(id, stream_name, type, serialized_data, serialized_metadata, expected_version)
  position(records)
end