import { ConfigOptions, GetResponse, SearchResponse } from "elasticsearch"; import { Tracer } from "tracer"; export declare class EsStoreService { private $logger; private client; constructor($logger: Tracer.Logger); /** * 保存分析出来的链接地址 * 先判断地址是不是已经在es中 * 存在的话,则不存入queue中 * @param urls 连接数组 * @param esIndex index * @param esType type */ saveUrls(urls: Array, esIndex: string, esType: string): Promise>; clearUrls(esIndex: string): Promise; /** * 存储当前的地址 * @param queueItem 数据 * @param esIndex 索引 * @param esType 类型 */ saveQueueItem(queueItem: any, esIndex: string, esType: string): Promise; /** * 存储当前的地址 * @param result 数据 * @param esIndex 索引 * @param esType 类型 */ saveResult(_id: string, result: any, esIndex: string, esType: string): Promise; /** * 存储当前的地址 * @param result 数据 * @param esIndex 索引 * @param esType 类型 */ createResult(_id: string, result: any, esIndex: string, esType: string): Promise; /** * 获取单个数据 * @param param0 * _id es的id * esIndex 索引 * esType 类型 */ getItem(_id: any, esIndex: string, esType: string): Promise>; /** * scroll 所有的记录 * @param esIndex index * @param esType type * @param scrollId id */ scroll(esIndex: string, esType: string, scrollId: string): Promise>; /** * 初始化 * @param globalOptions 设置项 */ init(globalOptions: ConfigOptions): Promise; /** * pick 字段 * @param result 数据 * @param fields 字段 */ private pick; }