repositories

Documentation

Index

• type DBRepository
  • func NewDBRepository(db adapters.DB) DBRepository
• type FileRepository
  • func NewFileRepository(fileSystem adapters.FileSystem) FileRepository

Types

type DBRepository

type DBRepository interface {
	CreateMigrationsTableIfNeeded() error
	GetAlreadyRunMigrationFilePaths(migrationsDirectoryAbsolutePath string) ([]string, error)
	RunMigrationQuery(query string) error
	RegisterRunMigration(migrationFileName string) error
	Ping() error
}

DBRepository runs migration queries and handles the migrations table.

func NewDBRepository

func NewDBRepository(db adapters.DB) DBRepository

NewDBRepository returns an implementation of DbRepository.

type FileRepository

type FileRepository interface {
	GetMigrationFilePaths(migrationsDirectoryAbsolutePath string) ([]string, error)
	GetMigrationQuery(migrationAbsolutePath string) (string, error)
	CreateMigration(migrationAbsolutePath, query string) error
}

FileRepository fetches migrations files from a given path.

func NewFileRepository

func NewFileRepository(fileSystem adapters.FileSystem) FileRepository

NewFileRepository returns an implementation of FileRepository.