dbmigration

package

Go to main page

Versions in this module

v0

v0.1.26

May 26, 2021

v0.1.25

May 24, 2021

v0.1.24

May 24, 2021

v0.1.23

May 7, 2021

v0.1.22

Apr 7, 2021

v0.1.21

Apr 6, 2021

v0.1.20

Apr 6, 2021

v0.1.19

Feb 28, 2021

v0.1.18

Feb 28, 2021

v0.1.17

Jan 21, 2021

v0.1.16

Dec 1, 2020

Changes in this version

+ func RegisterMigrationServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

+ func RegisterMigrationServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client MigrationServiceClient) error

+ func RegisterMigrationServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

+ func RegisterMigrationServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server MigrationServiceServer) error

v0.1.15

Dec 1, 2020

v0.1.14

Nov 30, 2020

Changes in this version

+ var File_dbmigration_dbmigration_proto protoreflect.FileDescriptor

+ func RegisterMigrationServiceServer(s *grpc.Server, srv MigrationServiceServer)

+ type DatabaseForceVersionRequest struct

+ Version int32

+ func (*DatabaseForceVersionRequest) Descriptor() ([]byte, []int)

+ func (*DatabaseForceVersionRequest) ProtoMessage()

+ func (x *DatabaseForceVersionRequest) GetVersion() int32

+ func (x *DatabaseForceVersionRequest) ProtoReflect() protoreflect.Message

+ func (x *DatabaseForceVersionRequest) Reset()

+ func (x *DatabaseForceVersionRequest) String() string

+ type DatabaseForceVersionResponse struct

+ Status *MigrationStatus

+ func (*DatabaseForceVersionResponse) Descriptor() ([]byte, []int)

+ func (*DatabaseForceVersionResponse) ProtoMessage()

+ func (x *DatabaseForceVersionResponse) GetStatus() *MigrationStatus

+ func (x *DatabaseForceVersionResponse) ProtoReflect() protoreflect.Message

+ func (x *DatabaseForceVersionResponse) Reset()

+ func (x *DatabaseForceVersionResponse) String() string

+ type DatabaseMigrateRequest struct

+ func (*DatabaseMigrateRequest) Descriptor() ([]byte, []int)

+ func (*DatabaseMigrateRequest) ProtoMessage()

+ func (x *DatabaseMigrateRequest) ProtoReflect() protoreflect.Message

+ func (x *DatabaseMigrateRequest) Reset()

+ func (x *DatabaseMigrateRequest) String() string

+ type DatabaseMigrateResponse struct

+ Status *MigrationStatus

+ func (*DatabaseMigrateResponse) Descriptor() ([]byte, []int)

+ func (*DatabaseMigrateResponse) ProtoMessage()

+ func (x *DatabaseMigrateResponse) GetStatus() *MigrationStatus

+ func (x *DatabaseMigrateResponse) ProtoReflect() protoreflect.Message

+ func (x *DatabaseMigrateResponse) Reset()

+ func (x *DatabaseMigrateResponse) String() string

+ type DatabaseRollbackRequest struct

+ func (*DatabaseRollbackRequest) Descriptor() ([]byte, []int)

+ func (*DatabaseRollbackRequest) ProtoMessage()

+ func (x *DatabaseRollbackRequest) ProtoReflect() protoreflect.Message

+ func (x *DatabaseRollbackRequest) Reset()

+ func (x *DatabaseRollbackRequest) String() string

+ type DatabaseRollbackResponse struct

+ Status *MigrationStatus

+ func (*DatabaseRollbackResponse) Descriptor() ([]byte, []int)

+ func (*DatabaseRollbackResponse) ProtoMessage()

+ func (x *DatabaseRollbackResponse) GetStatus() *MigrationStatus

+ func (x *DatabaseRollbackResponse) ProtoReflect() protoreflect.Message

+ func (x *DatabaseRollbackResponse) Reset()

+ func (x *DatabaseRollbackResponse) String() string

+ type DatabaseStatusRequest struct

+ func (*DatabaseStatusRequest) Descriptor() ([]byte, []int)

+ func (*DatabaseStatusRequest) ProtoMessage()

+ func (x *DatabaseStatusRequest) ProtoReflect() protoreflect.Message

+ func (x *DatabaseStatusRequest) Reset()

+ func (x *DatabaseStatusRequest) String() string

+ type DatabaseStatusResponse struct

+ Status *MigrationStatus

+ func (*DatabaseStatusResponse) Descriptor() ([]byte, []int)

+ func (*DatabaseStatusResponse) ProtoMessage()

+ func (x *DatabaseStatusResponse) GetStatus() *MigrationStatus

+ func (x *DatabaseStatusResponse) ProtoReflect() protoreflect.Message

+ func (x *DatabaseStatusResponse) Reset()

+ func (x *DatabaseStatusResponse) String() string

+ type MigrationServiceClient interface

+ DatabaseForceVersion func(ctx context.Context, in *DatabaseForceVersionRequest, opts ...grpc.CallOption) (*DatabaseForceVersionResponse, error)

+ DatabaseMigrate func(ctx context.Context, in *DatabaseMigrateRequest, opts ...grpc.CallOption) (*DatabaseMigrateResponse, error)

+ DatabaseRollback func(ctx context.Context, in *DatabaseRollbackRequest, opts ...grpc.CallOption) (*DatabaseRollbackResponse, error)

+ DatabaseStatus func(ctx context.Context, in *DatabaseStatusRequest, opts ...grpc.CallOption) (*DatabaseStatusResponse, error)

+ func NewMigrationServiceClient(cc grpc.ClientConnInterface) MigrationServiceClient

+ type MigrationServiceServer interface

+ DatabaseForceVersion func(context.Context, *DatabaseForceVersionRequest) (*DatabaseForceVersionResponse, error)

+ DatabaseMigrate func(context.Context, *DatabaseMigrateRequest) (*DatabaseMigrateResponse, error)

+ DatabaseRollback func(context.Context, *DatabaseRollbackRequest) (*DatabaseRollbackResponse, error)

+ DatabaseStatus func(context.Context, *DatabaseStatusRequest) (*DatabaseStatusResponse, error)

+ type MigrationStatus struct

+ Dirty bool

+ LatestVersion int32

+ UpToDate bool

+ Version uint32

+ func (*MigrationStatus) Descriptor() ([]byte, []int)

+ func (*MigrationStatus) ProtoMessage()

+ func (x *MigrationStatus) GetDirty() bool

+ func (x *MigrationStatus) GetLatestVersion() int32

+ func (x *MigrationStatus) GetUpToDate() bool

+ func (x *MigrationStatus) GetVersion() uint32

+ func (x *MigrationStatus) ProtoReflect() protoreflect.Message

+ func (x *MigrationStatus) Reset()

+ func (x *MigrationStatus) String() string

+ type UnimplementedMigrationServiceServer struct

+ func (UnimplementedMigrationServiceServer) DatabaseForceVersion(context.Context, *DatabaseForceVersionRequest) (*DatabaseForceVersionResponse, error)

+ func (UnimplementedMigrationServiceServer) DatabaseMigrate(context.Context, *DatabaseMigrateRequest) (*DatabaseMigrateResponse, error)

+ func (UnimplementedMigrationServiceServer) DatabaseRollback(context.Context, *DatabaseRollbackRequest) (*DatabaseRollbackResponse, error)

+ func (UnimplementedMigrationServiceServer) DatabaseStatus(context.Context, *DatabaseStatusRequest) (*DatabaseStatusResponse, error)

+ type UnsafeMigrationServiceServer interface

v0.1.13

Nov 22, 2020

v0.1.12

Nov 9, 2020

v0.1.11

Sep 30, 2020

v0.1.10

Sep 29, 2020

v0.1.9

Sep 28, 2020

v0.1.8

Sep 23, 2020

v0.1.7

Aug 17, 2020

v0.1.6

Aug 13, 2020

v0.1.5

Aug 13, 2020

v0.1.4

Jun 29, 2020

v0.1.3

Jun 29, 2020

Changes in this version

type MigrationConfig

+ MigrateOnStart bool

+ SqlConnStr string

+ SqlFileDir string

v0.1.2

Jun 26, 2020

Changes in this version

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

+ type MigrationConfig struct

+ type MigrationService struct

+ 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 struct

+ 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)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL