windy/kafka-proxy
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

delete unused

Browse Source
This commit is contained in:
fengzhiqiang
2019-01-09 11:20:02 +08:00
parent bcac07e597
commit 3c6e47d85c
1 changed files with 0 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
serv.go
-5
View File
@@ -306,11 +306,6 @@ func main() {
Handler: loggedRouter, // Pass our instance of gorilla/mux in. Handler: loggedRouter, // Pass our instance of gorilla/mux in.
} }
// hub := newHub()
// go hub.run()
// r.HandleFunc("/ws/{topic}/{offset}", func(w http.ResponseWriter, r *http.Request) {
// serveWs(w, r)
// })
router.Path("/ws/{topic}/{partition}").Queries("offset", "{offset}").HandlerFunc(websocketHandler).Name("web-socket") router.Path("/ws/{topic}/{partition}").Queries("offset", "{offset}").HandlerFunc(websocketHandler).Name("web-socket")
// Run our server in a goroutine so that it doesn't block. // Run our server in a goroutine so that it doesn't block.