instrumentation

package

v0.8.2 Latest Latest Go to latest Published: Sep 17, 2025 License: Apache-2.0 Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

func NewPGDumpAllFn(pgdumpallFn pglib.PGDumpAllFn, instrumentation *otel.Instrumentation) pglib.PGDumpAllFn

func NewPGDumpFn(pgdumpFn pglib.PGDumpFn, instrumentation *otel.Instrumentation) pglib.PGDumpFn

func NewPGRestoreFn(pgrestoreFn pglib.PGRestoreFn, instrumentation *otel.Instrumentation) pglib.PGRestoreFn

func NewQuerier(q pglib.Querier, instrumentation *otel.Instrumentation) (pglib.Querier, error)

func NewQuerierBuilder(b pglib.QuerierBuilder, i *otel.Instrumentation) (pglib.QuerierBuilder, error)

func NewTx(t pglib.Tx, instrumentation *otel.Instrumentation) pglib.Tx

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

func (i *PGDumpRestore) PGDump(ctx context.Context, opts pglib.PGDumpOptions) (dump []byte, err error)

func (i *PGDumpRestore) PGDumpAll(ctx context.Context, opts pglib.PGDumpAllOptions) (dump []byte, err error)

func (i *PGDumpRestore) PGRestore(ctx context.Context, opts pglib.PGRestoreOptions, dump []byte) (out string, err error)

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

func (i *Querier) Close(ctx context.Context) (err error)

func (i *Querier) CopyFrom(ctx context.Context, tableName string, columnNames []string, srcRows [][]any) (rowCount int64, err error)

func (i *Querier) Exec(ctx context.Context, query string, args ...any) (tag pglib.CommandTag, err error)

func (i *Querier) ExecInTx(ctx context.Context, fn func(tx pglib.Tx) error) (err error)

func (i *Querier) ExecInTxWithOptions(ctx context.Context, fn func(tx pglib.Tx) error, txOpts pglib.TxOptions) (err error)

func (i *Querier) Ping(ctx context.Context) (err error)

func (i *Querier) Query(ctx context.Context, query string, args ...any) (rows pglib.Rows, err error)

func (i *Querier) QueryRow(ctx context.Context, query string, args ...any) pglib.Row

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

func (i *Tx) CopyFrom(ctx context.Context, tableName string, columnNames []string, srcRows [][]any) (rowCount int64, err error)

func (i *Tx) Exec(ctx context.Context, query string, args ...any) (tag pglib.CommandTag, err error)

func (i *Tx) Query(ctx context.Context, query string, args ...any) (rows pglib.Rows, err error)

func (i *Tx) QueryRow(ctx context.Context, query string, args ...any) pglib.Row