workflow v0.2.0 Workflow.Extreme.Mapper

Map raw events to event data structs ready to be persisted to the event store.

Summary

Functions

extract_data(message)

extract_events(arg)

make_alias(name)

map_read_stream(stream_id, from_event_number, max_count)

create a read stream message

map_to_event_data(events, correlation_id)

map_write_events(stream, events)

create a write message for a list of events

Functions

extract_data(message)

extract_events(arg)

make_alias(name)

map_read_stream(stream_id, from_event_number, max_count)

create a read stream message

map_to_event_data(events, correlation_id)

map_write_events(stream, events)

create a write message for a list of events