Versions in this module Expand all Collapse all v1 v1.0.0 Jan 4, 2017 Changes in this version + const EventPublishEnvVar + var ErrConcurrency = errors.New("Concurrency Exception") + var ErrEventInsert = errors.New("Error inserting record into events table") + var ErrPayloadType = errors.New("Only payloads of type []byte are allowed") + var ErrPubInsert = errors.New("Error inserting record into pub table") + func InsertEventFromParts(db *sql.DB, aggId string, version int, typecode string, payload []byte) error + type OraEventStore struct + func NewOraEventStore(db *sql.DB) (*OraEventStore, error) + func (ora *OraEventStore) GetMaxVersionForAggregate(aggId string) (*int, error) + func (ora *OraEventStore) RetrieveEvents(aggID string) ([]goes.Event, error) + func (ora *OraEventStore) StoreEvents(agg *goes.Aggregate) error
Go to main page