websocket

Documentation

Index

• func AddExtension(repos []k0sv1beta1.Repository, chart ecv1beta1.Chart, ...) error
• func Connect(w http.ResponseWriter, r *http.Request, nodeName string) error
• func GetClients() map[string]types.WSClient
• func RemoveExtension(repos []k0sv1beta1.Repository, chart ecv1beta1.Chart, ...) error
• func UpgradeCluster(installation *ecv1beta1.Installation, appSlug, versionLabel, stepID string) error
• func UpgradeExtension(repos []k0sv1beta1.Repository, chart ecv1beta1.Chart, ...) error

Functions

func AddExtension

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) error

func GetClients

func GetClients() map[string]types.WSClient

func RemoveExtension

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

func UpgradeCluster

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 UpgradeExtension

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