mysql

Documentation

Index

• Variables
• func NewDatabaseEventStore(db *sql.DB) cqrs.EventStore
• type EventStore
  • func (s *EventStore) FindStream(aggregateTypes []string, aggregateIds []uuid.UUID, eventTypes []string) (cqrs.EventStream, error)
  • func (s *EventStore) LoadStream(aggregateType string, aggregateId uuid.UUID, version int) (cqrs.EventStream, error)
  • func (s *EventStore) WriteEvent(aggregateType string, events ...cqrs.Event) error
• type UUID
  • func MysqlUUID(uuid uuid.UUID) UUID
  • func (u UUID) Value() (driver.Value, 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 []uuid.UUID, eventTypes []string) (cqrs.EventStream, error)

func (*EventStore) LoadStream

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

func (*EventStore) WriteEvent

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

type UUID

type UUID struct {
	uuid.UUID
}

mysql optimized ID key, we store it as a bytes VARBINARY(16) instead of string

func MysqlUUID

func MysqlUUID(uuid uuid.UUID) UUID

func (UUID) Value

func (u UUID) Value() (driver.Value, error)

optimized way of storing uuid in mysql