kube

Documentation

Index

• Constants
• func CreateBastionPod(kubeClient kubernetes.Interface, remoteHost string, remotePort int, ...) (*apiv1.Pod, error)
• func DeleteBastionPod(kubeClient kubernetes.Interface, bastionPod *apiv1.Pod) error
• func GetKubernetesClient(kubecontext string, kubeconfig string) (*rest.Config, kubernetes.Interface, error)
• func PollPodStatus(kubeClient kubernetes.Interface, bastionPod *apiv1.Pod) error
• type Tunnel
  • func NewTunnel(client rest.Interface, config *rest.Config, namespace, podName string, ...) *Tunnel
  • func (t *Tunnel) Close()
  • func (t *Tunnel) ForwardPort(localPort int) error

Constants

const BastionPodSelector = "app.kubernetes.io/managed-by==bastion-pod-ctl"

const ProxyServerPodPort = 8080

Functions

func CreateBastionPod

func CreateBastionPod(kubeClient kubernetes.Interface, remoteHost string, remotePort int, namespace string) (*apiv1.Pod, error)

func DeleteBastionPod

func DeleteBastionPod(kubeClient kubernetes.Interface, bastionPod *apiv1.Pod) error

func GetKubernetesClient

func GetKubernetesClient(kubecontext string, kubeconfig string) (*rest.Config, kubernetes.Interface, error)

func PollPodStatus

func PollPodStatus(kubeClient kubernetes.Interface, bastionPod *apiv1.Pod) error

Types

type Tunnel

type Tunnel struct {
	Local     int
	Remote    int
	Namespace string
	PodName   string
	Out       io.Writer
	// contains filtered or unexported fields
}

Tunnel describes a ssh-like tunnel to a kubernetes pod

func NewTunnel

func NewTunnel(client rest.Interface, config *rest.Config, namespace, podName string, remote int) *Tunnel

NewTunnel creates a new tunnel

func (*Tunnel) Close

func (t *Tunnel) Close()

Close disconnects a tunnel connection

func (*Tunnel) ForwardPort

func (t *Tunnel) ForwardPort(localPort int) error

ForwardPort opens a tunnel to a kubernetes pod