kurl

Documentation

Index

• Variables
• func DeleteNode(ctx context.Context, client kubernetes.Interface, restconfig *rest.Config, ...) error
• func DrainNode(ctx context.Context, client kubernetes.Interface, node *corev1.Node) error
• func GenerateAddNodeCommand(client kubernetes.Interface, master bool) ([]string, *time.Time, error)
• func GetNodes(client kubernetes.Interface) (*types.KurlNodes, error)
• func GetS3Secret() (*corev1.Secret, error)
• func IsKurl() bool
• func ReadConfigMap(client kubernetes.Interface) (*corev1.ConfigMap, error)
• func SyncExec(coreClient corev1client.CoreV1Interface, clientConfig *rest.Config, ...) (int, string, string, error)
• func UpdateConfigMap(client kubernetes.Interface, generateBootstrapToken, uploadCerts bool) (*corev1.ConfigMap, error)

Variables

var (
	// ConfigExpirationRegeneratePeriod the expiry grace period to regenerate the bootstrap token
	ConfigExpirationRegeneratePeriod = 10 * time.Minute
)

var ErrNoEkco = errors.New("Ekco not found")

Functions

func DeleteNode

func DeleteNode(ctx context.Context, client kubernetes.Interface, restconfig *rest.Config, node *corev1.Node) error

func DrainNode

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

func GenerateAddNodeCommand

func GenerateAddNodeCommand(client kubernetes.Interface, master bool) ([]string, *time.Time, error)

GenerateAddNodeCommand will generate the Kurl node add command for a master or worker

func GetNodes

func GetNodes(client kubernetes.Interface) (*types.KurlNodes, error)

GetNodes will get a list of nodes with stats

func GetS3Secret

func GetS3Secret() (*corev1.Secret, error)

func IsKurl

func IsKurl() bool

func ReadConfigMap

func ReadConfigMap(client kubernetes.Interface) (*corev1.ConfigMap, error)

ReadConfigMap will read the Kurl config from a configmap

func SyncExec

func SyncExec(coreClient corev1client.CoreV1Interface, clientConfig *rest.Config, ns, pod, container string, command ...string) (int, string, string, error)

SyncExec returns exitcode, stdout, stderr. A non-zero exit code from the command is not considered an error.

func UpdateConfigMap

func UpdateConfigMap(client kubernetes.Interface, generateBootstrapToken, uploadCerts bool) (*corev1.ConfigMap, error)

UpdateConfigMap will save the Kurl config in a configmap