maintenance

type LineageRevalidator ¶

type LineageRevalidator interface {
	RevalidateUnresolvedLineage(ctx context.Context, limit int) (revalidated, stillUnknown int, err error)
	RevalidateContradictedColumnClaims(ctx context.Context, limit int) (revalidated, stillUnknown int, err error)
}

Runner prunes data with a retention window. LineageRevalidator re-checks ingested lineage whose endpoints the metadata registry did not know when it was stored, and whose column claims a relation that appeared later contradicts.

type Runner ¶

type Runner struct {
	// contains filtered or unexported fields
}

func NewRunner(stores *store.Store, revalidator LineageRevalidator) *Runner

func (r *Runner) Run(ctx context.Context, wg *sync.WaitGroup)