retrier

package

v0.9.3 Latest Latest Go to latest Published: Dec 16, 2025 License: Apache-2.0 Imports: 7 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewQuerier(ctx context.Context, cfg backoff.Config, connBuilder connBuilder, logger loglib.Logger) (*Querier, error)

func (q *Querier) Close(ctx context.Context) error

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

func (q *Querier) Exec(ctx context.Context, query string, args ...any) (postgres.CommandTag, error)

func (q *Querier) ExecInTx(ctx context.Context, fn func(tx postgres.Tx) error) error

func (q *Querier) ExecInTxWithOptions(ctx context.Context, fn func(tx postgres.Tx) error, txOpts postgres.TxOptions) error

func (q *Querier) Ping(ctx context.Context) error

func (q *Querier) Query(ctx context.Context, query string, args ...any) (postgres.Rows, error)

func (q *Querier) QueryRow(ctx context.Context, dest []any, query string, args ...any) error