kubernetes

package

v1.0.4 Latest Latest Go to latest Published: Apr 17, 2025 License: Apache-2.0 Imports: 22 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/aws/eks-hybrid

Links

Documentation ¶

Index ¶

Constants
func CheckForNodeWithE2ELabel(ctx context.Context, k8s kubernetes.Interface, nodeName string) (*corev1.Node, error)
func CordonNode(ctx context.Context, k8s kubernetes.Interface, node *corev1.Node, ...) error
func CreateNginxPodInNode(ctx context.Context, k8s kubernetes.Interface, ...) error
func CreatePod(ctx context.Context, k8s kubernetes.Interface, pod *corev1.Pod, ...) error
func DeleteNode(ctx context.Context, k8s kubernetes.Interface, name string) error
func DeletePod(ctx context.Context, k8s kubernetes.Interface, name, namespace string) error
func DrainNode(ctx context.Context, k8s kubernetes.Interface, node *corev1.Node) error
func EnsureNodeWithE2ELabelIsDeleted(ctx context.Context, k8s kubernetes.Interface, nodeName string) error
func ExecPodWithRetries(ctx context.Context, config *restclient.Config, k8s kubernetes.Interface, ...) (stdout, stderr string, err error)
func GetDaemonSet(ctx context.Context, logger logr.Logger, k8s kubernetes.Interface, ...) (*appsv1.DaemonSet, error)
func GetNginxPodName(name string) string
func GetNodeInternalIP(node *corev1.Node) string
func GetPodLogsWithRetries(ctx context.Context, k8s kubernetes.Interface, name, namespace string) (logs string, err error)
func IsPreviousVersionSupported(kubernetesVersion string) (bool, error)
func NewServiceAccount(ctx context.Context, logger logr.Logger, k8s kubernetes.Interface, ...) error
func PreviousVersion(kubernetesVersion string) (string, error)
func UncordonNode(ctx context.Context, k8s kubernetes.Interface, node *corev1.Node) error
func WaitForDaemonSetPodToBeRunning(ctx context.Context, k8s kubernetes.Interface, ...) error
func WaitForHybridNodeToBeNotReady(ctx context.Context, k8s kubernetes.Interface, nodeName string, ...) error
func WaitForHybridNodeToBeReady(ctx context.Context, k8s kubernetes.Interface, nodeName string, ...) (*corev1.Node, error)
func WaitForNode(ctx context.Context, k8s kubernetes.Interface, nodeName string, ...) (*corev1.Node, error)
func WaitForNodeToHaveVersion(ctx context.Context, k8s kubernetes.Interface, nodeName, targetVersion string, ...) (*corev1.Node, error)
type VerifyNode
- func (v VerifyNode) Run(ctx context.Context) error
- func (v VerifyNode) WaitForNodeReady(ctx context.Context) (*corev1.Node, error)

Constants ¶

View Source

const (
	MinimumVersion = "1.25"
)

Variables ¶

This section is empty.

Functions ¶

func CheckForNodeWithE2ELabel ¶ added in v1.0.4

func CheckForNodeWithE2ELabel(ctx context.Context, k8s kubernetes.Interface, nodeName string) (*corev1.Node, error)

func CordonNode ¶

func CordonNode(ctx context.Context, k8s kubernetes.Interface, node *corev1.Node, logger logr.Logger) error

func CreateNginxPodInNode ¶

func CreateNginxPodInNode(ctx context.Context, k8s kubernetes.Interface, nodeName, namespace, region string, logger logr.Logger) error

func CreatePod ¶ added in v1.0.4

func CreatePod(ctx context.Context, k8s kubernetes.Interface, pod *corev1.Pod, logger logr.Logger) error

func DeleteNode ¶

func DeleteNode(ctx context.Context, k8s kubernetes.Interface, name string) error

func DeletePod ¶

func DeletePod(ctx context.Context, k8s kubernetes.Interface, name, namespace string) error

func DrainNode ¶

func DrainNode(ctx context.Context, k8s kubernetes.Interface, node *corev1.Node) error

func EnsureNodeWithE2ELabelIsDeleted ¶ added in v1.0.4

func EnsureNodeWithE2ELabelIsDeleted(ctx context.Context, k8s kubernetes.Interface, nodeName string) error

func ExecPodWithRetries ¶ added in v1.0.2

func ExecPodWithRetries(ctx context.Context, config *restclient.Config, k8s kubernetes.Interface, name, namespace string, cmd ...string) (stdout, stderr string, err error)

Retries up to 5 times to avoid connection errors

func GetDaemonSet ¶ added in v1.0.2

func GetDaemonSet(ctx context.Context, logger logr.Logger, k8s kubernetes.Interface, namespace, name string) (*appsv1.DaemonSet, error)

func GetNginxPodName ¶

func GetNginxPodName(name string) string

func GetNodeInternalIP ¶ added in v1.0.4

func GetNodeInternalIP(node *corev1.Node) string

func GetPodLogsWithRetries ¶ added in v1.0.2

func GetPodLogsWithRetries(ctx context.Context, k8s kubernetes.Interface, name, namespace string) (logs string, err error)

Retries up to 5 times to avoid connection errors

func IsPreviousVersionSupported ¶

func IsPreviousVersionSupported(kubernetesVersion string) (bool, error)

func NewServiceAccount ¶ added in v1.0.3

func NewServiceAccount(ctx context.Context, logger logr.Logger, k8s kubernetes.Interface, namespace, name string) error

func PreviousVersion ¶

func PreviousVersion(kubernetesVersion string) (string, error)

func UncordonNode ¶

func UncordonNode(ctx context.Context, k8s kubernetes.Interface, node *corev1.Node) error

func WaitForDaemonSetPodToBeRunning ¶ added in v1.0.4

func WaitForDaemonSetPodToBeRunning(ctx context.Context, k8s kubernetes.Interface, namespace, daemonSetName, nodeName string, logger logr.Logger) error

func WaitForHybridNodeToBeNotReady ¶

func WaitForHybridNodeToBeNotReady(ctx context.Context, k8s kubernetes.Interface, nodeName string, logger logr.Logger) error

func WaitForHybridNodeToBeReady ¶

func WaitForHybridNodeToBeReady(ctx context.Context, k8s kubernetes.Interface, nodeName string, logger logr.Logger) (*corev1.Node, error)

WaitForHybridNodeToBeReady will continue to poll until the node is: - marked ready - cilium-agent taint is removed (agent is ready on this node) - nodeNetworkAvailable is true - internal IP address is set

func WaitForNode ¶

func WaitForNode(ctx context.Context, k8s kubernetes.Interface, nodeName string, logger logr.Logger) (*corev1.Node, error)

WaitForNode wait for the node to join the cluster and fetches the node info which has the nodeName label

func WaitForNodeToHaveVersion ¶

func WaitForNodeToHaveVersion(ctx context.Context, k8s kubernetes.Interface, nodeName, targetVersion string, logger logr.Logger) (*corev1.Node, error)

Types ¶

type VerifyNode ¶

type VerifyNode struct {
	ClientConfig *rest.Config
	K8s          clientgo.Interface
	Logger       logr.Logger
	Region       string

	NodeName string
	NodeIP   string
}

VerifyNode checks that a node is healthy, can run pods, extract logs and run commands on them.

func (VerifyNode) Run ¶

func (v VerifyNode) Run(ctx context.Context) error

func (VerifyNode) WaitForNodeReady ¶ added in v1.0.3

func (v VerifyNode) WaitForNodeReady(ctx context.Context) (*corev1.Node, error)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL