db

package

v0.0.0-...-acb90c0 Latest Latest Go to latest Published: Nov 4, 2025 License: Apache-2.0 Imports: 16 Imported by: 4

Details

This section is empty.

This section is empty.

func BulkInsert[T Table](executor gorp.SqlExecutor, db DB, allObjs ...T) error

Bulk insert objects into the database, using an executor which can be a transaction or a database connection itself.

Note: This function does NOT support auto-incrementing primary keys.

func ReplaceAll[T Table](db DB, objs ...T) error

Replace all old objects of a table with new objects.

type Connector struct{ client.Client }

Kubernetes connector which initializes the database connection from a secret.

func (c Connector) FromSecretRef(ctx context.Context, ref corev1.SecretReference) (*DB, error)

Create a new database client with authentication from the provided secret reference.

type DB struct {
	*gorp.DbMap
	// contains filtered or unexported fields
}

Wrapper around gorp.DbMap that adds some convenience functions.

func (d *DB) AddTable(t Table) *gorp.TableMap

Adds a Model table to the database.

func (d *DB) CreateTable(table ...*gorp.TableMap) error

Adds missing functionality to gorp.DbMap which creates one table.

func (d *DB) SelectTimed(group string, i any, query string, args ...any) ([]any, error)

Executes a select query while monitoring its execution time.

func (d *DB) TableExists(t Table) bool

Check if a table exists in the database.

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

func NewDBMonitor(registry *monitoring.Registry) Monitor

func NewUnregisteredDBMonitor() Monitor

func (m *Monitor) Collect(ch chan<- prometheus.Metric)

func (m *Monitor) Describe(ch chan<- *prometheus.Desc)

type Table interface {
	TableName() string
	// Map of index name to column names.
	Indexes() map[string][]string
}