k8sutil

package
v1.115.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 15, 2024 License: Apache-2.0 Imports: 55 Imported by: 2

Documentation

Index

Constants

View Source 
const (
	DEFAULT_K8S_CLIENT_QPS   = 100
	DEFAULT_K8S_CLIENT_BURST = 100
)
View Source 
const (
	KotsadmIDConfigMapName = "kotsadm-id"
)

Variables

View Source 
var (
	ErrWaitForPodTimeout = errors.New("timeout waiting for pod")
)

Functions

func AddFlags 

func AddFlags(flags *flag.FlagSet)

func CreateKotsadmIDConfigMap 

func CreateKotsadmIDConfigMap(clientset kubernetes.Interface, kotsadmID string) error

func DeleteKotsadm 

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

func FindFreePort added in v1.85.0 

func FindFreePort(clientset kubernetes.Interface) (int, error)

func FindKotsadm 

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

func FindKotsadmImage 

func FindKotsadmImage(namespace string) (string, error)

func GenerateBootstrapToken 

func GenerateBootstrapToken(client kubernetes.Interface, ttl time.Duration) (string, error)

GenerateBootstrapToken will generate a node join token for kubeadm. ttl defines the time to live for this token.

func GenerateK0sBootstrapToken added in v1.105.0 

func GenerateK0sBootstrapToken(client kbclient.Client, ttl time.Duration, role string) (string, error)

func GetClientset 

func GetClientset() (*kubernetes.Clientset, error)

func GetClusterCaCert added in v1.105.0 

func GetClusterCaCert(ctx context.Context, client kbclient.Client) (string, error)

func GetClusterConfig 

func GetClusterConfig() (*rest.Config, error)

func GetCurrentRules 

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

func GetDynamicClient added in v1.98.3 

func GetDynamicClient() (dynamic.Interface, error)

func GetDynamicResourceInterface added in v1.100.0 

func GetDynamicResourceInterface(gvk *schema.GroupVersionKind, namespace string) (dynamic.ResourceInterface, error)

func GetK8sMinorVersion added in v1.101.1 

func GetK8sMinorVersion(clientset kubernetes.Interface) (int, error)

func GetK8sVersion 

func GetK8sVersion(clientset kubernetes.Interface) (string, error)

func GetKotsadmID added in v1.103.2 

func GetKotsadmID(clientset kubernetes.Interface) string

func GetKotsadmIDConfigMap 

func GetKotsadmIDConfigMap(clientset kubernetes.Interface) (*corev1.ConfigMap, error)

func GetKubeClient added in v1.109.10 

func GetKubeClient(ctx context.Context) (kbclient.Client, error)

func GetOpenShiftPodSecurityContext 

func GetOpenShiftPodSecurityContext(kotsadmNamespace string, strictSecurityContext bool) (*corev1.PodSecurityContext, error)

GetOpenShiftPodSecurityContext returns a PodSecurityContext object that has: User set to the minimum value in the "openshift.io/sa.scc.uid-range" annotation. Group set to the minimum value in the "openshift.io/sa.scc.supplemental-groups" annotation if exists, else falls back to the minimum value in the "openshift.io/sa.scc.uid-range" annotation.

func GetPodLogs 

func GetPodLogs(ctx context.Context, clientset kubernetes.Interface, pod *corev1.Pod, follow bool, maxLines *int64) ([]byte, error)

func InitHelmCapabilities 

func InitHelmCapabilities() error

func IsGKEAutopilot added in v1.91.1 

func IsGKEAutopilot(clientset kubernetes.Interface) bool

IsGKEAutopilot returns true if the cluster is positively identified as being an autopilot cluster in GKE

func IsKotsadmClusterScoped 

func IsKotsadmClusterScoped(ctx context.Context, clientset kubernetes.Interface, namespace string) bool

IsKotsadmClusterScoped will check if kotsadm has cluster scope access or not

func IsKotsadmIDConfigMapPresent 

func IsKotsadmIDConfigMapPresent() (bool, 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(clientset kubernetes.Interface, port int) (bool, error)

func MergeEnvVars 

func MergeEnvVars(desired []corev1.EnvVar, existing []corev1.EnvVar, override bool) []corev1.EnvVar

func MergeImagePullSecrets added in v1.94.0 

func MergeImagePullSecrets(desired []corev1.LocalObjectReference, existing []corev1.LocalObjectReference, override bool) []corev1.LocalObjectReference

func MergeVolumeMounts added in v1.94.0 

func MergeVolumeMounts(desired []corev1.VolumeMount, existing []corev1.VolumeMount, override bool) []corev1.VolumeMount

func MergeVolumes added in v1.94.0 

func MergeVolumes(desired []corev1.Volume, existing []corev1.Volume, override bool) []corev1.Volume

func PodsHaveTheSameOwner 

func PodsHaveTheSameOwner(pods []corev1.Pod) bool

func PortForward 

func PortForward(localPort int, remotePort int, namespace string, getPodName func() (string, error), pollForAdditionalPorts bool, stopCh <-chan struct{}, log *logger.CLILogger) (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 RestartKotsadm added in v1.89.0 

func RestartKotsadm(ctx context.Context, clientset *kubernetes.Clientset, namespace string, timeout time.Duration) error

func ScaleDownDeployment 

func ScaleDownDeployment(ctx context.Context, clientset kubernetes.Interface, namespace string, deploymentName string) error

func SecureContainerContext added in v1.98.0 

func SecureContainerContext(isStrict bool) *corev1.SecurityContext

func SecurePodContext added in v1.98.0 

func SecurePodContext(user int64, group int64, isStrict bool) *corev1.PodSecurityContext

func ServiceForward 

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

func UpdateKotsadmIDConfigMap 

func UpdateKotsadmIDConfigMap(clientset kubernetes.Interface, kotsadmID string) error

func WaitForDeploymentReady 

func WaitForDeploymentReady(ctx context.Context, clientset kubernetes.Interface, namespace string, deploymentName string, timeout time.Duration) error

func WaitForKotsadm 

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

func WaitForPod 

func WaitForPod(ctx context.Context, clientset kubernetes.Interface, namespace string, podName string, timeoutWaitingForPod time.Duration) error

func WaitForStatefulSetReady 

func WaitForStatefulSetReady(ctx context.Context, clientset kubernetes.Interface, namespace string, statefulSetName string, timeout time.Duration) error

func WriteKustomizationToFile 

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

Types

This section is empty.

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.