remove dups

Signed-off-by: Sarah Funkhouser <[email protected]>

internal/river/river.go

@@ -13,6 +13,8 @@ import (
 	"github.com/riverqueue/river"
 	"github.com/riverqueue/river/riverdriver/riverpgxv5"
 	"github.com/rs/zerolog/log"
+
+	"github.com/theopenlane/riverboat/pkg/riverqueue"
 )
 
 const (
@@ -28,7 +30,7 @@ func Start(ctx context.Context, c Config) error {
 	}
 
 	// Run migrations on startup
-	if err := runMigrations(ctx, dbPool); err != nil {
+	if err := riverqueue.RunMigrations(ctx, dbPool); err != nil {
 		log.Fatal().Err(err).Msg("failed to run migrations")
 	}
 

pkg/riverqueue/client.go

@@ -95,7 +95,7 @@ func New(ctx context.Context, opts ...Option) (c *Client, err error) {
 
 	// run migrations if the flag is set
 	if c.config.RunMigrations {
-		if err := runMigrations(ctx, c.pool); err != nil {
+		if err := RunMigrations(ctx, c.pool); err != nil {
 			log.Error().Err(err).Msg("error running migrations")
 			return nil, err
 		}

pkg/riverqueue/migrate.go

@@ -8,9 +8,9 @@ import (
 	"github.com/riverqueue/river/rivermigrate"
 )
 
-// runMigrations runs the migrations for the river server
+// RunMigrations runs the migrations for the river server
 // see https://riverqueue.com/docs/migrations for more information
-func runMigrations(ctx context.Context, dbPool *pgxpool.Pool) error {
+func RunMigrations(ctx context.Context, dbPool *pgxpool.Pool) error {
 	// run migrations here
 	migrator, err := rivermigrate.New(riverpgxv5.New(dbPool), nil)
 	if err != nil {