database

type DBGetter interface {
	// GetDB returns a TrackedDB reference for the dqlite-backed database that
	// contains the data for the specified namespace.
	// A NotFound error is returned if the worker is unaware of the requested
	// DB.
	GetDB(namespace string) (TrackedDB, error)
}

type NoopSlowQueryLogger struct{}

type SlowQueryLogger interface {
	// Log the slow query, with the given arguments.
	RecordSlowQuery(msg, stmt string, args []any, duration float64)
}

type TrackedDB interface {
	// Txn executes the input function against the tracked database,
	// within a transaction that depends on the input context.
	// Retry semantics are applied automatically based on transient failures.
	// This is the function that almost all downstream database consumers
	// should use.
	Txn(context.Context, func(context.Context, *sql.Tx) error) error

	// TxnNoRetry executes the input function against the tracked database,
	// within a transaction that depends on the input context.
	// No retries are attempted.
	TxnNoRetry(context.Context, func(context.Context, *sql.Tx) error) error

	// Err returns an error if the underlying tracked DB is in an error
	// condition. Depending on the error, determines of the tracked DB can be
	// requested again, or should be given up and thrown away.
	Err() error
}