mirror of
https://github.com/labring/sealos.git
synced 2026-10-29 17:25:58 +08:00
* update kafka monitor * launchpad monitor * launchpad monitor * launchpad monitor * launchpad monitor * launchpad monitor * launchpad monitor * launchpad monitor * launchpad monitor * launchpad monitor * launchpad monitor * launchpad monitor * launchpad monitor * launchpad monitor * launchpad monitor * launchpad monitor * launchpad monitor * launchpad monitor * fix build error. Signed-off-by: yy <lingdie.yy@outlook.com> Signed-off-by: yy <lingdie.yy@outlook.com> --------- Signed-off-by: yy <lingdie.yy@outlook.com> Co-authored-by: yy <56745951+lingdie@users.noreply.github.com> Co-authored-by: yy <lingdie.yy@outlook.com>
65 lines
1.1 KiB
Go
65 lines
1.1 KiB
Go
package main
|
|
|
|
import (
|
|
"flag"
|
|
"fmt"
|
|
"log"
|
|
"net"
|
|
"net/http"
|
|
"os"
|
|
|
|
launchpadServer "github.com/labring/sealos/service/launchpad/server"
|
|
)
|
|
|
|
type RestartableServer struct {
|
|
configFile string
|
|
}
|
|
|
|
func (rs *RestartableServer) Serve(c *launchpadServer.Config) {
|
|
var vs, err = launchpadServer.NewVMServer(c)
|
|
if err != nil {
|
|
fmt.Printf("Failed to create auth server: %s\n", err)
|
|
return
|
|
}
|
|
|
|
hs := &http.Server{
|
|
Addr: c.Server.ListenAddress,
|
|
Handler: vs,
|
|
}
|
|
|
|
var listener net.Listener
|
|
listener, err = net.Listen("tcp", c.Server.ListenAddress)
|
|
if err != nil {
|
|
fmt.Println(err)
|
|
return
|
|
}
|
|
fmt.Printf("Serve on %s\n", c.Server.ListenAddress)
|
|
|
|
if err := hs.Serve(listener); err != nil {
|
|
fmt.Println(err)
|
|
return
|
|
}
|
|
}
|
|
|
|
func main() {
|
|
log.SetOutput(os.Stdout) // 将日志输出定向到标准输出(stdout)
|
|
log.SetFlags(log.LstdFlags | log.Lshortfile)
|
|
flag.Parse()
|
|
|
|
cf := flag.Arg(0)
|
|
if cf == "" {
|
|
fmt.Println("Config file not sepcified")
|
|
return
|
|
}
|
|
|
|
config, err := launchpadServer.InitConfig(cf)
|
|
if err != nil {
|
|
fmt.Println(err)
|
|
return
|
|
}
|
|
rs := RestartableServer{
|
|
configFile: cf,
|
|
}
|
|
rs.Serve(config)
|
|
}
|