Function NewConnectionManager

shared/messaging/connection_manager.go:37–41

Note that on multiple instances of the API gateway, the connection manager needs to store the connections on a separate shared storage.

()

// Note that on multiple instances of the API gateway, the connection manager needs to store the connections on a separate shared storage.
func NewConnectionManager() *ConnectionManager {
	return &ConnectionManager{
		connections: make(map[string]*connWrapper),
	}
}

func (cm *ConnectionManager) Upgrade(w http.ResponseWriter, r *http.Request) (*websocket.Conn, error) {
	conn, err := upgrader.Upgrade(w, r, nil)