migrate

type ErrDirty struct {
	Version int64
}

type ErrShortLimit struct {
	Short uint64
}

type Migrate struct {

	// Logger is the global logger object to print logs.
	Logger *log.Logger

	// GracefulStop accepts `true` and will stop executing migrations
	// as soon as possible at a safe break point, so that the database
	// is not corrupted.
	GracefulStop chan bool

	// PrefetchMigrations defaults to DefaultPrefetchMigrations,
	// but can be set per Migrate instance.
	PrefetchMigrations uint64

	// LockTimeout defaults to DefaultLockTimeout,
	// but can be set per Migrate instance.
	LockTimeout time.Duration

	SkipExecution   bool
	DryRun          bool
	ProgressBarLogs bool
	// contains filtered or unexported fields
}

type Migration struct {
	// Identifier can be any string to help identifying
	// the migration in the source.
	Identifier string

	// Version is the version of this migration.
	Version uint64

	// TargetVersion is the migration version after this migration
	// has been applied to the database.
	// Can be -1, implying that this is a NilVersion.
	TargetVersion int64

	// File Type
	FileType string

	// File name
	FileName string

	// Body holds an io.ReadCloser to the source.
	Body io.ReadCloser

	// BufferedBody holds an buffered io.Reader to the underlying Body.
	BufferedBody io.Reader

	// BufferSize defaults to DefaultBufferSize
	BufferSize uint64

	// Scheduled is the time when the migration was scheduled/ queued.
	Scheduled time.Time

	// StartedBuffering is the time when buffering of the migration source started.
	StartedBuffering time.Time

	// FinishedBuffering is the time when buffering of the migration source finished.
	FinishedBuffering time.Time

	// FinishedReading is the time when the migration source is fully read.
	FinishedReading time.Time

	// BytesRead holds the number of Bytes read from the migration source.
	BytesRead int64
	// contains filtered or unexported fields
}

type MigrationStatus struct {
	// Version is the version of this migration.
	Version uint64 `json:"-"`

	// Name helps finding this migration in the source folder
	Name string `json:"-"`

	// Check if the migration is applied on the cluster
	IsApplied bool `json:"database_status"`

	// Check if the migration is present on the local.
	IsPresent bool `json:"source_status"`

	IsDirty bool `json:"-"`
}

type MultiError struct {
	Errs []error
}

type NewMigrateOpts struct {
	Stdout io.Writer
	Stderr io.Writer
	// contains filtered or unexported fields
}

type Status struct {
	Index      uint64Slice                 `json:"migrations"`
	Migrations map[uint64]*MigrationStatus `json:"status"`
}