分享
聊聊storagetapper的server
codecraft · · 837 次点击 · · 开始浏览这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。
序
本文主要研究一下storagetapper的server
server
storagetapper/server/server.go
var server *http.Server
var mutex = sync.Mutex{}
func init() {
http.HandleFunc("/health", healthCheck)
http.HandleFunc("/schema", schemaCmd)
http.HandleFunc("/cluster", clusterInfoCmd)
http.HandleFunc("/table", tableCmd)
http.HandleFunc("/config", configCmd)
http.HandleFunc("/", indexCmd)
}
//StartHTTPServer starts listening and serving traffic on configured port and sets up http routes.
func StartHTTPServer(port int) {
state.EmitRegisteredTablesCount()
mutex.Lock()
server = &http.Server{Addr: fmt.Sprintf(":%d", port), Handler: nil}
log.Debugf("HTTP server is listening on %v port", port)
mutex.Unlock()
err := server.ListenAndServe()
if err != nil && err != http.ErrServerClosed {
log.E(err)
}
}
//Shutdown gracefully stops the server
func Shutdown() {
mutex.Lock()
defer mutex.Unlock()
if server == nil {
return
}
ctx, cancel := context.WithCancel(context.Background())
defer cancel()
log.E(server.Shutdown(ctx))
server = nil
}storagetapper的server提供了StartHTTPServer、Shutdown方法;其init方法注册了/health,/schema,/cluster,/table,/config,/这几个url
healthCheck
storagetapper/server/server.go
//healthCheck handles call to the health check endpoint
func healthCheck(w http.ResponseWriter, r *http.Request) {
w.Header().Add("Content-Type", "text/plain")
w.WriteHeader(http.StatusOK)
if _, err := w.Write([]byte("OK")); err != nil {
log.Errorf("Health check failed: %s\n", err)
}
}healthCheck返回200,文本内容为OK
小结
storagetapper的server提供了StartHTTPServer、Shutdown方法;其init方法注册了/health,/schema,/cluster,/table,/config,/这几个url。
doc
有疑问加站长微信联系(非本文作者)
入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889
关注微信837 次点击
添加一条新回复
(您需要 后才能回复 没有账号 ?)
- 请尽量让自己的回复能够对别人有帮助
- 支持 Markdown 格式, **粗体**、~~删除线~~、
`单行代码` - 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
- 图片支持拖拽、截图粘贴等方式上传
收入到我管理的专栏 新建专栏
序
本文主要研究一下storagetapper的server
server
storagetapper/server/server.go
var server *http.Server
var mutex = sync.Mutex{}
func init() {
http.HandleFunc("/health", healthCheck)
http.HandleFunc("/schema", schemaCmd)
http.HandleFunc("/cluster", clusterInfoCmd)
http.HandleFunc("/table", tableCmd)
http.HandleFunc("/config", configCmd)
http.HandleFunc("/", indexCmd)
}
//StartHTTPServer starts listening and serving traffic on configured port and sets up http routes.
func StartHTTPServer(port int) {
state.EmitRegisteredTablesCount()
mutex.Lock()
server = &http.Server{Addr: fmt.Sprintf(":%d", port), Handler: nil}
log.Debugf("HTTP server is listening on %v port", port)
mutex.Unlock()
err := server.ListenAndServe()
if err != nil && err != http.ErrServerClosed {
log.E(err)
}
}
//Shutdown gracefully stops the server
func Shutdown() {
mutex.Lock()
defer mutex.Unlock()
if server == nil {
return
}
ctx, cancel := context.WithCancel(context.Background())
defer cancel()
log.E(server.Shutdown(ctx))
server = nil
}storagetapper的server提供了StartHTTPServer、Shutdown方法;其init方法注册了/health,/schema,/cluster,/table,/config,/这几个url
healthCheck
storagetapper/server/server.go
//healthCheck handles call to the health check endpoint
func healthCheck(w http.ResponseWriter, r *http.Request) {
w.Header().Add("Content-Type", "text/plain")
w.WriteHeader(http.StatusOK)
if _, err := w.Write([]byte("OK")); err != nil {
log.Errorf("Health check failed: %s\n", err)
}
}healthCheck返回200,文本内容为OK
小结
storagetapper的server提供了StartHTTPServer、Shutdown方法;其init方法注册了/health,/schema,/cluster,/table,/config,/这几个url。