Function handleConnection

cli/cluster/logs.go:139–150

(connection *websocket.Conn, done chan struct{})

}

func handleConnection(connection *websocket.Conn, done chan struct{}) {
	routines.RunWithPanicHandler(func() {
		defer close(done)
		for {
			_, message, err := connection.ReadMessage()
			if err != nil {
				exit.Error(ErrorOperatorSocketRead(err))
			}
			fmt.Print(string(message))
		}
	}, false)
}

func closeConnection(connection *websocket.Conn, done chan struct{}, interrupt chan os.Signal) {
	for {