catalog

type ArtifactError struct {
	Error error
	Path  string
}

type MigrationItem struct {
	Name                   string
	NormalizedName         string
	Path                   string
	Type                   MigrationType
	CatalogInFile          *drivers.CatalogEntry
	CatalogInStore         *drivers.CatalogEntry
	NewCatalog             *drivers.CatalogEntry
	HasChanged             bool
	FromName               string
	FromNormalizedName     string
	FromPath               string
	NormalizedDependencies []string
	Error                  *runtimev1.ReconcileError
}

type MigrationMeta struct {
	// temporary information. should this be persisted into olap?
	// LastMigration stores the last time migrate was run. Used to filter out repos that didnt change since this time
	LastMigration time.Time

	// used to get path when we only have name. happens when we get name from DAG
	// TODO: should we add path to the DAG instead
	NameToPath map[string]string
	// contains filtered or unexported fields
}

type MigrationType int

type ReconcileConfig struct {
	DryRun            bool
	Strict            bool
	ChangedPaths      []string
	ForcedPaths       []string
	SafeSourceRefresh bool
}

type ReconcileResult struct {
	AddedObjects   []*drivers.CatalogEntry
	UpdatedObjects []*drivers.CatalogEntry
	DroppedObjects []*drivers.CatalogEntry
	AffectedPaths  []string
	Errors         []*runtimev1.ReconcileError
}

type Service struct {
	Catalog       drivers.CatalogStore
	Repo          drivers.RepoStore
	Olap          drivers.OLAPStore
	RegistryStore drivers.RegistryStore
	InstID        string

	Meta *MigrationMeta
	// contains filtered or unexported fields
}