Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EventStoreSqlite ¶
type EventStoreSqlite struct {
// contains filtered or unexported fields
}
func NewEventStore ¶
func NewEventStore(filepath string) (es EventStoreSqlite, err error)
func (*EventStoreSqlite) Next ¶
func (es *EventStoreSqlite) Next(cursorID string) (eventMetadata *esam.EventMetadata, err error)
type GormEvent ¶
type GormEvent struct { gorm.Model EventID string `gorm:"column:event_id;index:event_id_idx" json:"event_id"` esam.EventMetadata }
type GormProjection ¶
type ProjectionSqlite ¶
type ProjectionSqlite struct {
// contains filtered or unexported fields
}
func NewProjection ¶
func NewProjection(filepath string, es esam.EventStore) (p ProjectionSqlite, err error)
func (*ProjectionSqlite) Project ¶
func (p *ProjectionSqlite) Project(ctx context.Context)
func (*ProjectionSqlite) RegisterEvent ¶
func (p *ProjectionSqlite) RegisterEvent(eventName string, prObj esam.EventProjection) (err error)
Click to show internal directories.
Click to hide internal directories.