我無(wú)法使用“github.com/jackc/pgx/v4/pgxpool”庫(kù)通過(guò) ssh 隧道創(chuàng)建與 postgres 數(shù)據(jù)庫(kù)的連接。我似乎無(wú)法弄清楚如何為我想用來(lái)建立連接的 *pgxpool.Config 設(shè)置 DialFunc。這就是我想要做的： sshConnStr := mkPostgresXViaSSHConnStr(config, tz) config, err := parseSshConnStr(sshConnStr) // var config *pgsshConfig sshcon, err := ssh.Dial("tcp", fmt.Sprintf("%s:%d", config.tunnelHost, config.tunnelConfig), &config.tunnelConfig) // var sshcon *ssh.Client cfg, err = pgxpool.ParseConfig(config.pgConnStr) // var cfg *pgxpool.Config cfg.ConnConfig.DialFunc = func(network, addr string) (net.Conn, error) { return sshcon.Dial(network, addr) }當(dāng)我嘗試設(shè)置 DialFunc 時(shí)，出現(xiàn)以下錯(cuò)誤：無(wú)法使用 (func(network, addr string) (net.Conn, error) literal) (value of type func(network string, addr string) (net.Conn, error )) 作為賦值中的 pgconn.DialFunc 值關(guān)于如何讓它工作的任何建議？
2 回答
小怪獸愛(ài)吃肉
TA貢獻(xiàn)1852條經(jīng)驗(yàn) 獲得超1個(gè)贊
添加上下文并轉(zhuǎn)換為pgconn.DialFunc：
package main
import (
"context"
"net"
"github.com/jackc/pgconn"
"github.com/jackc/pgx/v4/pgxpool"
)
func main() {
cfg, _ := pgxpool.ParseConfig("")
myDial := func(ctx context.Context, network, addr string) (net.Conn, error) {
return nil, nil
}
cfg.ConnConfig.DialFunc = pgconn.DialFunc(myDial)
}
猛跑小豬
TA貢獻(xiàn)1858條經(jīng)驗(yàn) 獲得超8個(gè)贊
我正在查看 DialFunc 的錯(cuò)誤類(lèi)型。對(duì)于 pgx/v3.6.2，只需要網(wǎng)絡(luò)和地址作為參數(shù)。在更新版本中，pgx/v4 context.Context 也需要作為變量傳遞（無(wú)論是否實(shí)際使用）。修復(fù)錯(cuò)誤的更新是這樣的：
cfg.ConnConfig.DialFunc = func(ctx context.Context, network, addr string) (net.Conn, error) {
return sshcon.Dial(network, addr)
}- 2 回答
- 0 關(guān)注
- 168 瀏覽
添加回答
舉報(bào)
0/150
提交
取消