k8sutil

Documentation

Index

• 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 IsPortAvailable(port int) bool
• func PortForward(kubernetesConfigFlags *genericclioptions.ConfigFlags, localPort int, ...) (int, <-chan error, error)
• func ReadKustomizationFromFile(file string) (*kustomizetypes.Kustomization, error)
• func ServiceForward(kubernetesConfigFlags *genericclioptions.ConfigFlags, localPort int, ...) (chan struct{}, error)
• func UpdateRole(existingRole, desiredRole *v1.Role)
• func WaitForKotsadm(clientset *kubernetes.Clientset, namespace string, ...) (string, error)
• func WriteKustomizationToFile(kustomization *kustomizetypes.Kustomization, file string) error

Functions

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 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(kubernetesConfigFlags *genericclioptions.ConfigFlags, localPort int, remotePort int, namespace string, serviceName string) (chan struct{}, error)

func UpdateRole

func UpdateRole(existingRole, desiredRole *v1.Role)

func WaitForKotsadm

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

func WriteKustomizationToFile

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