Documentation
¶
Index ¶
- Variables
- func NewDatabaseEventStream(rows *sql.Rows) cqrs.EventStream
- func NewMySQLSnapshotStore(db *sql.DB) cqrs.SnapshotStore
- func NewPostgresSnapshotStore(db *sql.DB) cqrs.SnapshotStore
- type EventStream
- func (s *EventStream) AggregateId() cqrs.AggregateId
- func (s *EventStream) Error() error
- func (s *EventStream) EventType() cqrs.EventType
- func (s *EventStream) Next() bool
- func (s *EventStream) Scan(event cqrs.EventData) error
- func (s *EventStream) Timestamp() time.Time
- func (s *EventStream) Version() int
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ErrNoEventData = errors.New("Cannot scan, no event data")
)
Functions ¶
func NewDatabaseEventStream ¶
func NewMySQLSnapshotStore ¶
Types ¶
type EventStream ¶
type EventStream struct {
// contains filtered or unexported fields
}
func (*EventStream) AggregateId ¶
func (s *EventStream) AggregateId() cqrs.AggregateId
func (*EventStream) Error ¶
func (s *EventStream) Error() error
func (*EventStream) EventType ¶
func (s *EventStream) EventType() cqrs.EventType
func (*EventStream) Next ¶
func (s *EventStream) Next() bool
func (*EventStream) Scan ¶
func (s *EventStream) Scan(event cqrs.EventData) error
func (*EventStream) Timestamp ¶
func (s *EventStream) Timestamp() time.Time
func (*EventStream) Version ¶
func (s *EventStream) Version() int
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.