H A D | database.go | 45 type PgDatabase struct { struct 50 func NewPgDatabase(ctx context.Context, logger hclog.Logger, dsn string) (*PgDatabase, error) { 59 return &PgDatabase{pool: pool, log: logger}, nil 63 func (p PgDatabase) Insert(ctx context.Context, t *Table, resources Resources) error { argument 104 func (p PgDatabase) CopyFrom(ctx context.Context, resources Resources, shouldCascade bool, cascadeD… argument 145 func (p PgDatabase) Exec(ctx context.Context, query string, args ...interface{}) error { argument 151 func (p PgDatabase) Query(ctx context.Context, query string, args ...interface{}) (pgx.Rows, error)… argument 157 func (p PgDatabase) QueryOne(ctx context.Context, query string, args ...interface{}) pgx.Row { argument 162 func (p PgDatabase) Delete(ctx context.Context, t *Table, kvFilters []interface{}) error { argument 181 func (p PgDatabase) RemoveStaleData(ctx context.Context, t *Table, executionStart time.Time, kvFilt… argument [all …]
|