Function Migration

rivershared/testfactory/test_factory.go:139–149

(ctx context.Context, tb testing.TB, exec riverdriver.Executor, opts *MigrationOpts)

}

func Migration(ctx context.Context, tb testing.TB, exec riverdriver.Executor, opts *MigrationOpts) *riverdriver.Migration {
	tb.Helper()

	migration, err := exec.MigrationInsertMany(ctx, &riverdriver.MigrationInsertManyParams{
		Line:     ptrutil.ValOrDefault(opts.Line, riverdriver.MigrationLineMain),
		Schema:   opts.Schema,
		Versions: []int{ptrutil.ValOrDefaultFunc(opts.Version, nextSeq)},
	})
	require.NoError(tb, err)
	return migration[0]
}

var seq int64 = 1 //nolint:gochecknoglobals