Method Merge

factstore/temporal.go:377–394

Merge merges contents of another temporal store into this one. Returns an error if the interval limit is exceeded for any atom.

(other ReadOnlyTemporalFactStore)

// Merge merges contents of another temporal store into this one.
// Returns an error if the interval limit is exceeded for any atom.
func (s *TemporalStore) Merge(other ReadOnlyTemporalFactStore) error {
	var mergeErr error
	for _, pred := range other.ListPredicates() {
		query := ast.NewQuery(pred)
		other.GetAllFacts(query, func(tf TemporalFact) error {
			_, err := s.Add(tf.Atom, tf.Interval)
			if err != nil {
				mergeErr = err
				return err // Stop iteration on error
			}
			return nil
		})
		if mergeErr != nil {
			return mergeErr
		}
	}
	return nil
}

// TemporalFactStoreAdapter wraps a TemporalFactStore to provide
// a standard FactStore interface. Facts are returned without