updates

package
v0.0.0-...-2de04ff Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 24, 2023 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var Init = func() DBUpdate {
	buf, err := updates.ReadFile("sql_files/init.sql")
	if err != nil {
		panic(err)
	}

	return ParseUpdate(string(buf), "sql_files/init.sql")
}()
View Source
var Validate = func() []database.TxOP {
	buf, err := updates.ReadFile("sql_files/validate.sql")
	if err != nil {
		panic(err)
	}

	return ParseUpdate(string(buf), "sql_files/validate.sql").Queries
}()
View Source
var Versions = func() []DBUpdate {
	entries, err := updates.ReadDir("sql_files")
	if err != nil {
		panic(err)
	}

	out := make([]DBUpdate, 0)
	path := "sql_files"

	for _, v := range entries {
		if v.IsDir() {
			continue
		}

		if !updateFileRegex.MatchString(filepath.Base(v.Name())) {
			continue
		}

		buf, err := updates.ReadFile(filepath.Join(path, v.Name()))
		if err != nil {
			panic(err)
		}

		out = append(out, ParseUpdate(string(buf), v.Name()))
	}

	sort.Sort(sortByVersion(out))

	return out
}()

Functions

This section is empty.

Types

type DBUpdate

type DBUpdate struct {
	Version uint64
	Queries []database.TxOP
}

func GetNeededUpdates

func GetNeededUpdates(currentUpdate uint64) []DBUpdate

func ParseUpdate

func ParseUpdate(in string, file string) DBUpdate

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL