Method GetAllFacts

factstore/temporal.go:224–259

GetAllFacts returns all facts matching the query with their intervals.

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

// GetAllFacts returns all facts matching the query with their intervals.
func (s *TemporalStore) GetAllFacts(query ast.Atom, fn func(TemporalFact) error) error {
	if query.Predicate.Symbol == "" {
		for _, predMap := range s.facts {
			for hash, tree := range predMap {
				atom := s.atoms[hash]
				err := tree.All(func(interval ast.Interval) error {
					return fn(TemporalFact{Atom: atom, Interval: interval})
				})
				if err != nil {
					return err
				}
			}
		}
		return nil
	}

	predMap, ok := s.facts[query.Predicate]
	if !ok {
		return nil
	}

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

		err := tree.All(func(interval ast.Interval) error {
			return fn(TemporalFact{Atom: atom, Interval: interval})
		})
		if err != nil {
			return err
		}
	}
	return nil
}

// ContainsAt returns true if the atom is valid at the given time.
func (s *TemporalStore) ContainsAt(atom ast.Atom, t time.Time) bool {