A Go library for creating port forwards into pods running in a Kubernetes cluster.
This code is heavily inspired by the implementations in kubectl, fission, and helm:
- https://github.com/kubernetes/helm/blob/master/pkg/kube/tunnel.go
- https://github.com/kubernetes/kubernetes/blob/master/pkg/kubectl/cmd/portforward.go
- https://github.com/fission/fission/blob/master/fission/portforward/portforward.go
See godoc.org for full documentation.
A minimal example which will forward to the
package main
import (
"log"
"time"
"github.com/justinbarrick/go-k8s-portforward"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
)
func main() {
pf, err := portforward.NewPortForwarder("default", metav1.LabelSelector{
MatchLabels: map[string]string{
"app": "nginx",
},
}, 80)
if err != nil {
log.Fatal("Error setting up port forwarder: ", err)
}
err = pf.Start()
if err != nil {
log.Fatal("Error starting port forward: ", err)
}
log.Printf("Started tunnel on %d\n", pf.ListenPort)
time.Sleep(60 * time.Second)
}
Also see cmd/main.go.
By default, it will load a Kubernetes configuration file from ~/.kube/config or $KUBECONFIG.
It is possible to provide your own Kubernetes client by instantiating the PortForward struct
directly instead of calling the NewPortForwarder method.
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent