database

Documentation

Index

• func GetDatabase() *pgx.Conn
• func InitDatabase(ctx context.Context, config DatabaseConfig) error
• func Notice(logger zerolog.Logger) pgconn.NoticeHandler
• func ParseConfig(config DatabaseConfig) (*pgx.ConnConfig, error)
• func PgError(logger zerolog.Logger) pgconn.PgErrorHandler
• func ValidateConnect(logger zerolog.Logger) func(context.Context, *pgconn.PgConn) error
• type DatabaseConfig
• type DatabaseTracer
  • func NewDatabaseTracer(logger zerolog.Logger) *DatabaseTracer
  • func (tracer *DatabaseTracer) TraceQueryEnd(ctx context.Context, conn *pgx.Conn, data pgx.TraceQueryEndData)
  • func (tracer *DatabaseTracer) TraceQueryStart(ctx context.Context, conn *pgx.Conn, data pgx.TraceQueryStartData) context.Context

Functions

func GetDatabase

func GetDatabase() *pgx.Conn

func InitDatabase

func InitDatabase(ctx context.Context, config DatabaseConfig) error

func Notice

func Notice(logger zerolog.Logger) pgconn.NoticeHandler

func ParseConfig

func ParseConfig(config DatabaseConfig) (*pgx.ConnConfig, error)

func PgError

func PgError(logger zerolog.Logger) pgconn.PgErrorHandler

func ValidateConnect

func ValidateConnect(logger zerolog.Logger) func(context.Context, *pgconn.PgConn) error

Types

type DatabaseConfig

type DatabaseConfig struct {
	Host     string
	Port     uint16
	Database string
	User     string
	Password string
	Tls      bool
}

type DatabaseTracer

type DatabaseTracer struct {
	// contains filtered or unexported fields
}

func NewDatabaseTracer

func NewDatabaseTracer(logger zerolog.Logger) *DatabaseTracer

func (*DatabaseTracer) TraceQueryEnd

func (tracer *DatabaseTracer) TraceQueryEnd(ctx context.Context, conn *pgx.Conn, data pgx.TraceQueryEndData)

func (*DatabaseTracer) TraceQueryStart

func (tracer *DatabaseTracer) TraceQueryStart(ctx context.Context, conn *pgx.Conn, data pgx.TraceQueryStartData) context.Context