migrator

Documentation

Index

• Variables
• func Create(ctx context.Context, olap drivers.OLAPStore, repo drivers.RepoStore, ...) error
• func CreateValidationError(filePath, message string) []*runtimev1.ReconcileError
• func Delete(ctx context.Context, olap drivers.OLAPStore, catalog *drivers.CatalogEntry) error
• func ExistsInOlap(ctx context.Context, olap drivers.OLAPStore, catalog *drivers.CatalogEntry) (bool, error)
• func GetDependencies(ctx context.Context, olap drivers.OLAPStore, catalog *drivers.CatalogEntry) ([]string, []*drivers.CatalogEntry)
• func IsEqual(ctx context.Context, cat1, cat2 *drivers.CatalogEntry) bool
• func LastUpdated(ctx context.Context, instID string, repo drivers.RepoStore, ...) (time.Time, error)
• func Register(t drivers.ObjectType, artifact EntityMigrator)
• func Rename(ctx context.Context, olap drivers.OLAPStore, from string, ...) error
• func SetSchema(ctx context.Context, olap drivers.OLAPStore, catalog *drivers.CatalogEntry) error
• func Update(ctx context.Context, olap drivers.OLAPStore, repo drivers.RepoStore, ...) error
• func Validate(ctx context.Context, olap drivers.OLAPStore, catalog *drivers.CatalogEntry) []*runtimev1.ReconcileError
• type EntityMigrator
• type Options

Variables

var Migrators = make(map[drivers.ObjectType]EntityMigrator)

Functions

func Create

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

func CreateValidationError

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

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

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, opts Options, oldCatalog, newCatalog *drivers.CatalogEntry) error

func Validate

func Validate(ctx context.Context, olap drivers.OLAPStore, catalog *drivers.CatalogEntry) []*runtimev1.ReconcileError

Validate also returns list of dependents.

Types

type EntityMigrator

type EntityMigrator interface {
	Create(ctx context.Context, olap drivers.OLAPStore, repo drivers.RepoStore, opts Options, catalog *drivers.CatalogEntry) error
	Update(ctx context.Context, olap drivers.OLAPStore, repo drivers.RepoStore, opts Options, 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)
}

type Options

type Options struct {
	InstanceEnv               map[string]string
	IngestStorageLimitInBytes int64
}