catalog

Documentation

Index

• Constants
• type ArtifactError
• type MigrationItem
• type ReconcileConfig
• type ReconcileResult
  • func NewReconcileResult() *ReconcileResult
• type Service
  • func NewService(catalog drivers.CatalogStore, repo drivers.RepoStore, olap drivers.OLAPStore, ...) *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)

Constants

const (
	MigrationNoChange int = 0
	MigrationCreate   int = 1
	MigrationRename   int = 2
	MigrationUpdate   int = 3
	MigrationDelete   int = 4
)

Types

type ArtifactError

type ArtifactError struct {
	Error error
	Path  string
}

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

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

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
	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 NewService(
	catalog drivers.CatalogStore,
	repo drivers.RepoStore,
	olap drivers.OLAPStore,
	instID string,
	logger *zap.Logger,
) *Service

func (*Service) FindEntries

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

func (*Service) FindEntry

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

func (*Service) Reconcile

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