migration

Documentation

Index

• type Client
  • func NewClient[C DBClient](c C, config ConfigRepo, migrations Migrations[C], retry int) *Client[C]
  • func (c Client[C]) Migrate(ctx context.Context) (err error)
• type ConfigRepo
• type DBClient
• type Key
• type MigrationFunc
• type Migrations

Types

type Client

type Client[C DBClient] struct {
	// contains filtered or unexported fields
}

func NewClient

func NewClient[C DBClient](c C, config ConfigRepo, migrations Migrations[C], retry int) *Client[C]

func (Client[C]) Migrate

func (c Client[C]) Migrate(ctx context.Context) (err error)

type ConfigRepo

type ConfigRepo interface {
	Current(ctx context.Context) (Key, error)
	Save(ctx context.Context, m Key) error
	Begin(ctx context.Context) error
	End(ctx context.Context) error
}

type DBClient

type DBClient interface {
	Transaction() usecasex.Transaction
}

type Key

type Key = int64

type MigrationFunc

type MigrationFunc[C DBClient] func(context.Context, C) error

type Migrations

type Migrations[C DBClient] map[Key]MigrationFunc[C]