Method GetFactsDuring

factstore/temporal.go:198–221

GetFactsDuring returns facts that overlap with the given interval. Uses interval tree for O(log n + k) query performance.

(query ast.Atom, interval ast.Interval, fn func(TemporalFact) error)

// GetFactsDuring returns facts that overlap with the given interval.
// Uses interval tree for O(log n + k) query performance.
func (s *TemporalStore) GetFactsDuring(query ast.Atom, interval ast.Interval, fn func(TemporalFact) error) error {
	predMap, ok := s.facts[query.Predicate]
	if !ok {
		return nil
	}

	start := GetStartTime(interval)
	end := GetEndTime(interval)

	for hash, tree := range predMap {
		atom := s.atoms[hash]
		if !Matches(query.Args, atom.Args) {
			continue
		}

		err := tree.QueryRange(start, end, func(factInterval ast.Interval) error {
			return fn(TemporalFact{Atom: atom, Interval: factInterval})
		})
		if err != nil {
			return err
		}
	}
	return nil
}

// GetAllFacts returns all facts matching the query with their intervals.
func (s *TemporalStore) GetAllFacts(query ast.Atom, fn func(TemporalFact) error) error {