migrator

package

v0.0.0-...-e035a7c Latest Latest Go to latest Published: May 22, 2025 License: Apache-2.0 Imports: 21 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/wellmadearr/pipelaner

Links

Open Source Insights

Documentation ¶

Overview ¶

nolint

Index ¶

Variables
type Click
- func NewMigrateClick(cfg migrations.Clickhouse) *Click
- func (m *Click) Run(migrationsDir string) error
type ClickHouse
type ClickhouseMigration
type Config
type MigrationInterface
type Migrator
- func NewMigrator(cfg *config.Pipelaner) (*Migrator, error)
- func (m *Migrator) Migrate() error

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	DefaultMigrationsTable       = "schema_migrations"
	DefaultMultiStatementMaxSize = 10 * 1 << 20 // 10 MB

	ErrNilConfig = fmt.Errorf("no config")
)

Functions ¶

This section is empty.

Types ¶

type Click ¶

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

func NewMigrateClick ¶

func NewMigrateClick(cfg migrations.Clickhouse) *Click

func (*Click) Run ¶

func (m *Click) Run(migrationsDir string) error

type ClickHouse ¶

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

func (*ClickHouse) Close ¶

func (ch *ClickHouse) Close() error

func (*ClickHouse) Drop ¶

func (ch *ClickHouse) Drop() (err error)

func (*ClickHouse) Lock ¶

func (ch *ClickHouse) Lock() error

func (*ClickHouse) Open ¶

func (ch *ClickHouse) Open(dsn string) (database.Driver, error)

func (*ClickHouse) Run ¶

func (ch *ClickHouse) Run(r io.Reader) error

func (*ClickHouse) SetVersion ¶

func (ch *ClickHouse) SetVersion(version int, dirty bool) error

func (*ClickHouse) Unlock ¶

func (ch *ClickHouse) Unlock() error

func (*ClickHouse) Version ¶

func (ch *ClickHouse) Version() (int, bool, error)

type ClickhouseMigration ¶

type ClickhouseMigration interface {
	MigrationInterface
}

type Config ¶

type Config struct {
	DatabaseName          string
	ClusterName           string
	MigrationsTable       string
	MigrationsTableEngine string
	MultiStatementEnabled bool
	MultiStatementMaxSize int
}

type MigrationInterface ¶

type MigrationInterface interface {
	Run(migrationsDir string) error
}

type Migrator ¶

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

func NewMigrator ¶

func NewMigrator(
	cfg *config.Pipelaner,
) (*Migrator, error)

func (*Migrator) Migrate ¶

func (m *Migrator) Migrate() error

Source Files ¶

View all Source files

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