|
@@ -63,9 +63,7 @@ func StartUp(Version string) {
|
|
if e != nil {
|
|
if e != nil {
|
|
logger.Fatal("Listen error: ", e)
|
|
logger.Fatal("Listen error: ", e)
|
|
}
|
|
}
|
|
- msg := fmt.Sprintf("Serving kuiper (version - %s) on port %d... \n", Version, common.Config.Port)
|
|
|
|
- logger.Info(msg)
|
|
|
|
- fmt.Printf(msg)
|
|
|
|
|
|
+
|
|
if common.Config.Prometheus {
|
|
if common.Config.Prometheus {
|
|
go func() {
|
|
go func() {
|
|
port := common.Config.PrometheusPort
|
|
port := common.Config.PrometheusPort
|
|
@@ -84,12 +82,17 @@ func StartUp(Version string) {
|
|
|
|
|
|
//Start rest service
|
|
//Start rest service
|
|
srv := createRestServer(common.Config.RestPort)
|
|
srv := createRestServer(common.Config.RestPort)
|
|
|
|
+
|
|
go func() {
|
|
go func() {
|
|
if err := srv.ListenAndServe(); err != nil {
|
|
if err := srv.ListenAndServe(); err != nil {
|
|
logger.Fatal("Error serving rest service: ", err)
|
|
logger.Fatal("Error serving rest service: ", err)
|
|
}
|
|
}
|
|
}()
|
|
}()
|
|
|
|
|
|
|
|
+ msg := fmt.Sprintf("Serving kuiper (version - %s) on port %d, and restful api on port %d. \n", Version, common.Config.Port, common.Config.RestPort)
|
|
|
|
+ logger.Info(msg)
|
|
|
|
+ fmt.Printf(msg)
|
|
|
|
+
|
|
// Start accept incoming HTTP connections
|
|
// Start accept incoming HTTP connections
|
|
err = http.Serve(listener, nil)
|
|
err = http.Serve(listener, nil)
|
|
if err != nil {
|
|
if err != nil {
|