migration

Documentation

Index

• type RegressionMigrator
  • func New(ctx context.Context, db pool.Pool, dbType config.DataStoreType) (*RegressionMigrator, error)
  • func (m *RegressionMigrator) RunOneMigration(batchSize int)
  • func (m *RegressionMigrator) RunPeriodicMigration(iterationPeriod time.Duration, batchSize int)

Types

type RegressionMigrator

type RegressionMigrator struct {
	// contains filtered or unexported fields
}

RegressionMigrator provides a struct to migrate regression data from regressions to regressions2 table.

func New

func New(ctx context.Context, db pool.Pool, dbType config.DataStoreType) (*RegressionMigrator, error)

New returns a new instance of RegressionMigrator.

func (*RegressionMigrator) RunOneMigration

func (m *RegressionMigrator) RunOneMigration(batchSize int)

The helper function for RunPeriodicMigration to run a single iteration, with the proper handling on timeout.

func (*RegressionMigrator) RunPeriodicMigration

func (m *RegressionMigrator) RunPeriodicMigration(iterationPeriod time.Duration, batchSize int)

RunPeriodicMigration runs a goroutine that runs the migration with the provided batch size with a frequency specified by iterationPeriod.