catalog

Documentation

Index

• type ArtifactError
• type MigrationItem
• type MigrationMeta
  • func NewMigrationMeta() *MigrationMeta
• type MigrationType
• type ReconcileConfig
• type ReconcileResult
  • func NewReconcileResult() *ReconcileResult
• type Service
  • func NewService(catalog drivers.CatalogStore, repo drivers.RepoStore, olap drivers.OLAPStore, ...) *Service
  • func (s *Service) Close()
  • func (s *Service) FindEntries(ctx context.Context, typ drivers.ObjectType) ([]*drivers.CatalogEntry, error)
  • func (s *Service) FindEntry(ctx context.Context, name string) (*drivers.CatalogEntry, error)
  • func (s *Service) Reconcile(ctx context.Context, conf ReconcileConfig) (*ReconcileResult, error)

Types

type ArtifactError

type ArtifactError struct {
	Error error
	Path  string
}

type MigrationItem

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

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
}

func NewMigrationMeta

func NewMigrationMeta() *MigrationMeta

type MigrationType

type MigrationType int

const (
	MigrationNoChange     MigrationType = 0
	MigrationCreate       MigrationType = 1
	MigrationRename       MigrationType = 2
	MigrationUpdate       MigrationType = 3
	MigrationReportUpdate MigrationType = 4
	MigrationDelete       MigrationType = 5
)

type ReconcileConfig

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

type ReconcileResult

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

func NewReconcileResult

func NewReconcileResult() *ReconcileResult

type Service

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

	Meta *MigrationMeta
	// contains filtered or unexported fields
}

func NewService

func NewService(
	catalog drivers.CatalogStore,
	repo drivers.RepoStore,
	olap drivers.OLAPStore,
	registry drivers.RegistryStore,
	instID string,
	logger *zap.Logger,
	m *MigrationMeta,
	release func(),
	ac activity.Client,
) *Service

func (*Service) Close

func (s *Service) Close()

func (*Service) FindEntries

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

func (*Service) FindEntry

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

func (*Service) Reconcile

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