|
|
@ -2,8 +2,9 @@ package db |
|
|
|
|
|
|
|
|
|
|
|
import ( |
|
|
|
import ( |
|
|
|
"context" |
|
|
|
"context" |
|
|
|
"fmt" |
|
|
|
|
|
|
|
"log" |
|
|
|
"log" |
|
|
|
|
|
|
|
"net" |
|
|
|
|
|
|
|
"strconv" |
|
|
|
|
|
|
|
|
|
|
|
"git.slaventius.ru/test3k/auth/internal/config" |
|
|
|
"git.slaventius.ru/test3k/auth/internal/config" |
|
|
|
|
|
|
|
|
|
|
@ -20,8 +21,8 @@ type AuthDBClient struct { |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
func NewDBClient(ctx context.Context, config *config.Config) *AuthDBClient { |
|
|
|
func NewDBClient(ctx context.Context, config *config.Config) *AuthDBClient { |
|
|
|
connStr := fmt.Sprintf("%s:%d", config.Db.Host, config.Db.Port) |
|
|
|
conStr := net.JoinHostPort(config.Db.Host, strconv.Itoa(config.Db.Port)) |
|
|
|
client, err := grpc.Dial(connStr, grpc.WithInsecure()) |
|
|
|
client, err := grpc.Dial(conStr, grpc.WithInsecure()) |
|
|
|
if err != nil { |
|
|
|
if err != nil { |
|
|
|
log.Fatal(err) |
|
|
|
log.Fatal(err) |
|
|
|
} |
|
|
|
} |
|
|
|