mysql

Documentation

Index

• Variables
• func NewDatabaseEventStore(db *sql.DB) cqrs.EventStore
• type EventStore
  • func (s *EventStore) FindStream(aggregateTypes []string, aggregateIds []cqrs.AggregateId, eventTypes []string) (cqrs.EventStream, error)
  • func (s *EventStore) LoadStream(aggregateType string, aggregateId cqrs.AggregateId, version int) (cqrs.EventStream, error)
  • func (s *EventStore) WriteEvent(aggregateType string, events ...cqrs.Event) error

Variables

var ErrNoAffectedRows = errors.New("No affected rows")

Functions

func NewDatabaseEventStore

func NewDatabaseEventStore(db *sql.DB) cqrs.EventStore

Types

type EventStore

type EventStore struct {
	// contains filtered or unexported fields
}

func (*EventStore) FindStream

func (s *EventStore) FindStream(aggregateTypes []string, aggregateIds []cqrs.AggregateId, eventTypes []string) (cqrs.EventStream, error)

func (*EventStore) LoadStream

func (s *EventStore) LoadStream(aggregateType string, aggregateId cqrs.AggregateId, version int) (cqrs.EventStream, error)

func (*EventStore) WriteEvent

func (s *EventStore) WriteEvent(aggregateType string, events ...cqrs.Event) error