migrate

type Change struct {
	// Cmd or statement to execute.
	Cmd string

	// Args for placeholder parameters in the statement above.
	Args []any

	// A Comment describes the change.
	Comment string

	// Reverse contains the "reversed" statement(s) if
	// the command is reversible.
	Reverse any // string | []string

	// The Source that caused this change, or nil.
	Source schema.Change
}

type CheckpointDir interface {
	Dir
	// WriteCheckpoint writes the given checkpoint file to the migration directory.
	WriteCheckpoint(name, tag string, content []byte) error

	// CheckpointFiles returns a set of checkpoint files stored in this Dir,
	// ordered by name.
	CheckpointFiles() ([]File, error)

	// FilesFromCheckpoint returns the files to be executed on a database from
	// the given checkpoint file, including it. An ErrCheckpointNotFound if the
	// checkpoint file is not found in the directory.
	FilesFromCheckpoint(string) ([]File, error)
}

type CheckpointFile interface {
	File
	// IsCheckpoint returns true if the file is a checkpoint file.
	IsCheckpoint() bool

	// CheckpointTag returns the tag of the checkpoint file, if defined. The tag
	// can be derived from the file name, internal metadata or directive comments.
	//
	// An ErrNotCheckpoint is returned if the file is not a checkpoint file.
	CheckpointTag() (string, error)
}

type ChecksumError struct {
	Line, Total, Pos int    // line number in file of the mismatch, total number of lines, pos in file
	File             string // filename of the mismatch
	Reason           Reason // reason of a mismatch by filename
}

type CleanChecker interface {
	// CheckClean checks if the connected realm or schema does not contain any resources besides the
	// revision history table. A NotCleanError is returned in case the connection is not-empty.
	CheckClean(context.Context, *TableIdent) error
}

type Dir interface {
	fs.FS
	// WriteFile writes the data to the named file.
	WriteFile(string, []byte) error

	// Files returns a set of files stored in this Dir to be executed on a database.
	Files() ([]File, error)

	// Checksum returns a HashFile of the migration directory.
	Checksum() (HashFile, error)
}

type Driver interface {
	schema.Differ
	schema.ExecQuerier
	schema.Inspector
	PlanApplier
}

type ExecOrder uint

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

type ExecutorOption func(*Executor) error

type File interface {
	// Name returns the name of the migration file.
	Name() string
	// Desc returns the description of the migration File.
	Desc() string
	// Version returns the version of the migration File.
	Version() string
	// Bytes returns the read content of the file.
	Bytes() []byte
	// Stmts returns the set of SQL statements this file holds.
	Stmts() ([]string, error)
	// StmtDecls returns the set of SQL statements this file holds alongside its preceding comments.
	StmtDecls() ([]*Stmt, error)
}

type Formatter interface {
	// Format formats the given Plan into one or more migration files.
	Format(*Plan) ([]File, error)
}

type HashFile []struct{ N, H string }

type HistoryChangedError struct {
	File string
	Stmt int
}

type HistoryNonLinearError struct {
	// OutOfOrder are the files that were added out of order.
	OutOfOrder []File
	// Pending are valid files that are still pending for execution.
	Pending []File
}

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

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

type LogCheck struct {
	Stmt  string // Check statement.
	Error error  // Check error.
}

type LogChecks struct {
	Name  string   // Optional name.
	Stmts []string // Check statements.
}

type LogChecksDone struct {
	Error error // Optional error.
}

type LogDone struct{}

type LogEntry interface {
	// contains filtered or unexported methods
}

type LogError struct {
	SQL   string // Set, if Error was caused by a SQL statement.
	Error error
}

type LogExecution struct {
	// From what version.
	From string
	// To what version.
	To string
	// Migration Files to be executed.
	Files []File
}

type LogFile struct {
	// The File being executed.
	File File
	// Version executed.
	// Deprecated: Use File.Version() instead.
	Version string
	// Desc of migration executed.
	// Deprecated: Use File.Desc() instead.
	Desc string
	// Skip holds the number of stmts of this file that will be skipped.
	// This happens, if a migration file was only applied partially and will now continue to be applied.
	Skip int
}

type LogStmt struct {
	SQL string
}

type Logger interface {
	Log(LogEntry)
}

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

type MissingMigrationError struct{ Version, Description string }

type NopLogger struct{}

type NopRevisionReadWriter struct{}

type NotCleanError struct {
	Reason string        // reason why the database is considered not clean
	State  *schema.Realm // the state the dev-connection is in
}

type Plan struct {
	// Version and Name of the plan. Provided by the user or auto-generated.
	Version, Name string

	// Reversible describes if the changeset is reversible.
	Reversible bool

	// Transactional describes if the changeset is transactional.
	Transactional bool

	// Changes defines the list of changeset in the plan.
	Changes []*Change
}

type PlanApplier interface {
	// PlanChanges returns a migration plan for applying the given changeset.
	PlanChanges(context.Context, string, []schema.Change, ...PlanOption) (*Plan, error)

	// ApplyChanges is responsible for applying the given changeset.
	// An error may return from ApplyChanges if the driver is unable
	// to execute a change.
	ApplyChanges(context.Context, []schema.Change, ...PlanOption) error
}

type PlanMode uint8

type PlanOption func(*PlanOptions)

type PlanOptions struct {
	// PlanWithSchemaQualifier allows setting a custom schema to prefix
	// tables and other resources. An empty string indicates no qualifier.
	SchemaQualifier *string
	// Indent is the string to use for indentation.
	// If empty, no indentation is used.
	Indent string
	// Mode represents the migration planning mode to be used. If not specified, the driver picks its default.
	// This is useful to indicate to the driver whether the context is a live database, an empty one, or the
	// versioned migration workflow.
	Mode PlanMode
}

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

type PlannerOption func(*Planner)

type Reason uint

type ReplayOption func(*replayConfig)

type RestoreFunc func(context.Context) error

type Revision struct {
	Version         string        `json:"Version"`             // Version of the migration.
	Description     string        `json:"Description"`         // Description of this migration.
	Type            RevisionType  `json:"Type"`                // Type of the migration.
	Applied         int           `json:"Applied"`             // Applied amount of statements in the migration.
	Total           int           `json:"Total"`               // Total amount of statements in the migration.
	ExecutedAt      time.Time     `json:"ExecutedAt"`          // ExecutedAt is the starting point of execution.
	ExecutionTime   time.Duration `json:"ExecutionTime"`       // ExecutionTime of the migration.
	Error           string        `json:"Error,omitempty"`     // Error of the migration, if any occurred.
	ErrorStmt       string        `json:"ErrorStmt,omitempty"` // ErrorStmt is the statement that raised Error.
	Hash            string        `json:"-"`                   // Hash of migration file.
	PartialHashes   []string      `json:"-"`                   // PartialHashes is the hashes of applied statements.
	OperatorVersion string        `json:"OperatorVersion"`     // OperatorVersion that executed this migration.
}

type RevisionReadWriter interface {
	// Ident returns an object identifies this history table.
	Ident() *TableIdent
	// ReadRevisions returns all revisions.
	ReadRevisions(context.Context) ([]*Revision, error)
	// ReadRevision returns a revision by version.
	// Returns ErrRevisionNotExist if the version does not exist.
	ReadRevision(context.Context, string) (*Revision, error)
	// WriteRevision saves the revision to the storage.
	WriteRevision(context.Context, *Revision) error
	// DeleteRevision deletes a revision by version from the storage.
	DeleteRevision(context.Context, string) error
}

type RevisionType uint

type Scanner struct {
	ScannerOptions
	// contains filtered or unexported fields
}

type ScannerOptions struct {
	// MatchBegin enables matching for BEGIN ... END statements block.
	MatchBegin bool
	// MatchBeginAtomic enables matching for BEGIN ATOMIC ... END statements block.
	MatchBeginAtomic bool
	// MatchDollarQuote enables the PostgreSQL dollar-quoted string syntax.
	MatchDollarQuote bool
}

type Snapshoter interface {
	// Snapshot takes a snapshot of the current database state and returns a function that can be called to restore
	// that state. Snapshot should return an error, if the current state can not be restored completely, e.g. if
	// there is a table already containing some rows.
	Snapshot(context.Context) (RestoreFunc, error)
}

type StateReader interface {
	ReadState(ctx context.Context) (*schema.Realm, error)
}

type StateReaderFunc func(ctx context.Context) (*schema.Realm, error)

type Stmt struct {
	Pos      int      // statement position
	Text     string   // statement text
	Comments []string // associated comments
}

type StmtScanner interface {
	ScanStmts(input string) ([]*Stmt, error)
}

type TableIdent struct {
	Name   string // name of the table.
	Schema string // optional schema.
}

type TemplateFormatter []struct{ N, C *template.Template }