catalog

Aug 17, 2023

Changes in this version

type Service

+ func (s *Service) Close()

Apr 24, 2023

Changes in this version

+ type MigrationMeta struct

+ LastMigration time.Time

+ NameToPath map[string]string

+ func NewMigrationMeta() *MigrationMeta

type Service

+ Meta *MigrationMeta

Mar 16, 2023

Changes in this version

type ReconcileConfig

+ SafeSourceRefresh bool

Feb 23, 2023

Changes in this version

type Service

+ RegistryStore drivers.RegistryStore

Jan 18, 2023

Changes in this version

type MigrationItem

+ FromNormalizedName string

+ HasChanged bool

+ NewCatalog *drivers.CatalogEntry

+ type MigrationType int

+ const MigrationReportUpdate

Jan 6, 2023

Changes in this version

type Service

+ InstID string

Dec 14, 2022

Changes in this version

type MigrationItem

+ NormalizedDependencies []string

+ NormalizedName string

+ type ReconcileConfig struct

+ ChangedPaths []string

+ DryRun bool

+ ForcedPaths []string

+ Strict bool

+ type ReconcileResult struct

+ AddedObjects []*drivers.CatalogEntry

+ AffectedPaths []string

+ DroppedObjects []*drivers.CatalogEntry

+ Errors []*runtimev1.ReconcileError

+ UpdatedObjects []*drivers.CatalogEntry

+ func NewReconcileResult() *ReconcileResult

type Service

+ func (s *Service) FindEntries(ctx context.Context, typ drivers.ObjectType) []*drivers.CatalogEntry

+ func (s *Service) FindEntry(ctx context.Context, name string) (*drivers.CatalogEntry, bool)

+ func (s *Service) Reconcile(ctx context.Context, conf ReconcileConfig) (*ReconcileResult, error)

Nov 22, 2022

Changes in this version

+ const MigrationCreate

+ const MigrationDelete

+ const MigrationNoChange

+ const MigrationRename

+ const MigrationUpdate

+ type ArtifactError struct

+ Error error

+ Path string

+ type MigrationConfig struct

+ ChangedPaths []string

+ DryRun bool

+ ForcedPaths []string

+ Strict bool

+ type MigrationItem struct

+ CatalogInFile *api.CatalogObject

+ CatalogInStore *api.CatalogObject

+ Dependencies []string

+ Error *api.MigrationError

+ FromName string

+ FromPath string

+ Name string

+ Path string

+ Type int

+ type MigrationResult struct

+ AddedObjects []*api.CatalogObject

+ AffectedPaths []string

+ DroppedObjects []*api.CatalogObject

+ Errors []*api.MigrationError

+ UpdatedObjects []*api.CatalogObject

+ func NewMigrationResult() *MigrationResult

+ type Service struct

+ Catalog drivers.CatalogStore

+ InstId string

+ LastMigration time.Time

+ NameToPath map[string]string

+ Olap drivers.OLAPStore

+ PathToName map[string]string

+ Repo drivers.RepoStore

+ RepoId string

+ func NewService(catalog drivers.CatalogStore, repo drivers.RepoStore, olap drivers.OLAPStore, ...) *Service

+ func (s *Service) GetCatalogObject(ctx context.Context, name string) (*api.CatalogObject, error)

+ func (s *Service) ListObjects(ctx context.Context, typ api.CatalogObject_Type) ([]*api.CatalogObject, error)

+ func (s *Service) Migrate(ctx context.Context, conf MigrationConfig) (*MigrationResult, error)