Documentation
¶
Index ¶
- func Migrate(pool *pgxpool.Pool, log *slog.Logger) error
- func NewConnPool(ctx context.Context, dbConnDSN string, log *slog.Logger, ...) (*pgxpool.Pool, io.Closer, error)
- func RegisterPoolMetrics(meter metric.Meter, pool *pgxpool.Pool) error
- type ConnPoolOption
- type QueryMetricsTracer
- type RequestStats
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewConnPool ¶
Types ¶
type ConnPoolOption ¶
func WithQueryTracer ¶
func WithQueryTracer(tracer pgx.QueryTracer) ConnPoolOption
type QueryMetricsTracer ¶
type QueryMetricsTracer struct {
// contains filtered or unexported fields
}
func NewQueryMetricsTracer ¶
func NewQueryMetricsTracer(meter metric.Meter) (*QueryMetricsTracer, error)
func (*QueryMetricsTracer) TraceQueryEnd ¶
func (t *QueryMetricsTracer) TraceQueryEnd(ctx context.Context, _ *pgx.Conn, data pgx.TraceQueryEndData)
func (*QueryMetricsTracer) TraceQueryStart ¶
func (t *QueryMetricsTracer) TraceQueryStart(ctx context.Context, _ *pgx.Conn, data pgx.TraceQueryStartData) context.Context
type RequestStats ¶
type RequestStats struct {
// contains filtered or unexported fields
}
RequestStats accumulates per-request query count and total time spent in the database, so a request can be classified as DB-bound vs render-bound.
func WithRequestStats ¶
func WithRequestStats(ctx context.Context) (context.Context, *RequestStats)
WithRequestStats attaches a fresh RequestStats to ctx. The query tracer adds to it on every query that runs under the returned context.
func (*RequestStats) DBDuration ¶
func (rs *RequestStats) DBDuration() time.Duration
func (*RequestStats) Queries ¶
func (rs *RequestStats) Queries() int64
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.