Documentation ¶
Index ¶
- Variables
- type EventStreamRepository
- func (esr *EventStreamRepository) AllIntegrationEventsEverPublished() ([]cqrs.VersionedEvent, error)
- func (esr *EventStreamRepository) Get(id string) ([]cqrs.VersionedEvent, error)
- func (esr *EventStreamRepository) GetDb() *sqlx.DB
- func (esr *EventStreamRepository) GetIntegrationEventsByCorrelationID(correlationID string) ([]cqrs.VersionedEvent, error)
- func (esr *EventStreamRepository) Save(sourceID string, events []cqrs.VersionedEvent) error
- func (esr *EventStreamRepository) SaveIntegrationEvent(event cqrs.VersionedEvent) error
- type PgVersionedEvent
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrPgConnStr = errors.New("invalid postgres connection string") ErrPgPrepInsertStmt = errors.New("error prepapring insert statement") ErrPgPrepSelectStmt = errors.New("error preparing select statement") ErrPgSelectSource = errors.New("error querying for events using source id") ErrPgNoEventType = errors.New("cannot find event type") ErrPgUnmarshalingEvent = errors.New("error unmarshaling event") ErrPgMarshalingEvent = errors.New("error marshaling event") ErrPgSavingEvent = errors.New("error saving event") ErrPgSavingIntegEvent = errors.New("error saving integration event") ErrPgSavingCorrelEvent = errors.New("error saving correlation event") ErrPgIntegEventsByCorrel = errors.New("error querying for integration events using correlation id") ErrPgAllIntegEvents = errors.New("error querying for all integration events") )
Functions ¶
This section is empty.
Types ¶
type EventStreamRepository ¶
type EventStreamRepository struct {
// contains filtered or unexported fields
}
func NewEventStreamRepository ¶
func NewEventStreamRepository(connStr string, typeRegistry cqrs.TypeRegistry) (*EventStreamRepository, error)
func (*EventStreamRepository) AllIntegrationEventsEverPublished ¶
func (esr *EventStreamRepository) AllIntegrationEventsEverPublished() ([]cqrs.VersionedEvent, error)
func (*EventStreamRepository) Get ¶
func (esr *EventStreamRepository) Get(id string) ([]cqrs.VersionedEvent, error)
func (*EventStreamRepository) GetDb ¶
func (esr *EventStreamRepository) GetDb() *sqlx.DB
func (*EventStreamRepository) GetIntegrationEventsByCorrelationID ¶
func (esr *EventStreamRepository) GetIntegrationEventsByCorrelationID(correlationID string) ([]cqrs.VersionedEvent, error)
func (*EventStreamRepository) Save ¶
func (esr *EventStreamRepository) Save(sourceID string, events []cqrs.VersionedEvent) error
func (*EventStreamRepository) SaveIntegrationEvent ¶
func (esr *EventStreamRepository) SaveIntegrationEvent(event cqrs.VersionedEvent) error
Click to show internal directories.
Click to hide internal directories.