datastore

type Backend interface {
	HealthCheck(ctx context.Context) error
	io.Closer
}

type ConnectionInfo struct {
	Host     string
	Port     uint16
	Database string
	User     string

	ServerVersion    string
	ServerVersionNum int64

	Latency time.Duration

	Stats *pgxpool.Stat
}

type Executor interface {
	Exec(ctx context.Context, sql string, args ...any) (pgconn.CommandTag, error)
	Query(ctx context.Context, sql string, args ...any) (pgx.Rows, error)
	QueryRow(ctx context.Context, sql string, args ...any) pgx.Row
}

type Options struct {
	// DSN is the connection string (postgresql:// or postgres://).
	DSN string

	// MaxConnections caps pool size; 0 keeps pgx/DSN default.
	MaxConnections int32

	// MinConnections keeps warm idle; 0 keeps pgx/DSN default.
	MinConnections int32

	// MaxConnLifetime bounds reuse; 0 keeps pgx/DSN default.
	MaxConnLifetime time.Duration

	// MaxConnIdleTime closes idle conns; 0 keeps pgx/DSN default.
	MaxConnIdleTime time.Duration
}

type Postgres struct {
	// contains filtered or unexported fields
}

type Store interface {
	Backend
	Executor

	WithTx(ctx context.Context, fn func(Executor) error) error
}