Documentation
¶
Index ¶
Constants ¶
View Source
const ( MigrationNoChange int = 0 MigrationCreate = 1 MigrationRename = 2 MigrationUpdate = 3 MigrationDelete = 4 )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ArtifactError ¶
type MigrationItem ¶
type MigrationItem struct {
Name string
NormalizedName string
Path string
CatalogInFile *drivers.CatalogEntry
CatalogInStore *drivers.CatalogEntry
Type int
FromName string
FromPath string
NormalizedDependencies []string
Error *runtimev1.ReconcileError
}
type ReconcileConfig ¶ added in v0.16.0
type ReconcileResult ¶ added in v0.16.0
type ReconcileResult struct {
AddedObjects []*drivers.CatalogEntry
UpdatedObjects []*drivers.CatalogEntry
DroppedObjects []*drivers.CatalogEntry
AffectedPaths []string
Errors []*runtimev1.ReconcileError
}
func NewReconcileResult ¶ added in v0.16.0
func NewReconcileResult() *ReconcileResult
type Service ¶
type Service struct {
Catalog drivers.CatalogStore
Repo drivers.RepoStore
Olap drivers.OLAPStore
InstId string
// 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
// used to get last logged name when parsing fails
PathToName map[string]string
// contains filtered or unexported fields
}
func NewService ¶
func (*Service) FindEntries ¶ added in v0.16.0
func (s *Service) FindEntries(ctx context.Context, typ drivers.ObjectType) []*drivers.CatalogEntry
func (*Service) Reconcile ¶ added in v0.16.0
func (s *Service) Reconcile(ctx context.Context, conf ReconcileConfig) (*ReconcileResult, error)
Click to show internal directories.
Click to hide internal directories.