Query returns a an iterator for the supplied query.
(q *query.Query, local, internal bool)
| 108 | |
| 109 | // Query returns a an iterator for the supplied query. |
| 110 | func (s *StorageInterface) Query(q *query.Query, local, internal bool) (*iterator.Iterator, error) { |
| 111 | it := iterator.New() |
| 112 | |
| 113 | module.mgr.Go("connection query", func(_ *mgr.WorkerCtx) error { |
| 114 | s.processQuery(q, it) |
| 115 | return nil |
| 116 | }) |
| 117 | |
| 118 | return it, nil |
| 119 | } |
| 120 | |
| 121 | func (s *StorageInterface) processQuery(q *query.Query, it *iterator.Iterator) { |
| 122 | var matches bool |
nothing calls this directly
no test coverage detected