sshtun is a Go package that provides a SSH tunnel with port forwarding supporting:
- TCP and unix socket connections
- Password authentication
- Un/encrypted key file authentication
ssh-agentbased authentication
By default it reads the default linux ssh private key location $HOME/.ssh/id_rsa and fallbacks to using ssh-agent, but a specific authentication method can be set.
go get github.com/rgzr/sshtun
package main
import (
"log"
"time"
"github.com/rgzr/sshtun"
)
func main() {
// We want to connect to port 8080 on our machine to access port 80 on my.super.host.com
sshTun := sshtun.New(8080, "my.super.host.com", 80)
// We enable debug messages to see what happens
sshTun.SetDebug(true)
// We set a callback to know when the tunnel is ready
sshTun.SetConnState(func(tun *sshtun.SSHTun, state sshtun.ConnState) {
switch state {
case sshtun.StateStarting:
log.Printf("STATE is Starting")
case sshtun.StateStarted:
log.Printf("STATE is Started")
case sshtun.StateAccepted:
log.Printf("STATE is Accepted")
case sshtun.StateOpen:
log.Printf("STATE is Open")
case sshtun.StateClosed:
log.Printf("STATE is Closed")
case sshtun.StateFailed:
log.Printf("STATE is Failed")
case sshtun.StateRemoteDropped:
log.Printf("STATE is Dropped")
case sshtun.StateStopped:
log.Printf("STATE is Stopped")
}
})
// We start the tunnel (and restart it every time it is stopped)
go func() {
for {
if err := sshTun.Start(); err != nil {
log.Printf("SSH tunnel stopped: %s", err.Error())
time.Sleep(time.Second) // don't flood if there's a start error :)
}
}
}()
// We stop the tunnel every 20 seconds (just to see what happens)
for {
time.Sleep(time.Second * time.Duration(20))
log.Println("Lets stop the SSH tunnel...")
sshTun.Stop()
}
}