sql

Nov 29, 2025

Changes in this version

+ type Iterator struct

+ CurrentGlobalVersion core.Version

+ Rows *sql.Rows

+ func (i *Iterator) Close()

+ func (i *Iterator) Next() bool

+ func (i *Iterator) Value() (core.Event, error)

Jun 29, 2025

Changes in this version

+ type Postgres struct

+ func NewPostgres(db *sql.DB) (*Postgres, error)

+ func (s *Postgres) All(start core.Version, count uint64) (core.Iterator, error)

+ func (s *Postgres) Close()

+ func (s *Postgres) Get(ctx context.Context, id string, aggregateType string, ...) (core.Iterator, error)

+ func (s *Postgres) Save(events []core.Event) error

+ type SQLServer struct

+ func NewSQLServer(db *sql.DB) (*SQLServer, error)

+ func (s *SQLServer) All(start core.Version, count uint64) (core.Iterator, error)

+ func (s *SQLServer) Close()

+ func (s *SQLServer) Get(ctx context.Context, id string, aggregateType string, ...) (core.Iterator, error)

+ func (s *SQLServer) Save(events []core.Event) error

+ type SQLite struct

+ func NewSQLite(db *sql.DB) (*SQLite, error)

+ func NewSQLiteSingelWriter(db *sql.DB) (*SQLite, error)

+ func (s *SQLite) All(start core.Version, count uint64) (core.Iterator, error)

+ func (s *SQLite) Close()

+ func (s *SQLite) Get(ctx context.Context, id string, aggregateType string, ...) (core.Iterator, error)

+ func (s *SQLite) Save(events []core.Event) error

Jul 30, 2024

Changes in this version

type SQL

+ func OpenWithSingelWriter(db *sql.DB) *SQL

Mar 4, 2024

Changes in this version

type SQL

+ func (s *SQL) All(start core.Version, count uint64) (core.Iterator, error)

Mar 14, 2021

Changes in this version

type SQL

+ func (s *SQL) GlobalEvents(start, count uint64) ([]eventsourcing.Event, error)

Apr 13, 2020

Changes in this version

+ type SQL struct

+ func Open(db sql.DB, serializer eventstore.EventSerializer) *SQL

+ func (sql *SQL) Close()

+ func (sql *SQL) Get(id string, aggregateType string, afterVersion eventsourcing.Version) (events []eventsourcing.Event, err error)

+ func (sql *SQL) Migrate() error

+ func (sql *SQL) MigrateTest() error

+ func (sql *SQL) Save(events []eventsourcing.Event) error