pgxwrapper

Documentation

Index

• type PgxWrapper
  • func New(ctx context.Context, dsn string, waitFor time.Duration, ...) (PgxWrapper, error)
  • func (p PgxWrapper) Exec(ctx context.Context, queryName, sql string, args ...interface{}) error
  • func (p PgxWrapper) GetConn(ctx context.Context) (*pgx.Conn, error)

Types

type PgxWrapper

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

PgxWrapper is a wrapper to jackc/pgx/v4.

func New

func New(
	ctx context.Context,
	dsn string,
	waitFor time.Duration,
	tracer opentracing.Tracer,
) (PgxWrapper, error)

New returns a new PgxWrapper given a postgresql dsn. The wrapper has built in tracing. The connection will be retried until completion.

func (PgxWrapper) Exec

func (p PgxWrapper) Exec(ctx context.Context, queryName, sql string, args ...interface{}) error

Exec is pgx's concrete implementation for executing a query with tracing.

func (PgxWrapper) GetConn

func (p PgxWrapper) GetConn(ctx context.Context) (*pgx.Conn, error)

GetConn returns the underlying pgx connection.