package main
import (
"crypto/tls""fmt""github.com/tlsproxy/pgproxy"
)
funcmain() {
proxyConfig:=&pgproxy.ProxyConfig{
Src: "0.0.0.0:7777",
Dst: "192.168.1.11:5432",
HandleError: func(errerror) {
fmt.Printf("%+v", err)
},
HandleRead: func(b []byte, state tls.ConnectionState) error {
returnnil
},
HandleWrite: nil,
HandleClientState: func(w tls.ConnectionState) error {
returnnil
},
}
tlsConfig:=&pgproxy.TlsConfig{
ServerCert: "/ca/server.crt",
ServerKey: "/ca/server.key",
CaCert: "/ca/ca.crt",
}
proxy, err:=pgproxy.NewProxy(proxyConfig, tlsConfig)
iferr!=nil {
panic(err)
}
err=proxy.Listen()
iferr!=nil {
panic(err)
}
}