Documentation
¶
Index ¶
- func WithTracingEnabled(ctx context.Context) context.Context
- type LogTracer
- func (l *LogTracer) TraceBatchEnd(ctx context.Context, conn *pgx.Conn, data pgx.TraceBatchEndData)
- func (l *LogTracer) TraceBatchQuery(ctx context.Context, conn *pgx.Conn, data pgx.TraceBatchQueryData)
- func (l *LogTracer) TraceBatchStart(ctx context.Context, conn *pgx.Conn, data pgx.TraceBatchStartData) context.Context
- func (l *LogTracer) TraceQueryEnd(ctx context.Context, conn *pgx.Conn, data pgx.TraceQueryEndData)
- func (l *LogTracer) TraceQueryStart(ctx context.Context, _ *pgx.Conn, data pgx.TraceQueryStartData) context.Context
- type Option
- func WithLogAllQueries() Option
- func WithLogEndHook(f func(ctx context.Context, query string, duration time.Duration)) Option
- func WithLogFailedQueries() Option
- func WithLogFailedQueryHook(f func(ctx context.Context, query string, err error)) Option
- func WithLogSlowQueriesThreshold(threshold time.Duration) Option
- func WithLogSlowQueryHook(f func(ctx context.Context, query string, duration time.Duration)) Option
- func WithLogStartHook(f func(ctx context.Context, query string, args []any)) Option
- func WithLogValues() Option
- type SQLTracer
- func (s *SQLTracer) TraceBatchEnd(ctx context.Context, conn *pgx.Conn, data pgx.TraceBatchEndData)
- func (s *SQLTracer) TraceBatchQuery(ctx context.Context, conn *pgx.Conn, data pgx.TraceBatchQueryData)
- func (s *SQLTracer) TraceBatchStart(ctx context.Context, conn *pgx.Conn, data pgx.TraceBatchStartData) context.Context
- func (s *SQLTracer) TraceQueryEnd(ctx context.Context, conn *pgx.Conn, data pgx.TraceQueryEndData)
- func (s *SQLTracer) TraceQueryStart(ctx context.Context, conn *pgx.Conn, data pgx.TraceQueryStartData) context.Context
- type Tracer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type LogTracer ¶
type LogTracer struct {
Logger *slog.Logger
LogAllQueries bool
LogFailedQueries bool
// replace placeholders with arguments useful for local debugging
LogValues bool
// enabled if non-zero value is provided
LogSlowQueriesThreshold time.Duration
// give client power to change each section which is being logged
StartQueryHook func(ctx context.Context, query string, args []any)
SlowQueryHook func(ctx context.Context, query string, duration time.Duration)
EndQueryHook func(ctx context.Context, query string, duration time.Duration)
FailedQueryHook func(ctx context.Context, query string, err error)
}
func (*LogTracer) TraceBatchEnd ¶
func (*LogTracer) TraceBatchQuery ¶
func (*LogTracer) TraceBatchStart ¶
func (*LogTracer) TraceQueryEnd ¶
type Option ¶
type Option interface {
// contains filtered or unexported methods
}
func WithLogAllQueries ¶
func WithLogAllQueries() Option
func WithLogEndHook ¶
func WithLogFailedQueries ¶
func WithLogFailedQueries() Option
func WithLogFailedQueryHook ¶
func WithLogSlowQueryHook ¶
func WithLogStartHook ¶
func WithLogValues ¶
func WithLogValues() Option
type SQLTracer ¶
type SQLTracer struct {
// contains filtered or unexported fields
}
func NewSQLTracer ¶
func (*SQLTracer) TraceBatchEnd ¶
func (*SQLTracer) TraceBatchQuery ¶
func (*SQLTracer) TraceBatchStart ¶
func (*SQLTracer) TraceQueryEnd ¶
type Tracer ¶
type Tracer interface {
pgx.QueryTracer
pgx.BatchTracer
}
Tracer see: https://github.com/jackc/pgx/blob/master/tracer.go Not implemented: CopyFromTracer, PrepareTracer, PrepareTracer ( not needed now )
Click to show internal directories.
Click to hide internal directories.