|
|
@ -61,13 +61,17 @@ func start(config *config.Config, s *grpc.Server, srv *server.AuthDBServer, canc |
|
|
|
|
|
|
|
|
|
|
|
//
|
|
|
|
//
|
|
|
|
connStr := net.JoinHostPort("", strconv.Itoa(config.App.Port)) |
|
|
|
connStr := net.JoinHostPort("", strconv.Itoa(config.App.Port)) |
|
|
|
|
|
|
|
kafkaStr := net.JoinHostPort(config.Kafka.Host, strconv.Itoa(config.Kafka.Port)) |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
//
|
|
|
|
lis, era := net.Listen("tcp", connStr) |
|
|
|
lis, era := net.Listen("tcp", connStr) |
|
|
|
if era != nil { |
|
|
|
if era != nil { |
|
|
|
log.Fatal(era) |
|
|
|
log.Fatal(era) |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
//
|
|
|
|
//
|
|
|
|
log.Printf("authDBServer starting (%s)\n", connStr) |
|
|
|
log.Printf("authDBServer starting on %s\n", connStr) |
|
|
|
|
|
|
|
log.Printf("authDBServer listening on %s\n", kafkaStr) |
|
|
|
|
|
|
|
|
|
|
|
//
|
|
|
|
//
|
|
|
|
eru := s.Serve(lis) |
|
|
|
eru := s.Serve(lis) |
|
|
|