NewDataReader - Creates a new DataReader
(database *db.Memory)
| 28 | |
| 29 | // NewDataReader - Creates a new DataReader |
| 30 | func NewDataReader(database *db.Memory) *DataReader { |
| 31 | return &DataReader{ |
| 32 | database: database, |
| 33 | } |
| 34 | } |
| 35 | |
| 36 | // QueryRelationships queries the database for relationships based on the provided filter. |
| 37 | func (r *DataReader) QueryRelationships(_ context.Context, tenantID string, filter *base.TupleFilter, _ string, pagination database.CursorPagination) (it *database.TupleIterator, err error) { |
no outgoing calls
no test coverage detected