code: def search(self, start_ts, end_ts):
          
          return self._stream_search(
              index=self.meta_index_name,
              body={"query": {"range": {"_ts": {"gte": start_ts, "lte": end_ts}}}},
          )
docs: Query Elasticsearch for documents in a time range.
  
          This method is used to find documents that may be in conflict during
          a rollback event in MongoDB.