Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- package main
- func main {
- dbHost := config.GetString(`database.host`)
- dbPort := config.GetString(`database.port`)
- dbUser := config.GetString(`database.user`)
- dbPass := config.GetString(`database.pass`)
- dbName := config.GetString(`database.name`)
- connection := fmt.Sprintf("%s:%s@tcp(%s:%s)/%s", dbUser, dbPass, dbHost, dbPort, dbName)
- val := url.Values{}
- val.Add("parseTime", "1")
- val.Add("loc", "Asia/Jakarta")
- dsn := fmt.Sprintf("%s?%s", connection, val.Encode())
- dbConn, err := sql.Open(`mysql`, dsn)
- if err != nil && config.GetBool("debug") {
- logrus.Error(err)
- }
- defer dbConn.Close()
- ar := articleRepo.NewMysqlArticleRepository(dbConn)
- au := articleUcase.NewArticleUsecase(ar)
- list, err := net.Listen("tcp", ":8080")
- if err != nil {
- logrus.Error(err)
- }
- server := grpc.NewServer()
- deliveryGrpc.NewArticleServerGrpc(server, au)
- server.Serve(list)
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement