database

type CustomList struct {
	*list.List
}

type Database struct {
	Name string
	Type string
}

type Driver interface {
	// Open returns a new driver instance configured with parameters
	// coming from the URL string. Migrate will call this function
	// only once per instance.
	Open(url string, isCMD bool, tlsConfig *tls.Config, logger *log.Logger, hasuraOpts *HasuraOpts) (Driver, error)

	// Close closes the underlying database instance managed by the driver.
	// Migrate will call this function only once per instance.
	Close() error

	Scan() error

	// Lock should acquire a database lock so that only one migration process
	// can run at a time. Migrate will call this function before Run is called.
	// If the implementation can't provide this functionality, return nil.
	// Return database.ErrLocked if database is already locked.
	Lock() error

	// Unlock should release the lock. Migrate will call this function after
	// all migrations have been run.
	UnLock() error

	// RunSeq applies a migration to the database in a sequential fashion. migration is guaranteed to be not nil.
	Run(migration io.Reader, fileType, fileName string) error

	// Reset Migration Query Args
	ResetQuery()

	// InsertVersion saves version
	// Migrate will call this function before and after each call to Run.
	// version must be >= -1. -1 means NilVersion.
	InsertVersion(version int64) error

	// SetVersion saves version and dirty state.
	// Migrate will call this function before and after each call to Run.
	// version must be >= -1. -1 means NilVersion.
	SetVersion(version int64, dirty bool) error

	// SetVersion saves version and dirty state.
	// Migrate will call this function before and after each call to Run.
	// version must be >= -1. -1 means NilVersion.
	RemoveVersion(version int64) error

	// Version returns the currently active version and if the database is dirty.
	// When no migration has been applied, it must return version -1.
	// Dirty means, a previous migration failed and user interaction is required.
	Version() (version int64, dirty bool, err error)

	// First returns the very first migration version available to the driver.
	// Migrate will call this function multiple times
	First() (migrationVersion *MigrationVersion, ok bool)

	// Last returns the latest version available in database
	Last() (*MigrationVersion, bool)

	// Prev returns the previous version for a given version available to the driver.
	// Migrate will call this function multiple times.
	// If there is no previous version available, it must return os.ErrNotExist.
	Prev(version uint64) (prevVersion *MigrationVersion, ok bool)

	// Next returns the next version for a given version available to the driver.
	// Migrate will call this function multiple times.
	// If there is no next version available, it must return os.ErrNotExist.
	Next(version uint64) (migrationVersion *MigrationVersion, ok bool)

	Read(version uint64) (ok bool)

	PushToList(migration io.Reader, fileType string, list *CustomList) error

	Squash(list *CustomList, ret chan<- interface{})

	MetadataDriver

	SchemaDriver

	SettingsDriver

	Query(data interface{}) error
}

type HasuraOpts struct {
	HasMetadataV3 bool
	SourceName    string
	SourceKind    hasura.SourceKind

	Client *hasura.Client

	PGSourceOps         hasura.PGSourceOps
	MSSQLSourceOps      hasura.MSSQLSourceOps
	MetadataOps         hasura.CommonMetadataOperations
	V2MetadataOps       hasura.V2CommonMetadataOperations
	GenericQueryRequest hasura.GenericSend

	MigrationsStateStore statestore.MigrationsStateStore
	SettingsStateStore   statestore.SettingsStateStore
}

type MetadataDriver interface {
	EnableCheckMetadataConsistency(bool)
}

type MigrationVersion struct {
	Version uint64
	Dirty   bool
}

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

type SchemaDriver interface {
	ExportSchemaDump(schemaName []string, sourceName string, sourceKind hasura.SourceKind) ([]byte, error)
}

type SettingsDriver interface {
	// Get Current setting from database
	GetSetting(name string) (value string, err error)

	// UpdateSetting updates a setting in database.
	UpdateSetting(name string, value string) error
}