Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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
type VersionIncrement ¶
VersionIncrement is used to send a request to increment a table's version w/o running a migration.
Click to show internal directories.
Click to hide internal directories.