pge

type Conn interface {
	Execute(ctx context.Context, query Query, args ...interface{}) (pgconn.CommandTag, error)

	Get(ctx context.Context, dst interface{}, query Query, args ...interface{}) error

	Select(ctx context.Context, dst interface{}, query Query, args ...interface{}) error

	PaginatedSelect(ctx context.Context, dst interface{}, query Query, args ...interface{}) (Cursors, error)
}

type Cursors struct {
	// ...after <cursor> (optional)
	AfterCursor string
	// ...or before <cursor> (optional)
	BeforeCursor string
}

type Migration struct {
	Name    string
	Queries []Query
}

type Order string

type Paginator struct {
	// as in "get the first <n> results..."
	First int64
	// as in "get the last <n> results..."
	Last int64

	Cursors
}

type Query struct {
	Name string
	// contains filtered or unexported fields
}

type QueryError struct {
	Query Query
	Err   error
}

type QueryOption func(*Query)

type Store interface {
	Conn
	io.Closer

	Migrate(ctx context.Context, migrations []Migration) error

	Tx(ctx context.Context, fn func(tx Tx) error, opts ...TxOption) error
}

type Tx interface {
	pgx.Tx
	Conn
}

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

type TxOption func(*TxInfo)