Merge pull request #2459 from headlamp-k8s/websocket-multiplexer

backend: Add websocket multiplexer
headlamp-k8s · Oct 24, 2024 · dd9697a · dd9697a
2 parents 0979b16 + bf2ec6d
commit dd9697a
Show file tree

Hide file tree

Showing 4 changed files with 1,064 additions and 0 deletions.
diff --git a/backend/cmd/headlamp.go b/backend/cmd/headlamp.go
@@ -59,6 +59,7 @@ type HeadlampConfig struct {
 	proxyURLs             []string
 	cache                 cache.Cache[interface{}]
 	kubeConfigStore       kubeconfig.ContextStore
+	multiplexer           *Multiplexer
 }
 
 const DrainNodeCacheTTL = 20 // seconds
@@ -1599,6 +1600,9 @@ func (c *HeadlampConfig) addClusterSetupRoute(r *mux.Router) {
 
 	// Rename a cluster
 	r.HandleFunc("/cluster/{name}", c.renameCluster).Methods("PUT")
+
+	// Websocket connections
+	r.HandleFunc("/wsMutliplexer", c.multiplexer.HandleClientWebSocket)
 }
 
 /*