postgres

Documentation

Index

• type DB
  • func NewDB(ctx context.Context, conn string) (*DB, error)
  • func (db *DB) Begin(ctx context.Context) (pgx.Tx, error)
  • func (db *DB) Close(ctx context.Context) error
  • func (db *DB) Exec(ctx context.Context, sql string, arguments ...any) (pgconn.CommandTag, error)
  • func (db *DB) GetTracesOlderThan(ctx context.Context, timestamp time.Time) ([]ptrace.Traces, error)
  • func (db *DB) PutTraces(ctx context.Context, traces ptrace.Traces) error
  • func (db *DB) Query(ctx context.Context, sql string, arguments ...any) (pgx.Rows, error)
  • func (db *DB) QueryRow(ctx context.Context, sql string, arguments ...any) pgx.Row
  • func (db *DB) RemoveTraces(ctx context.Context, traces ptrace.Traces) error
  • func (db *DB) Transact(ctx context.Context, opts pgx.TxOptions, ...) error

Types

type DB

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

func NewDB

func NewDB(ctx context.Context, conn string) (*DB, error)

func (*DB) Begin

func (db *DB) Begin(ctx context.Context) (pgx.Tx, error)

func (*DB) Close

func (db *DB) Close(ctx context.Context) error

func (*DB) Exec

func (db *DB) Exec(ctx context.Context, sql string, arguments ...any) (pgconn.CommandTag, error)

func (*DB) GetTracesOlderThan

func (db *DB) GetTracesOlderThan(ctx context.Context, timestamp time.Time) ([]ptrace.Traces, error)

func (*DB) PutTraces

func (db *DB) PutTraces(ctx context.Context, traces ptrace.Traces) error

func (*DB) Query

func (db *DB) Query(ctx context.Context, sql string, arguments ...any) (pgx.Rows, error)

func (*DB) QueryRow

func (db *DB) QueryRow(ctx context.Context, sql string, arguments ...any) pgx.Row

func (*DB) RemoveTraces

func (db *DB) RemoveTraces(ctx context.Context, traces ptrace.Traces) error

func (*DB) Transact

func (db *DB) Transact(ctx context.Context, opts pgx.TxOptions, f func(ctx context.Context, db *DB) error) error