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

Store clj/s protocol

insert-agg! clj/s

(insert-agg! store type attrs)

Insert a new aggregate. Store generates the id. Returns: {:id uuid :valid-from inst}

insert-event! clj/s

(insert-event! store type agg-id agg-type agg-ver request-id inter-id payload)

Insert a new event. Params: type keyword agg-id uuid agg-type keyword agg-ver pos-int request-id uuid inter-id uuid payload JsonEdn}

Returns: {:id uuid :created-at inst} Throws on (agg-type, agg-id, agg-ver) already occupied.

select-agg-by-id clj/s

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

Select aggregate by id. Returns: Agg or nil.

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

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

Select a single event by aggregate identity and version. Returns: Event 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, ordered by :agg-ver. Returns: seq of Event

update-agg! clj/s

(update-agg! store type id ver attrs)

Update an existing aggregate. ver: new version to set (caller must pass prev-ver + 1). CAS conflict enforced at the events level, not here. Returns: {:valid-from inst} or nil if not found.