Versions in this module Expand all Collapse all v0 v0.12.0 Jul 29, 2026 Changes in this version + func DecorateInput[Req any](fn func(context.Context, Req) error, codec codex.Codec[Req], ...) func(context.Context, Req) error + func DecorateOutput[Req, Resp any](fn func(context.Context, Req) (Resp, error), codec codex.Codec[Resp], ...) func(context.Context, Req) (Resp, error) v0.11.0 Jul 15, 2026 Changes in this version + func DrainInsertAdapter[T any](codec codex.Codec[T], insertFn func(context.Context, T) error, ...) ports.SinkAdapter[T] + func QueryAdapter[T any](codec codex.Codec[T], queryFn func(context.Context) ([]T, error), ...) ports.SourceAdapter[T] + func QueryEachAdapter[In, T any](codec codex.Codec[T], queryFn func(context.Context, In) ([]T, error), ...) ports.IOAdapter[In, T] + func Validate[T any](c codex.Codec[T], v T, opts ValidateOptions) (T, error) + type DrainInsertOptions struct + Observer stats.Observer + OnError func(error) + Op string + Table string + type InsertStreamError struct + Err error + Op string + Table string + func (e InsertStreamError) Error() string + func (e InsertStreamError) LogValue() slog.Value + func (e InsertStreamError) Unwrap() error + type MigrateOptions struct + Observer stats.Observer + type MigrationError struct + Err error + Op string + Version int64 + func (e MigrationError) Error() string + func (e MigrationError) LogValue() slog.Value + func (e MigrationError) Unwrap() error + type MigrationStatus struct + AppliedAt time.Time + Name string + Version int64 + type Migrator struct + func NewMigrator(db *sql.DB, migrations fs.FS, dir string, dialect string) (*Migrator, error) + func (m *Migrator) Down(ctx context.Context, opts MigrateOptions) error + func (m *Migrator) Status(ctx context.Context) ([]MigrationStatus, error) + func (m *Migrator) Up(ctx context.Context, opts MigrateOptions) error + type QueryEachStreamOptions struct + Buffer int + Observer stats.Observer + Op string + Table string + type QueryStreamError struct + Err error + Op string + Table string + func (e QueryStreamError) Error() string + func (e QueryStreamError) LogValue() slog.Value + func (e QueryStreamError) Unwrap() error + type QueryStreamOptions struct + Buffer int + Observer stats.Observer + Op string + Table string + type RowValidationError struct + Err error + Op string + Table string + func (e RowValidationError) Error() string + func (e RowValidationError) LogValue() slog.Value + func (e RowValidationError) Unwrap() error + type ValidateOptions struct + Observer stats.Observer + Op string + Table string
Go to main page