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 IsKurl() (bool, error)
- 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)
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // ConfigExpirationRegeneratePeriod the expiry grace period to regenerate the bootstrap token ConfigExpirationRegeneratePeriod = 10 * time.Minute )
View Source
var ErrNoEkco = errors.New("Ekco not found")
Functions ¶
func DeleteNode ¶
func GenerateAddNodeCommand ¶
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 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
Types ¶
This section is empty.
Source Files
¶
Click to show internal directories.
Click to hide internal directories.