migrate

Documentation

Index

• func NewDBRevisionRW(client *ent.Client) ports.RevisionReadWriter
• type AtlasMigrator
  • func (a AtlasMigrator) Migrate(ctx context.Context, req ports.MigrationRequest) (err error)
• type DBRevisionRW
  • func (rw DBRevisionRW) Client() *ent.Client
  • func (rw DBRevisionRW) DeleteRevision(ctx context.Context, s string) error
  • func (DBRevisionRW) Ident() *migrate.TableIdent
  • func (rw DBRevisionRW) ReadRevision(ctx context.Context, s string) (*migrate.Revision, error)
  • func (rw DBRevisionRW) ReadRevisions(ctx context.Context) ([]*migrate.Revision, error)
  • func (rw DBRevisionRW) WriteRevision(ctx context.Context, revision *migrate.Revision) error

Functions

func NewDBRevisionRW

func NewDBRevisionRW(client *ent.Client) ports.RevisionReadWriter

Types

type AtlasMigrator

type AtlasMigrator struct {
	MigrationsFS fs.FS
	RevisionRW   ports.RevisionReadWriter
}

func (AtlasMigrator) Migrate

func (a AtlasMigrator) Migrate(ctx context.Context, req ports.MigrationRequest) (err error)

type DBRevisionRW

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

func (DBRevisionRW) Client

func (rw DBRevisionRW) Client() *ent.Client

func (DBRevisionRW) DeleteRevision

func (rw DBRevisionRW) DeleteRevision(ctx context.Context, s string) error

func (DBRevisionRW) Ident

func (DBRevisionRW) Ident() *migrate.TableIdent

func (DBRevisionRW) ReadRevision

func (rw DBRevisionRW) ReadRevision(ctx context.Context, s string) (*migrate.Revision, error)

func (DBRevisionRW) ReadRevisions

func (rw DBRevisionRW) ReadRevisions(ctx context.Context) ([]*migrate.Revision, error)

func (DBRevisionRW) WriteRevision

func (rw DBRevisionRW) WriteRevision(ctx context.Context, revision *migrate.Revision) error