52 lines
851 B
Go
52 lines
851 B
Go
package admin
|
|
|
|
import (
|
|
"net"
|
|
"net/http"
|
|
"strings"
|
|
|
|
"github.com/rakyll/statik/fs"
|
|
|
|
_ "github.com/influxdb/influxdb/statik"
|
|
)
|
|
|
|
type HttpServer struct {
|
|
port string
|
|
listener net.Listener
|
|
closed bool
|
|
}
|
|
|
|
// port should be a string that looks like ":8083" or whatever port to serve on.
|
|
func NewHttpServer(port string) *HttpServer {
|
|
return &HttpServer{port: port, closed: true}
|
|
}
|
|
|
|
func (self *HttpServer) ListenAndServe() {
|
|
if self.port == "" {
|
|
return
|
|
}
|
|
|
|
self.closed = false
|
|
var err error
|
|
self.listener, err = net.Listen("tcp", self.port)
|
|
if err != nil {
|
|
panic(err)
|
|
}
|
|
|
|
statikFS, _ := fs.New()
|
|
|
|
err = http.Serve(self.listener, http.FileServer(statikFS))
|
|
if !strings.Contains(err.Error(), "closed") {
|
|
panic(err)
|
|
}
|
|
}
|
|
|
|
func (self *HttpServer) Close() {
|
|
if self.closed {
|
|
return
|
|
}
|
|
|
|
self.closed = true
|
|
self.listener.Close()
|
|
}
|