Function NewQuantStore

core/services/distributed/quant.go:47–54

NewQuantStore creates a new QuantStore and auto-migrates. Uses a PostgreSQL advisory lock to prevent concurrent migration races when multiple instances (frontend + workers) start at the same time.

(db *gorm.DB)

// Uses a PostgreSQL advisory lock to prevent concurrent migration races
// when multiple instances (frontend + workers) start at the same time.
func NewQuantStore(db *gorm.DB) (*QuantStore, error) {
	if err := advisorylock.WithLockCtx(context.Background(), db, advisorylock.KeySchemaMigrate, func() error {
		return db.AutoMigrate(&QuantJobRecord{})
	}); err != nil {
		return nil, fmt.Errorf("migrating quantization_jobs: %w", err)
	}
	return &QuantStore{db: db}, nil
}

// Create stores a new quantization job.
func (s *QuantStore) Create(job *QuantJobRecord) error {