The highest tagged major version is
Documentation
¶
Index ¶
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() uuid.UUID
func (*EventStream) Error ¶
func (s *EventStream) Error() error
func (*EventStream) EventName ¶
func (s *EventStream) EventName() string
func (*EventStream) Next ¶
func (s *EventStream) Next() bool
func (*EventStream) OccurredAt ¶
func (s *EventStream) OccurredAt() time.Time
func (*EventStream) Scan ¶
func (s *EventStream) Scan(event cqrs.Event) error
func (*EventStream) Version ¶
func (s *EventStream) Version() int
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.