plugins

type BaseExtractor[Opts any, Feature db.Table] struct {
	// Options to pass via yaml to this step.
	libconf.JsonOpts[Opts]
	// Database connection where the datasources are stored.
	DB *db.DB

	RecencySeconds int
	UpdatedAt      *time.Time
	// contains filtered or unexported fields
}

type Feature any

type FeatureExtractor interface {
	// Configure the feature extractor with a spec and (optional) databases.
	Init(datasourceDB *db.DB, extractorDB *db.DB, spec v1alpha1.KnowledgeSpec) error
	// Extract features from the given data.
	Extract() ([]Feature, error)
}