dbmigrator

Nov 22, 2023

Changes in this version

+ type Database interface

+ DeleteMigrationState func(ctx context.Context, migration *DbMigration) error

+ GetAppliedMigrations func(ctx context.Context) ([]DbMigration, error)

+ InsertMigrationState func(ctx context.Context, migration *DbMigration) error

+ RunCommands func(ctx context.Context, commands []bson.D) error

+ func NewDatabase(db *mongo.Database, migrationsColl string) Database

+ type DbMigration struct

+ DownScript []bson.D

+ Name string

+ UpScript []bson.D

+ func GetDbMigrationsFromFs(fsys fs.FS) ([]DbMigration, error)

+ type DbMigrator struct

+ func NewDbMigrator(db Database, list []DbMigration) *DbMigrator

+ func (d *DbMigrator) Apply(ctx context.Context) error

+ func (d *DbMigrator) GetApplied(ctx context.Context) (results []DbMigration, err error)

+ func (d *DbMigrator) Plan(ctx context.Context) (plan DbPlan, err error)

+ type DbPlan struct

+ Downs []DbMigration

+ Total int

+ Ups []DbMigration

+ type MockDatabase struct

+ func NewMockDatabase(ctrl *gomock.Controller) *MockDatabase

+ func (m *MockDatabase) DeleteMigrationState(arg0 context.Context, arg1 *DbMigration) error

+ func (m *MockDatabase) EXPECT() *MockDatabaseMockRecorder

+ func (m *MockDatabase) GetAppliedMigrations(arg0 context.Context) ([]DbMigration, error)

+ func (m *MockDatabase) InsertMigrationState(arg0 context.Context, arg1 *DbMigration) error

+ func (m *MockDatabase) RunCommands(arg0 context.Context, arg1 []primitive.D) error

+ type MockDatabaseMockRecorder struct

+ func (mr *MockDatabaseMockRecorder) DeleteMigrationState(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockDatabaseMockRecorder) GetAppliedMigrations(arg0 interface{}) *gomock.Call

+ func (mr *MockDatabaseMockRecorder) InsertMigrationState(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockDatabaseMockRecorder) RunCommands(arg0, arg1 interface{}) *gomock.Call