some shit
This commit is contained in:
@@ -0,0 +1,5 @@
|
||||
openapi: 3.0.3
|
||||
info:
|
||||
title: logiflow
|
||||
description: API для информационной системы для логистической компании
|
||||
version: 1.0.0
|
||||
|
||||
@@ -1,5 +1,23 @@
|
||||
package database
|
||||
|
||||
import "github.com/jackc/pgx/v5/pgxpool"
|
||||
import (
|
||||
"context"
|
||||
"log/slog"
|
||||
|
||||
func NewConnectionPool(connectionString string) (*pgxpool.Pool, error)
|
||||
"github.com/jackc/pgx/v5/pgxpool"
|
||||
)
|
||||
|
||||
func NewConnectionPool(ctx context.Context, connectionString string) (*pgxpool.Pool, error) {
|
||||
pool, err := pgxpool.New(ctx, connectionString)
|
||||
if err != nil {
|
||||
slog.ErrorContext(ctx, "Cant create pool of connection", slog.String("Error", err.Error()))
|
||||
return nil, err
|
||||
}
|
||||
|
||||
if err := pool.Ping(ctx); err != nil {
|
||||
slog.ErrorContext(ctx, "Cant ping connection", slog.String("Error", err.Error()))
|
||||
return nil, err
|
||||
}
|
||||
|
||||
return pool, nil
|
||||
}
|
||||
|
||||
@@ -5,7 +5,6 @@ import (
|
||||
"log/slog"
|
||||
|
||||
"github.com/anxi0uz/logiflow/internal/config"
|
||||
"github.com/redis/go-redis"
|
||||
"github.com/redis/go-redis/v9"
|
||||
)
|
||||
|
||||
@@ -16,7 +15,7 @@ func NewRedisConnection(ctx context.Context, cfg *config.Config) (*redis.Client,
|
||||
DB: cfg.Redis.DB,
|
||||
})
|
||||
|
||||
_, err := rdb.Ping().Result()
|
||||
_, err := rdb.Ping(ctx).Result()
|
||||
if err != nil {
|
||||
slog.ErrorContext(ctx, "Cant ping redis", slog.String("Error", err.Error()))
|
||||
return nil, err
|
||||
|
||||
Reference in New Issue
Block a user