pgx

package module
v2.0.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 13, 2024 License: GPL-3.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BatchEndFn added in v2.0.1

type BatchEndFn func(*pgx.Conn, pgx.TraceBatchEndData)

type BatchQueryFn added in v2.0.1

type BatchQueryFn func(*pgx.Conn, pgx.TraceBatchQueryData)

type Callback added in v2.0.1

type Callback interface {
	Query(context.Context, pgx.TraceQueryStartData) (context.Context, QueryFn)
	Batch(context.Context, pgx.TraceBatchStartData) (context.Context, BatchQueryFn, BatchEndFn)
	Copy(context.Context, pgx.TraceCopyFromStartData) (context.Context, CopyFn)
	Connect(context.Context, pgx.TraceConnectStartData) (context.Context, ConnectFn)
	Prepare(context.Context, pgx.TracePrepareStartData) (context.Context, PrepareFn)
}

type ConnectFn added in v2.0.1

type ConnectFn func(pgx.TraceConnectEndData)

type CopyFn added in v2.0.1

type CopyFn func(*pgx.Conn, pgx.TraceCopyFromEndData)

type ErrorToSpanStatus added in v2.0.1

type ErrorToSpanStatus func(err error) (codes.Code, string)

type LoggerConfig added in v2.0.1

type LoggerConfig struct {
	Dump bool

	NameFormatter NameFormatter
}

type NameFormatter added in v2.0.1

type NameFormatter func(ctx context.Context, op string) string

type Option added in v2.0.1

type Option interface {
	// contains filtered or unexported methods
}

Option interface used for setting optional config properties.

func WithLoggerConfig added in v2.0.1

func WithLoggerConfig(cfg LoggerConfig) Option

WithLoggerConfig overwrite default logger configuration

func WithLoggerDumpSQL added in v2.0.1

func WithLoggerDumpSQL(enable bool) Option

WithLoggerDumpSQL perform by logging debug dump sql and arguments

func WithLoggerNameFormatter added in v2.0.1

func WithLoggerNameFormatter(fn NameFormatter) Option

func WithMeterProvider added in v2.0.1

func WithMeterProvider(p metric.MeterProvider) Option

WithMeterProvider sets meter provider.

func WithRecordConfig added in v2.0.1

func WithRecordConfig(cfg RecordConfig) Option

WithRecordConfig overwrite default metric configuration

func WithRecordDefaultArgs added in v2.0.1

func WithRecordDefaultArgs(args ...attribute.KeyValue) Option

func WithTel added in v2.0.1

func WithTel(t *tel.Telemetry) Option

WithTel also add options to pass own metric and trace provider

func WithTraceConfig added in v2.0.1

func WithTraceConfig(cfg TraceConfig) Option

WithTraceConfig overwrite default trace configuration

func WithTraceDefaultArgs added in v2.0.1

func WithTraceDefaultArgs(args ...attribute.KeyValue) Option

func WithTraceRoot added in v2.0.1

func WithTraceRoot(enable bool) Option

WithTraceRoot create trace if nod parent span occurred

func WithTracerNameFormatter added in v2.0.1

func WithTracerNameFormatter(fn NameFormatter) Option

type PrepareFn added in v2.0.1

type PrepareFn func(*pgx.Conn, pgx.TracePrepareEndData)

type QueryFn added in v2.0.1

type QueryFn func(*pgx.Conn, pgx.TraceQueryEndData)

type RecordConfig added in v2.0.1

type RecordConfig struct {
	DefaultAttributes []attribute.KeyValue
	// contains filtered or unexported fields
}

type TraceConfig added in v2.0.1

type TraceConfig struct {
	AllowRootTrace    bool
	NameFormatter     NameFormatter
	DefaultAttributes []attribute.KeyValue
	ErrorToStatus     ErrorToSpanStatus
}

type TraceLog added in v2.0.1

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

TraceLog implements pgx.QueryTracer, pgx.BatchTracer, pgx.ConnectTracer, and pgx.CopyFromTracer. All fields are required.

func New added in v2.0.1

func New(opts ...Option) (*TraceLog, error)

func (*TraceLog) TraceBatchEnd added in v2.0.1

func (tl *TraceLog) TraceBatchEnd(ctx context.Context, conn *pgx.Conn, data pgx.TraceBatchEndData)

func (*TraceLog) TraceBatchQuery added in v2.0.1

func (tl *TraceLog) TraceBatchQuery(ctx context.Context, conn *pgx.Conn, data pgx.TraceBatchQueryData)

func (*TraceLog) TraceBatchStart added in v2.0.1

func (tl *TraceLog) TraceBatchStart(ctx context.Context, conn *pgx.Conn, data pgx.TraceBatchStartData) context.Context

func (*TraceLog) TraceConnectEnd added in v2.0.1

func (tl *TraceLog) TraceConnectEnd(ctx context.Context, data pgx.TraceConnectEndData)

func (*TraceLog) TraceConnectStart added in v2.0.1

func (tl *TraceLog) TraceConnectStart(ctx context.Context, data pgx.TraceConnectStartData) context.Context

func (*TraceLog) TraceCopyFromEnd added in v2.0.1

func (tl *TraceLog) TraceCopyFromEnd(ctx context.Context, conn *pgx.Conn, data pgx.TraceCopyFromEndData)

func (*TraceLog) TraceCopyFromStart added in v2.0.1

func (tl *TraceLog) TraceCopyFromStart(ctx context.Context, conn *pgx.Conn, data pgx.TraceCopyFromStartData) context.Context

func (*TraceLog) TracePrepareEnd added in v2.0.1

func (tl *TraceLog) TracePrepareEnd(ctx context.Context, conn *pgx.Conn, data pgx.TracePrepareEndData)

func (*TraceLog) TracePrepareStart added in v2.0.1

func (tl *TraceLog) TracePrepareStart(ctx context.Context, _ *pgx.Conn, data pgx.TracePrepareStartData) context.Context

func (*TraceLog) TraceQueryEnd added in v2.0.1

func (tl *TraceLog) TraceQueryEnd(ctx context.Context, conn *pgx.Conn, data pgx.TraceQueryEndData)

func (*TraceLog) TraceQueryStart added in v2.0.1

func (tl *TraceLog) TraceQueryStart(ctx context.Context, conn *pgx.Conn, data pgx.TraceQueryStartData) context.Context

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL