dbmigrate

type Execer func(context.Context, string, ...any) error

type Ledger struct {
	// Table은 ledger 테이블 이름이다.
	Table string
}

type LockConfig struct {
	// Key는 PostgreSQL advisory lock key다.
	Key int64
	// Acquire는 lock 획득 최대 대기 시간이다.
	Acquire time.Duration
	// Poll은 lock 획득 재시도 간격이다.
	Poll time.Duration
	// Release는 lock 해제 최대 대기 시간이다.
	Release time.Duration
	// OnUnlockError는 unlock 실패를 return 대신 전달받는 callback이다.
	OnUnlockError func(error)
}

type LockSession interface {
	// TryAdvisoryLock은 advisory lock 획득을 한 번 시도한다.
	TryAdvisoryLock(ctx context.Context, key int64) (bool, error)
	// AdvisoryUnlock은 advisory lock 해제를 시도한다.
	AdvisoryUnlock(ctx context.Context, key int64) (bool, error)
}

type Option func(*options)

type Row interface {
	// Scan은 row 값을 destination에 복사한다.
	Scan(dest ...any) error
}

type RowQuerier interface {
	// QueryRow는 단일 row 조회를 실행한다.
	QueryRow(ctx context.Context, query string, args ...any) Row
}

type SQLExecer interface {
	ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)
}

type SQLQueryRowContext interface {
	// QueryRowContext는 context-aware 단일 row 조회를 실행한다.
	QueryRowContext(ctx context.Context, query string, args ...any) *sql.Row
}

type SessionConfig struct {
	LockTimeout      time.Duration
	StatementTimeout time.Duration
}

type UnlockFailureEvicter interface {
	EvictAfterUnlockFailure() error
}