db

Documentation

Index

• type DB
• type EventTxFn
• type EventsTxFn
• type MigrationOptions
• type MigrationResult
• type Migrator
• type TxFn

Types

type DB

type DB interface {
	Connect() error
	Close() error
	Connection() *sqlx.DB
	Migrate(ctx context.Context, options *MigrationOptions) (*MigrationResult, error)
	Tx(ctx context.Context, tx TxFn) error
	EventTx(ctx context.Context, etx EventTxFn) (*events.EventID, error)
	EventsTx(ctx context.Context, etx EventsTxFn) ([]events.EventID, error)
}

type EventTxFn

type EventTxFn func(ctx context.Context, tx *sqlx.Tx) (*events.EventSpec, error)

type EventsTxFn

type EventsTxFn func(ctx context.Context, tx *sqlx.Tx) ([]*events.EventSpec, error)

type MigrationOptions

type MigrationOptions struct {
	DropTablesBeforeMigrating bool
}

type MigrationResult

type MigrationResult struct {
	AppliedMigrations []string
}

type Migrator

type Migrator interface {
	Migrate(ctx context.Context, dsn string) (*MigrationResult, error)
}

type TxFn

type TxFn func(ctx context.Context, tx *sqlx.Tx) error