forked from delimitrou/DeathStarBench
-
Notifications
You must be signed in to change notification settings - Fork 0
/
main.go
68 lines (56 loc) · 1.96 KB
/
main.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
package main
import (
"encoding/json"
"flag"
"io/ioutil"
"os"
"strconv"
"time"
"github.com/harlow/go-micro-services/registry"
"github.com/harlow/go-micro-services/services/frontend"
"github.com/harlow/go-micro-services/tracing"
"github.com/rs/zerolog"
"github.com/rs/zerolog/log"
)
func main() {
log.Logger = zerolog.New(zerolog.ConsoleWriter{Out: os.Stdout, TimeFormat: time.RFC3339}).With().Timestamp().Caller().Logger()
log.Info().Msg("Reading config...")
jsonFile, err := os.Open("config.json")
if err != nil {
log.Error().Msgf("Got error while reading config: %v", err)
}
defer jsonFile.Close()
byteValue, _ := ioutil.ReadAll(jsonFile)
var result map[string]string
json.Unmarshal([]byte(byteValue), &result)
serv_port, _ := strconv.Atoi(result["FrontendPort"])
serv_ip := result["FrontendIP"]
log.Info().Msgf("Read target port: %v", serv_port)
log.Info().Msgf("Read consul address: %v", result["consulAddress"])
log.Info().Msgf("Read jaeger address: %v", result["jaegerAddress"])
var (
// port = flag.Int("port", 5000, "The server port")
jaegeraddr = flag.String("jaegeraddr", result["jaegerAddress"], "Jaeger address")
consuladdr = flag.String("consuladdr", result["consulAddress"], "Consul address")
)
log.Info().Msgf("Initializing jaeger agent [service name: %v | host: %v]...", "frontend", *jaegeraddr)
tracer, err := tracing.Init("frontend", *jaegeraddr)
if err != nil {
log.Panic().Msgf("Got error while initializing jaeger agent: %v", err)
}
log.Info().Msg("Jaeger agent initialized")
log.Info().Msgf("Initializing consul agent [host: %v]...", *consuladdr)
registry, err := registry.NewClient(*consuladdr)
if err != nil {
log.Panic().Msgf("Got error while initializing consul agent: %v", err)
}
log.Info().Msg("Consul agent initialized")
srv := &frontend.Server{
Registry: registry,
Tracer: tracer,
IpAddr: serv_ip,
Port: serv_port,
}
log.Info().Msg("Starting server...")
log.Fatal().Msg(srv.Run().Error())
}