dbmigration

Documentation

Index

• func NewMigrationService(log *zap.SugaredLogger, config MigrationConfig) devpb.MigrationServer
• type MigrationConfig
• type MigrationService
  • func (s MigrationService) DatabaseForceVersion(ctx context.Context, request *devpb.DatabaseForceVersionRequest) (*devpb.DatabaseForceVersionResponse, error)
  • func (s MigrationService) DatabaseMigrate(ctx context.Context, request *devpb.DatabaseMigrateRequest) (*devpb.DatabaseMigrateResponse, error)
  • func (s MigrationService) DatabaseRollback(ctx context.Context, request *devpb.DatabaseRollbackRequest) (*devpb.DatabaseRollbackResponse, error)
  • func (s MigrationService) DatabaseStatus(ctx context.Context, request *devpb.DatabaseStatusRequest) (*devpb.DatabaseStatusResponse, error)
• type Migrator
  • func NewMigrator(log *zap.SugaredLogger, sqlConnStr, fileDir string) Migrator
  • func (m Migrator) ForceVersion(version int32) (*devpb.MigrationStatus, error)
  • func (m Migrator) Migrate() (*devpb.MigrationStatus, error)
  • func (m Migrator) Rollback() (*devpb.MigrationStatus, error)
  • func (m Migrator) Status() (*devpb.MigrationStatus, error)

Functions

func NewMigrationService

func NewMigrationService(log *zap.SugaredLogger, config MigrationConfig) devpb.MigrationServer

Types

type MigrationConfig

type MigrationConfig struct {
	MigrateOnStart bool
	SqlFileDir     string
	SqlConnStr     string
}

type MigrationService

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

func (MigrationService) DatabaseForceVersion

func (s MigrationService) DatabaseForceVersion(ctx context.Context, request *devpb.DatabaseForceVersionRequest) (*devpb.DatabaseForceVersionResponse, error)

func (MigrationService) DatabaseMigrate

func (s MigrationService) DatabaseMigrate(ctx context.Context, request *devpb.DatabaseMigrateRequest) (*devpb.DatabaseMigrateResponse, error)

func (MigrationService) DatabaseRollback

func (s MigrationService) DatabaseRollback(ctx context.Context, request *devpb.DatabaseRollbackRequest) (*devpb.DatabaseRollbackResponse, error)

func (MigrationService) DatabaseStatus

func (s MigrationService) DatabaseStatus(ctx context.Context, request *devpb.DatabaseStatusRequest) (*devpb.DatabaseStatusResponse, error)

type Migrator

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

func NewMigrator

func NewMigrator(log *zap.SugaredLogger, sqlConnStr, fileDir string) Migrator

func (Migrator) ForceVersion

func (m Migrator) ForceVersion(version int32) (*devpb.MigrationStatus, error)

func (Migrator) Migrate

func (m Migrator) Migrate() (*devpb.MigrationStatus, error)

func (Migrator) Rollback

func (m Migrator) Rollback() (*devpb.MigrationStatus, error)

func (Migrator) Status

func (m Migrator) Status() (*devpb.MigrationStatus, error)