migrator

Documentation

Index

• type Migrator
  • func New(aceBack backend.Backend, metaBack metadata.Reader, ...) *Migrator
  • func (m *Migrator) Close()
• type VersionIncrement

Types

type Migrator

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

Migrator manages the migration of Ace as new versioned tsvs come in.

func New

func New(aceBack backend.Backend,
	metaBack metadata.Reader,
	blueprintClient blueprint.Client,
	versions versions.GetterSetter,
	pollPeriod time.Duration,
	waitProcessorPeriod time.Duration,
	offpeakStartHour int,
	offpeakDurationHours int,
	versionIncrement chan VersionIncrement,
	onpeakMigrationTimeoutMs int,
	offpeakMigrationTimeoutMs int) *Migrator

New returns a new Migrator for migrating schemas

func (*Migrator) Close

func (m *Migrator) Close()

Close signals the migrator to stop looking for new migrations and waits until it's finished any migrations.

type VersionIncrement

type VersionIncrement struct {
	Table    string
	Version  int
	Response chan error
}

VersionIncrement is used to send a request to increment a table's version w/o running a migration.