k8sutil

Documentation

Index

• func DeleteKotsadm(clientset *kubernetes.Clientset, namespace string, isKurl bool) error
• func FindKotsadm(clientset *kubernetes.Clientset, namespace string) (string, error)
• func GetClientset(kubernetesConfigFlags *genericclioptions.ConfigFlags) (*kubernetes.Clientset, error)
• func GetCurrentRules(deployOptions kotsadmtypes.DeployOptions, clientset *kubernetes.Clientset) ([]rbacv1.PolicyRule, error)
• func IsOpenShift(clientset kubernetes.Interface) bool
• func IsPortAvailable(port int) bool
• func PortForward(kubernetesConfigFlags *genericclioptions.ConfigFlags, localPort int, ...) (int, <-chan error, error)
• func ReadKustomizationFromFile(file string) (*kustomizetypes.Kustomization, error)
• func ServiceForward(clientset *kubernetes.Clientset, cfg *rest.Config, localPort int, ...) (chan struct{}, error)
• func WaitForKotsadm(clientset *kubernetes.Clientset, namespace string, ...) (string, error)
• func WriteKustomizationToFile(kustomization kustomizetypes.Kustomization, file string) error

Functions

func DeleteKotsadm

func DeleteKotsadm(clientset *kubernetes.Clientset, namespace string, isKurl bool) error

func FindKotsadm

func FindKotsadm(clientset *kubernetes.Clientset, namespace string) (string, error)

func GetClientset

func GetClientset(kubernetesConfigFlags *genericclioptions.ConfigFlags) (*kubernetes.Clientset, error)

func GetCurrentRules

func GetCurrentRules(deployOptions kotsadmtypes.DeployOptions, clientset *kubernetes.Clientset) ([]rbacv1.PolicyRule, error)

func IsOpenShift

func IsOpenShift(clientset kubernetes.Interface) bool

IsOpenShift returns true if the cluster is positively identified as being an openshift cluster

func IsPortAvailable

func IsPortAvailable(port int) bool

func PortForward

func PortForward(kubernetesConfigFlags *genericclioptions.ConfigFlags, localPort int, remotePort int, namespace string, podName string, pollForAdditionalPorts bool, stopCh <-chan struct{}, log *logger.Logger) (int, <-chan error, error)

PortForward starts a local port forward to a pod in the cluster if localport is set, it will attempt to use that port locally. always check the port number returned though, because a port conflict could cause a different port to be used

func ReadKustomizationFromFile

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

func ServiceForward

func ServiceForward(clientset *kubernetes.Clientset, cfg *rest.Config, localPort int, remotePort int, namespace string, serviceName string) (chan struct{}, error)

func WaitForKotsadm

func WaitForKotsadm(clientset *kubernetes.Clientset, namespace string, timeoutWaitingForWeb time.Duration) (string, error)

func WriteKustomizationToFile

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