Class DummyElastic6Service<T>

class: DummyElastic6Service

service in-memory dummy data

Type Parameters

T extends GeneralItem

Hierarchy

Elastic6Service<T>
- DummyElastic6Service

Constructors

constructor

new DummyElastic6Service<T>(dataFile: string, options: ElasticOption): DummyElastic6Service<T>
Type Parameters
- T extends GeneralItem
Parameters
- dataFile: string
- options: ElasticOption
Returns DummyElastic6Service<T>
Overrides Elastic6Service.constructor
- Defined in src/cores/elastic/elastic6-service.ts:1416

Properties

`Readonly` _client

_client: Client

`Protected` _options

_options: ElasticOption

`Private` buffer

buffer: { [id: string]: T } = {}

Type declaration

[id: string]: T

`Static` `Readonly` DECOMPOSED_FIELD

DECOMPOSED_FIELD: "_decomposed" = '_decomposed'

`Static` `Readonly` QWERTY_FIELD

QWERTY_FIELD: "_qwerty" = '_qwerty'

Accessors

client

get client(): Client
get the client instance.

Returns Client
Inherited from Elastic6Service.client
- Defined in src/cores/elastic/elastic6-service.ts:234

isLatestOS2

get isLatestOS2(): boolean
get isLatestOS2
- used when verifying results of search
Returns boolean
Inherited from Elastic6Service.isLatestOS2
- Defined in src/cores/elastic/elastic6-service.ts:353

isOldES6

get isOldES6(): boolean
get isOldES6
- used when setting doctype
- used when verifying mismatched error and results of search
Returns boolean
Inherited from Elastic6Service.isOldES6
- Defined in src/cores/elastic/elastic6-service.ts:339

isOldES71

get isOldES71(): boolean
get isOldES71
- used when verifying mismatched error
Returns boolean
Inherited from Elastic6Service.isOldES71
- Defined in src/cores/elastic/elastic6-service.ts:346

options

get options(): ElasticOption
get the current options.

Returns ElasticOption
Inherited from Elastic6Service.options
- Defined in src/cores/elastic/elastic6-service.ts:240

parsedVersion

get parsedVersion(): ParsedVersion
get the parsedVersion

Returns ParsedVersion
Inherited from Elastic6Service.parsedVersion
- Defined in src/cores/elastic/elastic6-service.ts:359

version

get version(): number
get the version from options

Returns number
Inherited from Elastic6Service.version
- Defined in src/cores/elastic/elastic6-service.ts:246

Methods

createIndex

createIndex(settings?: any): Promise<{ acknowledged: any; index: string; status: any }>
create index by name
Parameters
- Optional settings: any
  
  creating settings
Returns Promise<{ acknowledged: any; index: string; status: any }>
Inherited from Elastic6Service.createIndex
- Defined in src/cores/elastic/elastic6-service.ts:545

deleteItem

deleteItem(id: string, sort?: string | number): Promise<T>
delete item with projections
Parameters
- id: string
  
  item-id
- Optional sort: string | number
Returns Promise<T>
Overrides Elastic6Service.deleteItem
- Defined in src/cores/elastic/elastic6-service.ts:1451

describe

describe(): Promise<{ mappings: any; settings: any }>
describe settings and mappings of index.

Returns Promise<{ mappings: any; settings: any }>
Inherited from Elastic6Service.describe
- Defined in src/cores/elastic/elastic6-service.ts:662

destroyIndex

destroyIndex(): Promise<{ acknowledged: any; index: string; status: any }>
destroy search index

Returns Promise<{ acknowledged: any; index: string; status: any }>
Inherited from Elastic6Service.destroyIndex
- Defined in src/cores/elastic/elastic6-service.ts:585

`Protected` executeSelfTest

executeSelfTest(): Promise<{ isEqual: boolean; optionVersion: ParsedVersion; rootVersion: ParsedVersion }>
Protected
check whether the service version matches the version provided in the options.

only for internal test.

Returns Promise<{ isEqual: boolean; optionVersion: ParsedVersion; rootVersion: ParsedVersion }>
Inherited from Elastic6Service.executeSelfTest
- Defined in src/cores/elastic/elastic6-service.ts:397

findIndex

findIndex(indexName?: string): Promise<{ docsCount: number; docsDeleted: number; health: string; index: string; pri: number; priStoreSize: string; rep: number; status: string; storeSize: string; uuid: string }>
find the index by name
Parameters
- Optional indexName: string
  
  name of the index
Returns Promise<{ docsCount: number; docsDeleted: number; health: string; index: string; pri: number; priStoreSize: string; rep: number; status: string; storeSize: string; uuid: string }>
Inherited from Elastic6Service.findIndex
- Defined in src/cores/elastic/elastic6-service.ts:533

flushIndex

flushIndex(): Promise<any>
flush search index - force store changes into search index immediately

Returns Promise<any>
Inherited from Elastic6Service.flushIndex
- Defined in src/cores/elastic/elastic6-service.ts:638

generateSearchResult

generateSearchResult(body: SearchBody, params?: ElasticSearchAllParams): AsyncGenerator<any[], void, unknown>
create async generator that yields items queried until last
Parameters
- body: SearchBody
  
  Elasticsearch Query DSL that defines the search request (e.g., size, query, filters).
- Optional params: ElasticSearchAllParams
  
  parameters including search type, limit, and retry options.
Returns AsyncGenerator<any[], void, unknown>
Inherited from Elastic6Service.generateSearchResult
- Defined in src/cores/elastic/elastic6-service.ts:1047

getIndexMapping

getIndexMapping(): Promise<any>
get mapping of an index

Returns Promise<any>
Inherited from Elastic6Service.getIndexMapping
- Defined in src/cores/elastic/elastic6-service.ts:510

`Protected` getVersion

getVersion(options?: { dump?: boolean }): Promise<ParsedVersion>
Protected
get the root version from client

only for internal test.
Parameters
- Optional options: { dump?: boolean }
  - Optional dump?: boolean
Returns Promise<ParsedVersion>
Inherited from Elastic6Service.getVersion
- Defined in src/cores/elastic/elastic6-service.ts:367

hello

hello(): string
say hello()

Returns string
Overrides Elastic6Service.hello
- Defined in src/cores/elastic/elastic6-service.ts:1437

listIndices

listIndices(): Promise<{ list: { docsCount: number; docsDeleted: number; health: string; index: string; pri: number; priStoreSize: string; rep: number; status: string; storeSize: string; uuid: string }[] }>
list of index

Returns Promise<{ list: { docsCount: number; docsDeleted: number; health: string; index: string; pri: number; priStoreSize: string; rep: number; status: string; storeSize: string; uuid: string }[] }>
Inherited from Elastic6Service.listIndices
- Defined in src/cores/elastic/elastic6-service.ts:478

load

load(data: T[]): void
Parameters
- data: T[]
Returns void
- Defined in src/cores/elastic/elastic6-service.ts:1425

parseVersion

parseVersion(version: string, options?: { throwable?: boolean }): ParsedVersion
parse version according to Semantic Versioning (SemVer) rules.

Returns
A ParsedVersion object or null if parsing fails and throwable is false.
Parameters
- version: string
  
  The version string to parse (e.g., "1.2.3", "1.2.3-alpha.1", "1.2.3+build.001").
- Optional options: { throwable?: boolean }
  
  Optional configuration for throwable behavior.
  - Optional throwable?: boolean
Returns ParsedVersion
Inherited from Elastic6Service.parseVersion
- Defined in src/cores/elastic/elastic6-service.ts:425

`Private` popullateAutocompleteFields

popullateAutocompleteFields<T>(body: T): T
Private
generate autocomplete fields into the item body to be indexed
Type Parameters
- T = any
Parameters
- body: T
  
  item body to be saved into ES6 index
Returns T
Inherited from Elastic6Service.popullateAutocompleteFields
- Defined in src/cores/elastic/elastic6-service.ts:1260

pushItem

pushItem(item: T, type?: string): Promise<T>
push item for time-series data.
Parameters
- item: T
  
  item to push
- Optional type: string
  
  document type (default: doc-type given at construction time)
Returns Promise<T>
Inherited from Elastic6Service.pushItem
- Defined in src/cores/elastic/elastic6-service.ts:751

readItem

readItem(id: string): Promise<T>
read item with projections
Parameters
- id: string
  
  item-id
Returns Promise<T>
Overrides Elastic6Service.readItem
- Defined in src/cores/elastic/elastic6-service.ts:1439

refreshIndex

refreshIndex(): Promise<any>
refresh search index - refresh index to make all items searchable

Returns Promise<any>
Inherited from Elastic6Service.refreshIndex
- Defined in src/cores/elastic/elastic6-service.ts:614

saveItem

saveItem(id: string, item: T): Promise<T>
save single item
Parameters
- id: string
  
  id
- item: T
  
  item to save
Returns Promise<T>
Overrides Elastic6Service.saveItem
- Defined in src/cores/elastic/elastic6-service.ts:1445

search

search(body: SearchBody, searchType?: SearchType): Promise<SearchResponse<any>>
run search, and get the formatmted response.
Parameters
- body: SearchBody
  
  Elasticsearch Query DSL that defines the search request (e.g., size, query, filters).
- Optional searchType: SearchType
  
  type of search (e.g., 'query_then_fetch', 'dfs_query_then_fetch').
Returns Promise<SearchResponse<any>>
Inherited from Elastic6Service.search
- Defined in src/cores/elastic/elastic6-service.ts:1010

searchAll

searchAll<T>(body: SearchBody, params?: ElasticSearchAllParams): Promise<T[]>
search all until limit (-1 means no-limit)
Type Parameters
- T
Parameters
- body: SearchBody
  
  Elasticsearch Query DSL that defines the search request (e.g., size, query, filters).
- Optional params: ElasticSearchAllParams
  
  parameters including search type, limit, and retry options.
Returns Promise<T[]>
Inherited from Elastic6Service.searchAll
- Defined in src/cores/elastic/elastic6-service.ts:1033

searchRaw

searchRaw<T>(body: SearchBody, searchType?: SearchType): Promise<T>
run search and get the raw response.
Type Parameters
- T extends object = any
Parameters
- body: SearchBody
  
  Elasticsearch Query DSL that defines the search request (e.g., size, query, filters).
- Optional searchType: SearchType
  
  type of search (e.g., 'query_then_fetch', 'dfs_query_then_fetch').
Returns Promise<T>
Inherited from Elastic6Service.searchRaw
- Defined in src/cores/elastic/elastic6-service.ts:970

updateItem

updateItem(id: string, updates: T, increments?: Incrementable): Promise<T>
update item (throw if not exist) update table set a=1, b=b+2 where id='a1' 0. no of a1 -> 1,2 (created)
1. a,b := 10,20 -> 11,22
2. a,b := 10,null -> 11,2 (upsert)
3. a,b := null,20 -> 1,22
Parameters
- id: string
  
  item-id
- updates: T
  
  item to update
- Optional increments: Incrementable
  
  item to increase
Returns Promise<T>
Overrides Elastic6Service.updateItem
- Defined in src/cores/elastic/elastic6-service.ts:1457

`Static` instance

instance(endpoint: string): { client: Client }
simple instance maker.
```
const { client } = ElasticIndexService.instance(endpoint);
```
See
https://www.elastic.co/guide/en/elasticsearch/client/javascript-api/16.x/configuration.html
Parameters
- endpoint: string
  
  service-url
Returns { client: Client }
- client: Client
Inherited from Elastic6Service.instance
- Defined in src/cores/elastic/elastic6-service.ts:205

`Static` prepareSettings

prepareSettings(params: { docType: string; idName: string; replicas?: number; shards?: number; timeSeries?: boolean; version?: string }): any
prepare default setting
- migrated from engine-v2.
Parameters
- params: { docType: string; idName: string; replicas?: number; shards?: number; timeSeries?: boolean; version?: string }
  - docType: string
  - idName: string
  - Optional replicas?: number
  - Optional shards?: number
  - Optional timeSeries?: boolean
  - Optional version?: string
Returns any
Inherited from Elastic6Service.prepareSettings
- Defined in src/cores/elastic/elastic6-service.ts:1090

Class DummyElastic6Service<T>

Type Parameters

T extends GeneralItem

Hierarchy

Index

Constructors

Properties

Accessors

Methods

Constructors

constructor

Type Parameters

T extends GeneralItem

Parameters

dataFile: string

options: ElasticOption

Returns DummyElastic6Service<T>

Properties

Readonly _client

Protected _options

Private buffer

Type declaration

[id: string]: T

Static Readonly DECOMPOSED_FIELD

Static Readonly QWERTY_FIELD

Accessors

client

Returns Client

isLatestOS2

Returns boolean

isOldES6

Returns boolean

isOldES71

Returns boolean

options

Returns ElasticOption

parsedVersion

Returns ParsedVersion

version

Returns number

Methods

createIndex

Parameters

Optional settings: any

Returns Promise<{ acknowledged: any; index: string; status: any }>

deleteItem

Parameters

id: string

Optional sort: string | number

Returns Promise<T>

describe

Returns Promise<{ mappings: any; settings: any }>

destroyIndex

Returns Promise<{ acknowledged: any; index: string; status: any }>

Protected executeSelfTest

Returns Promise<{ isEqual: boolean; optionVersion: ParsedVersion; rootVersion: ParsedVersion }>

findIndex

Parameters

Optional indexName: string

Returns Promise<{ docsCount: number; docsDeleted: number; health: string; index: string; pri: number; priStoreSize: string; rep: number; status: string; storeSize: string; uuid: string }>

flushIndex

Returns Promise<any>

generateSearchResult

Parameters

body: SearchBody

Optional params: ElasticSearchAllParams

Returns AsyncGenerator<any[], void, unknown>

getIndexMapping

Returns Promise<any>

Protected getVersion

Parameters

Optional options: { dump?: boolean }

Optional dump?: boolean

Returns Promise<ParsedVersion>

hello

Returns string

listIndices

Returns Promise<{ list: { docsCount: number; docsDeleted: number; health: string; index: string; pri: number; priStoreSize: string; rep: number; status: string; storeSize: string; uuid: string }[] }>

load

Parameters

`Readonly` _client

`Protected` _options

`Private` buffer

`Static` `Readonly` DECOMPOSED_FIELD

`Static` `Readonly` QWERTY_FIELD

`Optional` settings: any

`Optional` sort: string | number

`Protected` executeSelfTest

`Optional` indexName: string

`Optional` params: ElasticSearchAllParams

`Protected` getVersion

`Optional` options: { dump?: boolean }

`Optional` dump?: boolean

`Optional` options: { throwable?: boolean }

`Optional` throwable?: boolean

`Private` popullateAutocompleteFields

`Optional` type: string

`Optional` searchType: SearchType

`Optional` params: ElasticSearchAllParams

`Optional` searchType: SearchType

`Optional` increments: Incrementable

`Static` instance

`Static` prepareSettings

`Optional` replicas?: number

`Optional` shards?: number

`Optional` timeSeries?: boolean