telsos.lib.es.store — com.github.kongra/telsos-lib 0.1.527

Store clj/s protocol

insert-agg! clj/s

(insert-agg! store agg-type attrs)

Insert a new aggregate. Returns: {:id <UUIDv7> :valid-from inst}

insert-event! clj/s

(insert-event! store params)

Insert a new event. params: {:event-type :agg-type :agg-id :agg-version :request-id :interaction-id :payload} Returns: {:id <UUIDv7> :created-at inst} Throws on (agg-type, agg-id, agg-version) conflict.

select-agg-by-id clj/s

(select-agg-by-id store agg-type id)

Select aggregate by id. Returns: {:id :version :attrs :valid-from} or nil.

select-event-by-agg-version clj/s

(select-event-by-agg-version store agg-type agg-id agg-version)

Select a single event by aggregate identity and version. Returns: event map or nil.

select-events-by-agg-id clj/s

(select-events-by-agg-id store agg-type agg-id)

Select all events for an aggregate. Returns: seq of event maps, ordered by version.

update-agg! clj/s

(update-agg! store agg-type id version attrs)

Update an existing aggregate. Returns: {:valid-from inst} or nil if not found.