sql

Jul 1, 2025

Changes in this version

type DB

+ func (db *DB) Listen(ctx context.Context, channel string) (<-chan string, error)

+ func (db *DB) Notify(ctx context.Context, channel string, payload any) error

May 26, 2025

Changes in this version

+ type Event struct

+ Action Action

+ ID int

+ Record json.RawMessage

+ Table string

+ Time time.Time

+ func (v Event) LogValue() slog.Value

type Listener

+ func (b *Listener) RegisterTable(table string, forwarder ForwardFunc)

Apr 8, 2025

Changes in this version

+ func CollectExactlyOneRow[T any](rows pgx.Rows, fn pgx.RowToFunc[T]) (T, error)

+ func CollectOneRow[T any](rows pgx.Rows, fn pgx.RowToFunc[T]) (T, error)

+ func CollectOneType[T any](row pgx.Rows) (T, error)

+ func CollectRows[T any](rows pgx.Rows, fn pgx.RowToFunc[T]) ([]T, error)

+ type Connection = genericConnection

type DB

+ func (db *DB) Int(ctx context.Context, sql string, args ...any) (int64, error)

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

+ type Scanner interface

+ Scan func(dest ...any) error

Jan 20, 2025

Changes in this version

+ const AllocatorLockID

+ const NotifierLockID

+ const ReporterLockID

+ const RunnerManagerLockID

+ const SchedulerLockID

+ const TimeoutLockID

Jan 16, 2025

Changes in this version

+ func Updater[T any](ctx context.Context, db *DB, ...) (T, error)

Nov 22, 2024

Changes in this version

+ func GetLimit(opts resource.PageOptions) pgtype.Int4

+ func GetOffset(opts resource.PageOptions) pgtype.Int4

+ func ID(s resource.ID) pgtype.Text

+ func IDPtr(s *resource.ID) pgtype.Text

Oct 22, 2024

Changes in this version

+ func FromStringArray(pta []pgtype.Text) []string

+ func StringArray(ss []string) []pgtype.Text

type DB

+ func (db *DB) Querier(ctx context.Context) *sqlc.Queries

Dec 5, 2023

Changes in this version

+ const DeleteAction

+ const InsertAction

+ const UpdateAction

+ var ErrSubscriptionTerminated = errors.New("broker terminated the subscription")

+ func Bool(b bool) pgtype.Bool

+ func BoolPtr(s *bool) pgtype.Bool

+ func Inet(ip net.IP) pgtype.Inet

+ type Action string

+ type ForwardFunc func(ctx context.Context, id string, action Action)

+ type Listener struct

+ func NewListener(logger logr.Logger, db pool) *Listener

+ func (b *Listener) RegisterFunc(table string, getter ForwardFunc)

+ func (b *Listener) Start(ctx context.Context) error

+ func (b *Listener) Started() <-chan struct{}

Aug 13, 2023

Changes in this version

type DB

+ func (db *DB) SendBatch(ctx context.Context, b *pgx.Batch) pgx.BatchResults

Jul 24, 2023

Changes in this version

+ func TimestamptzPtr(t *time.Time) pgtype.Timestamptz

Jul 12, 2023

Changes in this version

type DB

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

Jul 8, 2023

Changes in this version

+ func NoRowsInResultError(err error) bool

type DB

+ func (db *DB) Conn(ctx context.Context) *pggen.DBQuerier

+ func (db *DB) Lock(ctx context.Context, table string, ...) error

Jul 2, 2023

Changes in this version

+ func Int4(s int) pgtype.Int4

+ func Int4Ptr(s *int) pgtype.Int4

+ func Int8(s int) pgtype.Int8

+ func Int8Ptr(s *int) pgtype.Int8

+ func StringPtr(s *string) pgtype.Text

Jun 25, 2023

Changes in this version

+ const TestDatabaseURL

+ func Error(err error) error

+ func JSON(b []byte) pgtype.JSON

+ func NewTestDB(t *testing.T) string

+ func NullString() pgtype.Text

+ func String(s string) pgtype.Text

+ func Timestamptz(t time.Time) pgtype.Timestamptz

+ func UUID(s uuid.UUID) pgtype.UUID

+ type DB struct

+ func New(ctx context.Context, opts Options) (*DB, error)

+ func (db *DB) Exec(ctx context.Context, sql string, arguments ...interface{}) (pgconn.CommandTag, error)

+ func (db *DB) GetLogs(ctx context.Context, runID string, phase internal.PhaseType) ([]byte, error)

+ func (db *DB) Tx(ctx context.Context, callback func(internal.DB) error) error

+ func (db *DB) WaitAndLock(ctx context.Context, id int64, fn func() error) (err error)

+ type Options struct

+ ConnString string

+ Logger logr.Logger