oceandb_elasticsearch_driver/plugin.py
def list(self, search_from=None, search_to=None, limit=None):
        """List all the objects saved elasticsearch.
         :param search_from: start offset of objects to return.
         :param search_to: last offset of objects to return.
         :param limit: max number of values to be returned.
         :return: list with transactions.
         """
        self.logger.debug('elasticsearch::list')
        body = {
            'sort': [
                {"_id": "asc"},
            ],
            'query': {
                'match_all': {}
            }
        }

        if search_from:
            body['from'] = search_from
        if search_to:
            body['size'] = search_to - search_from
        if limit:
            body['size'] = limit

        page = self.driver._es.search(
            index=self.driver._index,
            doc_type='_doc',
            body=body
        )

        object_list = []
        for x in page['hits']['hits']:
            object_list.append(x['_source'])
        return object_list
def list(self, search_from=None, search_to=None, limit=None):
        """List all the objects saved elasticsearch.
         :param search_from: start offset of objects to return.
         :param search_to: last offset of objects to return.
         :param limit: max number of values to be returned.
         :return: list with transactions.
         """
        self.logger.debug('elasticsearch::list')
        body = {
            'sort': [
                {"_id": "asc"},
            ],
            'query': {
                'match_all': {}
            }
        }

        if search_from:
            body['from'] = search_from
        if search_to:
            body['size'] = search_to - search_from
        if limit:
            body['size'] = limit

        page = self.driver._es.search(
            index=self.driver._index,
            doc_type='_doc',
            body=body
        )

        object_list = []
        for x in page['hits']['hits']:
            object_list.append(x['_source'])
        return object_list
def list ( self , search_from = None , search_to = None , limit = None ) : self . logger . debug ( 'elasticsearch::list' ) body = { 'sort' : [ { "_id" : "asc" } , ] , 'query' : { 'match_all' : { } } } if search_from : body [ 'from' ] = search_from if search_to : body [ 'size' ] = search_to - search_from if limit : body [ 'size' ] = limit page = self . driver . _es . search ( index = self . driver . _index , doc_type = '_doc' , body = body ) object_list = [ ] for x in page [ 'hits' ] [ 'hits' ] : object_list . append ( x [ '_source' ] ) return object_list
List all the objects saved elasticsearch.
         :param search_from: start offset of objects to return.
         :param search_to: last offset of objects to return.
         :param limit: max number of values to be returned.
         :return: list with transactions.
List all the objects saved elasticsearch . : param search_from : start offset of objects to return . : param search_to : last offset of objects to return . : param limit : max number of values to be returned . : return : list with transactions .