1515package main
1616
1717import (
18+ "context"
1819 "flag"
1920 "fmt"
20- recovery "github.com/grpc-ecosystem/go-grpc-middleware/recovery"
21+ "net"
22+ "net/http"
23+ "os"
24+ "sync"
25+
2126 embedetcd "github.com/linkall-labs/embed-etcd"
2227 "github.com/linkall-labs/vanus/internal/controller"
2328 "github.com/linkall-labs/vanus/internal/controller/eventbus"
@@ -28,28 +33,36 @@ import (
2833 "github.com/linkall-labs/vanus/observability/log"
2934 "github.com/linkall-labs/vanus/observability/metrics"
3035 ctrlpb "github.com/linkall-labs/vanus/proto/pkg/controller"
36+
37+ recovery "github.com/grpc-ecosystem/go-grpc-middleware/recovery"
3138 "github.com/prometheus/client_golang/prometheus/promhttp"
3239 "google.golang.org/grpc"
3340 "google.golang.org/grpc/reflection"
34- "net"
35- "net/http"
36- "os"
37- "sync"
3841)
3942
4043var (
41- configPath = flag .String ("config-file " , "./config/controller.yaml" , "the configuration file of controller" )
44+ configPath = flag .String ("config" , "./config/controller.yaml" , "the configuration file of controller" )
4245)
4346
4447func main () {
4548 flag .Parse ()
46- ctx := signal . SetupSignalContext ()
49+
4750 cfg , err := controller .InitConfig (* configPath )
4851 if err != nil {
49- log .Error (ctx , "init config error" , map [string ]interface {}{log .KeyError : err })
52+ log .Error (context .Background (), "init config error" , map [string ]interface {}{
53+ log .KeyError : err ,
54+ })
55+ os .Exit (- 1 )
56+ }
57+ listen , err := net .Listen ("tcp" , fmt .Sprintf (":%d" , cfg .Port ))
58+ if err != nil {
59+ log .Error (context .Background (), "failed to listen" , map [string ]interface {}{
60+ "error" : err ,
61+ })
5062 os .Exit (- 1 )
5163 }
5264
65+ ctx := signal .SetupSignalContext ()
5366 go startMetrics ()
5467 etcd := embedetcd .New (cfg .Topology )
5568 if err = etcd .Init (ctx , cfg .GetEtcdConfig ()); err != nil {
@@ -85,14 +98,6 @@ func main() {
8598 os .Exit (- 1 )
8699 }
87100
88- listen , err := net .Listen ("tcp" , fmt .Sprintf (":%d" , cfg .Port ))
89- if err != nil {
90- log .Error (ctx , "failed to listen" , map [string ]interface {}{
91- "error" : err ,
92- })
93- os .Exit (- 1 )
94- }
95-
96101 grpcServer := grpc .NewServer (
97102 grpc .ChainStreamInterceptor (
98103 recovery .StreamServerInterceptor (),
0 commit comments