k8sutil

Documentation

Index

• func GetCurrentRules(kubeconfig, context string, clientset *kubernetes.Clientset) ([]rbacv1.PolicyRule, error)
• func IsPortAvailable(port int) bool
• func PortForward(kubeContext string, localPort int, remotePort int, namespace string, ...) (<-chan error, error)
• func ReadKustomizationFromFile(file string) (*kustomizetypes.Kustomization, error)
• func ServiceForward(kubeContext string, localPort int, remotePort int, namespace string, ...) (chan struct{}, error)
• func WaitForWeb(namespace string, timeoutWaitingForWeb time.Duration) (string, error)
• func WriteKustomizationToFile(kustomization *kustomizetypes.Kustomization, file string) error

Functions

func GetCurrentRules

func GetCurrentRules(kubeconfig, context string, clientset *kubernetes.Clientset) ([]rbacv1.PolicyRule, error)

func IsPortAvailable

func IsPortAvailable(port int) bool

func PortForward

func PortForward(kubeContext string, localPort int, remotePort int, namespace string, podName string, pollForAdditionalPorts bool, stopCh <-chan struct{}) (<-chan error, error)

func ReadKustomizationFromFile

func ReadKustomizationFromFile(file string) (*kustomizetypes.Kustomization, error)

func ServiceForward

func ServiceForward(kubeContext string, localPort int, remotePort int, namespace string, serviceName string) (chan struct{}, error)

func WaitForWeb

func WaitForWeb(namespace string, timeoutWaitingForWeb time.Duration) (string, error)

func WriteKustomizationToFile

func WriteKustomizationToFile(kustomization *kustomizetypes.Kustomization, file string) error