|
|
|
@ -92,7 +92,7 @@ func NewSqliteSDKTraceExporterWithDB(db *sql.DB) (sdktrace.SpanExporter, error)
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
func doMigrate(db *sql.DB) error {
|
|
|
|
|
d, err := iofs.New(migrations, "sqliteexporter")
|
|
|
|
|
d, err := iofs.New(migrations, "migrations")
|
|
|
|
|
if err != nil {
|
|
|
|
|
return fmt.Errorf("failed to open iofs migration source: %w", err)
|
|
|
|
|
}
|
|
|
|
@ -102,7 +102,7 @@ func doMigrate(db *sql.DB) error {
|
|
|
|
|
return fmt.Errorf("failed to initialize sqlite3 migrate driver: %w", err)
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
m, err := migrate.NewWithInstance("iofs", d, "main", dr)
|
|
|
|
|
m, err := migrate.NewWithInstance("iofs", d, "sqliteexporter", dr)
|
|
|
|
|
if err != nil {
|
|
|
|
|
return fmt.Errorf("failed to initialize db migrate: %w", err)
|
|
|
|
|
}
|
|
|
|
|