migrator

package
v0.20.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 1, 2023 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

Functions

func Create

func Create(ctx context.Context, olap drivers.OLAPStore, repo drivers.RepoStore, catalog *drivers.CatalogEntry) error

func CreateValidationError added in v0.16.0

func CreateValidationError(filePath, message string) []*runtimev1.ReconcileError

func Delete

func Delete(ctx context.Context, olap drivers.OLAPStore, catalog *drivers.CatalogEntry) error

func ExistsInOlap

func ExistsInOlap(ctx context.Context, olap drivers.OLAPStore, catalog *drivers.CatalogEntry) (bool, error)

func GetDependencies

func GetDependencies(ctx context.Context, olap drivers.OLAPStore, catalog *drivers.CatalogEntry) ([]string, []*drivers.CatalogEntry)

func IsEqual

func IsEqual(ctx context.Context, cat1, cat2 *drivers.CatalogEntry) bool

IsEqual checks everything but the name.

func LastUpdated added in v0.17.0

func LastUpdated(ctx context.Context, instID string, repo drivers.RepoStore, catalog *drivers.CatalogEntry) (time.Time, error)

func Register

func Register(t drivers.ObjectType, artifact EntityMigrator)

func Rename

func Rename(ctx context.Context, olap drivers.OLAPStore, from string, catalog *drivers.CatalogEntry) error

func SetSchema added in v0.16.0

func SetSchema(ctx context.Context, olap drivers.OLAPStore, catalog *drivers.CatalogEntry) error

func Update

func Update(ctx context.Context, olap drivers.OLAPStore, repo drivers.RepoStore, oldCatalog, newCatalog *drivers.CatalogEntry) error

func Validate

Validate also returns list of dependents.

Types

type EntityMigrator

type EntityMigrator interface {
	Create(ctx context.Context, olap drivers.OLAPStore, repo drivers.RepoStore, catalog *drivers.CatalogEntry) error
	Update(ctx context.Context, olap drivers.OLAPStore, repo drivers.RepoStore, oldCatalog *drivers.CatalogEntry, newCatalog *drivers.CatalogEntry) error
	Rename(ctx context.Context, olap drivers.OLAPStore, from string, catalog *drivers.CatalogEntry) error
	Delete(ctx context.Context, olap drivers.OLAPStore, catalog *drivers.CatalogEntry) error
	GetDependencies(ctx context.Context, olap drivers.OLAPStore, catalog *drivers.CatalogEntry) ([]string, []*drivers.CatalogEntry)
	Validate(ctx context.Context, olap drivers.OLAPStore, catalog *drivers.CatalogEntry) []*runtimev1.ReconcileError
	// IsEqual checks everything but the name
	IsEqual(ctx context.Context, cat1 *drivers.CatalogEntry, cat2 *drivers.CatalogEntry) bool
	ExistsInOlap(ctx context.Context, olap drivers.OLAPStore, catalog *drivers.CatalogEntry) (bool, error)
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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