migrations

Documentation

Index

• func ExecInTx(db *sql.DB, opts *sql.TxOptions, initFn func(*sql.Tx) error, ...) (ret interface{}, err error)
• func GetAllKeysFromTable(tx *sql.Tx, table string) ([]string, error)
• func GetAllValuesFromTable(tx *sql.Tx, table string) (map[string][]byte, error)
• func GetEnvWithDefault(variable string, defaultValue string) string
• func GetTableName(networkId string, baseName string) string
• func MigrateNetworkAgnosticServiceToBlobstore(nid, typ, oldTable, newTable string)

Functions

func ExecInTx

func ExecInTx(
	db *sql.DB,
	opts *sql.TxOptions,
	initFn func(*sql.Tx) error,
	txFn func(*sql.Tx) (interface{}, error),
) (ret interface{}, err error)

ExecInTx executes a callback inside a sql transaction on the provided DB. The transaction is rolled back if any error is encountered. initFn is a callback to call before the main txFn, commonly used in our codebase to execute a CREATE TABLE IF NOT EXISTS. Copied from orc8r/cloud/go/sqorc/tx.go.

func GetAllKeysFromTable

func GetAllKeysFromTable(tx *sql.Tx, table string) ([]string, error)

func GetAllValuesFromTable

func GetAllValuesFromTable(tx *sql.Tx, table string) (map[string][]byte, error)

If the table DNE, log and return empty map

func GetEnvWithDefault

func GetEnvWithDefault(variable string, defaultValue string) string

func GetTableName

func GetTableName(networkId string, baseName string) string

func MigrateNetworkAgnosticServiceToBlobstore

func MigrateNetworkAgnosticServiceToBlobstore(nid, typ, oldTable, newTable string)

MigrateNetworkAgnosticServiceToBlobstore migrates a network-agnostic service's data from datastore to blobstore formats.

Schema migration:

• Datastore has cols
• key
• value
• generation_number
• deleted
• Blobstore has cols
• network_id
• type
• key
• value
• version
• Conversion (blobstore col <- datastore col)
• network_id <- [nid parameter]
• type <- [typ parameter]
• key <- key
• value <- value
• version <- generation_number
• n/a <- deleted