websocket

func AddExtension ¶ added in v1.122.1

func AddExtension(repos []k0sv1beta1.Repository, chart ecv1beta1.Chart, appSlug, versionLabel, stepID string) error

func Connect ¶

func Connect(w http.ResponseWriter, r *http.Request, nodeName string, version string) error

func GetClients ¶

func GetClients() map[string]types.WSClient

func RemoveExtension ¶ added in v1.122.1

func RemoveExtension(repos []k0sv1beta1.Repository, chart ecv1beta1.Chart, appSlug, versionLabel, stepID string) error

func ResetClients ¶ added in v1.124.0

func ResetClients()

This is only used for testing

func UpgradeCluster ¶ added in v1.122.1

func UpgradeCluster(installation *ecv1beta1.Installation, appSlug, versionLabel, stepID string) error

UpgradeCluster sends an upgrade command to the first available websocket from the active ones

func UpgradeECManager ¶ added in v1.124.0

func UpgradeECManager(nodeName, licenseID, licenseEndpoint, version, appSlug, versionLabel, stepID string) error

UpgradeECManager sends a manager upgrade command to all managers that are not running the specified version

func UpgradeExtension ¶ added in v1.122.1

func UpgradeExtension(repos []k0sv1beta1.Repository, chart ecv1beta1.Chart, appSlug, versionLabel, stepID string) error