migrations

Documentation

Index

• Constants
• type CatalogStateStore
  • func NewCatalogStateStore(c *statestore.CLICatalogState) *CatalogStateStore
  • func (m *CatalogStateStore) GetVersions(database string) (map[uint64]bool, error)
  • func (m *CatalogStateStore) InsertVersion(database string, version int64) error
  • func (m *CatalogStateStore) PrepareMigrationsStateStore(_ string) error
  • func (m *CatalogStateStore) RemoveVersion(database string, version int64) error
  • func (m *CatalogStateStore) SetVersion(database string, version int64, dirty bool) error
  • func (m *CatalogStateStore) SetVersions(database string, versions []statestore.Version) error
• type MigrationStateStoreHdbTable
  • func NewMigrationStateStoreHdbTable(client hasura.PGSourceOps, schema, table string) *MigrationStateStoreHdbTable
  • func (m *MigrationStateStoreHdbTable) GetVersions(sourceName string) (map[uint64]bool, error)
  • func (m *MigrationStateStoreHdbTable) InsertVersion(sourceName string, version int64) error
  • func (m *MigrationStateStoreHdbTable) PrepareMigrationsStateStore(sourceName string) error
  • func (m *MigrationStateStoreHdbTable) RemoveVersion(sourceName string, version int64) error
  • func (m *MigrationStateStoreHdbTable) SetVersion(sourceName string, version int64, dirty bool) error
  • func (m *MigrationStateStoreHdbTable) SetVersions(sourceName string, versions []statestore.Version) error

Constants

const (
	DefaultMigrationsTable = "schema_migrations"
	DefaultSchema          = "hdb_catalog"
)

Types

type CatalogStateStore

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

from v1.4 clients are expected to make use of the catalog API rather than assuming a SQL backend for metadata storage

func NewCatalogStateStore

func NewCatalogStateStore(c *statestore.CLICatalogState) *CatalogStateStore

func (*CatalogStateStore) GetVersions

func (m *CatalogStateStore) GetVersions(database string) (map[uint64]bool, error)

func (*CatalogStateStore) InsertVersion

func (m *CatalogStateStore) InsertVersion(database string, version int64) error

func (*CatalogStateStore) PrepareMigrationsStateStore

func (m *CatalogStateStore) PrepareMigrationsStateStore(_ string) error

func (*CatalogStateStore) RemoveVersion

func (m *CatalogStateStore) RemoveVersion(database string, version int64) error

func (*CatalogStateStore) SetVersion

func (m *CatalogStateStore) SetVersion(database string, version int64, dirty bool) error

func (*CatalogStateStore) SetVersions

func (m *CatalogStateStore) SetVersions(database string, versions []statestore.Version) error

type MigrationStateStoreHdbTable

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

until version 1.4 migration state was stored a special table this struct will implement the methods required

func NewMigrationStateStoreHdbTable

func NewMigrationStateStoreHdbTable(client hasura.PGSourceOps, schema, table string) *MigrationStateStoreHdbTable

func (*MigrationStateStoreHdbTable) GetVersions

func (m *MigrationStateStoreHdbTable) GetVersions(sourceName string) (map[uint64]bool, error)

func (*MigrationStateStoreHdbTable) InsertVersion

func (m *MigrationStateStoreHdbTable) InsertVersion(sourceName string, version int64) error

func (*MigrationStateStoreHdbTable) PrepareMigrationsStateStore

func (m *MigrationStateStoreHdbTable) PrepareMigrationsStateStore(sourceName string) error

func (*MigrationStateStoreHdbTable) RemoveVersion

func (m *MigrationStateStoreHdbTable) RemoveVersion(sourceName string, version int64) error

func (*MigrationStateStoreHdbTable) SetVersion

func (m *MigrationStateStoreHdbTable) SetVersion(sourceName string, version int64, dirty bool) error

func (*MigrationStateStoreHdbTable) SetVersions

func (m *MigrationStateStoreHdbTable) SetVersions(sourceName string, versions []statestore.Version) error

SetVersions is similar to SetVersion defined above. with the only difference, this is adapted to accept multiple versions