sqlprojection

Nov 23, 2025

Changes in this version

type Driver

+ DeleteCheckpointOffsets func(ctx context.Context, tx *sql.Tx, h []byte) error

type MessageHandler

+ Reset func(ctx context.Context, tx *sql.Tx, s dogma.ProjectionResetScope) error

+ type NoResetBehavior struct

+ func (NoResetBehavior) Reset(context.Context, *sql.Tx, dogma.ProjectionResetScope) error

Sep 18, 2025

Changes in this version

type Driver

+ QueryCheckpointOffset func(ctx context.Context, db *sql.DB, h, s *uuidpb.UUID) (uint64, error)

+ UpdateCheckpointOffset func(ctx context.Context, tx *sql.Tx, h, s *uuidpb.UUID, c, n uint64) (bool, error)

Mar 21, 2023

Changes in this version

+ type ResourceRepository struct

+ func NewResourceRepository(db *sql.DB, key string, options ...Option) *ResourceRepository

+ func (rr *ResourceRepository) DeleteResource(ctx context.Context, r []byte) error

+ func (rr *ResourceRepository) ResourceVersion(ctx context.Context, r []byte) ([]byte, error)

+ func (rr *ResourceRepository) StoreResourceVersion(ctx context.Context, r, v []byte) error

+ func (rr *ResourceRepository) UpdateResourceVersion(ctx context.Context, r, c, n []byte) (ok bool, err error)

+ func (rr *ResourceRepository) UpdateResourceVersionFn(ctx context.Context, r, c, n []byte, fn func(context.Context, *sql.Tx) error) (ok bool, err error)

Dec 11, 2020

Changes in this version

+ func CreateSchema(ctx context.Context, db *sql.DB, options ...Option) error

+ func DropSchema(ctx context.Context, db *sql.DB, options ...Option) error

Dec 11, 2020

Changes in this version

+ func New(db *sql.DB, h MessageHandler, options ...Option) dogma.ProjectionMessageHandler

+ type Driver interface

+ CreateSchema func(ctx context.Context, db *sql.DB) error

+ DeleteResource func(ctx context.Context, db *sql.DB, h string, r []byte) error

+ DropSchema func(ctx context.Context, db *sql.DB) error

+ IsCompatibleWith func(ctx context.Context, db *sql.DB) error

+ QueryVersion func(ctx context.Context, db *sql.DB, h string, r []byte) ([]byte, error)

+ StoreVersion func(ctx context.Context, db *sql.DB, h string, r, v []byte) error

+ UpdateVersion func(ctx context.Context, tx *sql.Tx, h string, r, c, n []byte) (bool, error)

+ var MySQLDriver Driver = mysqlDriver{}

+ var PostgresDriver Driver = postgresDriver{}

+ var SQLiteDriver Driver = sqliteDriver{}

+ func BuiltInDrivers() []Driver

+ func SelectDriver(ctx context.Context, db *sql.DB, candidates []Driver) (Driver, error)

+ type MessageHandler interface

+ Compact func(ctx context.Context, db *sql.DB, s dogma.ProjectionCompactScope) error

+ Configure func(c dogma.ProjectionConfigurer)

+ HandleEvent func(ctx context.Context, tx *sql.Tx, s dogma.ProjectionEventScope, m dogma.Message) error

+ TimeoutHint func(m dogma.Message) time.Duration

+ type NoCompactBehavior struct

+ func (NoCompactBehavior) Compact(ctx context.Context, db *sql.DB, s dogma.ProjectionCompactScope) error

+ type Option interface

+ func WithCandidateDrivers(drivers ...Driver) Option

+ func WithDriver(d Driver) Option