Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var V1MultitenancyMigration = Migration{ UseTxn: false, Run: func(ds datastoreReaderWriter) error { cidOwners, err := v0CidOwners(ds) if err != nil { return fmt.Errorf("getting cid owners: %s", err) } log.Infof("Starting job logger migration...") if err := migrateJobLogger(ds, cidOwners); err != nil { return fmt.Errorf("migrating job logger: %s", err) } log.Infof("Job logger migration finished") log.Infof("Starting storage info migration...") if err := migrateStorageInfo(ds, cidOwners); err != nil { return fmt.Errorf("migrating storage info: %s", err) } log.Infof("Storage info migration finished") log.Infof("Starting trackstore migration...") if err := migrateTrackstore(ds, cidOwners); err != nil { return fmt.Errorf("migrating trackstore: %s", err) } log.Infof("Trackstore migration finished") log.Infof("Starting started deals migration...") if err := migrateStartedDeals(ds); err != nil { return fmt.Errorf("migrating trackstore: %s", err) } log.Infof("Started deals migration finished") log.Infof("Starting pinstore filling migration...") if err := pinstoreFilling(ds, cidOwners); err != nil { return fmt.Errorf("filling pinstore: %s", err) } log.Infof("Pinstore filling migration finished") return nil }, }
V1MultitenancyMigration contains the logic to upgrade a datastore from version 0 to version 1. Transactionality is disabled since is a big migration.
Functions ¶
This section is empty.
Types ¶
type Migration ¶
Migration runs a vA->v(A+1) migration. UseTxn indicates if this migration should be run in a transaction.
Click to show internal directories.
Click to hide internal directories.