utils

Documentation

Index

• func BuildRestConfig(c *kubeconfig.KubeconfigBuilder) (*rest.Config, error)
• func ClusterApply(clientset simple.Clientset, clusterName string, allowKopsDowngrade bool, ...) error
• func ClusterExists(clientset simple.Clientset, clusterName string) (bool, error)
• func ClusterInstanceGroupsNeedingUpdate(clientset simple.Clientset, clusterName string) ([]string, error)
• func ClusterIsValid(clientset simple.Clientset, clusterName string) (bool, error)
• func ClusterRollingUpdate(clientset simple.Clientset, clusterName string, options RollingUpdateOptions) error
• func ClusterValidate(clientset simple.Clientset, clusterName string, options ValidateOptions) error
• func GetKubeConfigBuilder(clientset simple.Clientset, clusterName string, admin *time.Duration, ...) (*kubeconfig.KubeconfigBuilder, error)
• func InstanceGroupDelete(clientset simple.Clientset, clusterName string, instanceGroupName string) error
• func ParseLifecycle(lifecycle string) (fi.Lifecycle, error)
• func ParseLifecycleOverrides(lifecycleOverrides map[string]string) (map[string]fi.Lifecycle, error)
• type RollingUpdateOptions
• type ValidateOptions

Functions

func BuildRestConfig

func BuildRestConfig(c *kubeconfig.KubeconfigBuilder) (*rest.Config, error)

Create new Rest Client

func ClusterApply

func ClusterApply(clientset simple.Clientset, clusterName string, allowKopsDowngrade bool, lifecycleOverrides map[string]fi.Lifecycle, prune bool) error

func ClusterExists

func ClusterExists(clientset simple.Clientset, clusterName string) (bool, error)

func ClusterInstanceGroupsNeedingUpdate

func ClusterInstanceGroupsNeedingUpdate(clientset simple.Clientset, clusterName string) ([]string, error)

func ClusterIsValid

func ClusterIsValid(clientset simple.Clientset, clusterName string) (bool, error)

func ClusterRollingUpdate

func ClusterRollingUpdate(clientset simple.Clientset, clusterName string, options RollingUpdateOptions) error

func ClusterValidate

func ClusterValidate(clientset simple.Clientset, clusterName string, options ValidateOptions) error

func GetKubeConfigBuilder

func GetKubeConfigBuilder(clientset simple.Clientset, clusterName string, admin *time.Duration, internal bool) (*kubeconfig.KubeconfigBuilder, error)

func InstanceGroupDelete

func InstanceGroupDelete(clientset simple.Clientset, clusterName string, instanceGroupName string) error

func ParseLifecycle

func ParseLifecycle(lifecycle string) (fi.Lifecycle, error)

func ParseLifecycleOverrides

func ParseLifecycleOverrides(lifecycleOverrides map[string]string) (map[string]fi.Lifecycle, error)

Types

type RollingUpdateOptions

type RollingUpdateOptions struct {
	// MasterInterval is the amount of time to wait after stopping a master instance
	MasterInterval *metav1.Duration
	// NodeInterval is the amount of time to wait after stopping a non-master instance
	NodeInterval *metav1.Duration
	// BastionInterval is the amount of time to wait after stopping a bastion instance
	BastionInterval *metav1.Duration
	// FailOnDrainError will fail when a drain error occurs
	FailOnDrainError bool
	// FailOnValidate will fail when a validation error occurs
	FailOnValidate bool
	// PostDrainDelay is the duration we wait after draining each node
	PostDrainDelay *metav1.Duration
	// ValidationTimeout is the maximum time to wait for the cluster to validate, once we start validation
	ValidationTimeout *metav1.Duration
	// ValidateCount is the amount of time that a cluster needs to be validated after single node update
	ValidateCount *int
	// CloudOnly perform rolling update without confirming progress with k8s
	CloudOnly bool
	// Force forces a rolling update
	Force bool
}

type ValidateOptions

type ValidateOptions struct {
	// Timeout defines the maximum time to wait until the cluster becomes valid
	Timeout *metav1.Duration
	// PollInterval defines the interval between validation attempts
	PollInterval *metav1.Duration
}