Skip to main content

@terascope/teraslice-state-storage / elasticsearch-state-storage / default

Class: default

Defined in: teraslice-state-storage/src/elasticsearch-state-storage/index.ts:11

Constructors

Constructor

new default(client, logger, config): ESCachedStateStorage

Defined in: teraslice-state-storage/src/elasticsearch-state-storage/index.ts:22

Parameters

ParameterType
clientClient
loggerLogger
configESStateStorageConfig

Returns

ESCachedStateStorage

Properties

PropertyModifierTypeDefined in
cachepublicdefault<DataEntity<Record<string, any>, _DataEntityMetadata<Record<string, any>>>>teraslice-state-storage/src/elasticsearch-state-storage/index.ts:20

Methods

count()

count(): number

Defined in: teraslice-state-storage/src/elasticsearch-state-storage/index.ts:40

Returns

number


get()

get(doc): Promise<DataEntity<Record<string, any>, _DataEntityMetadata<Record<string, any>>> | undefined>

Defined in: teraslice-state-storage/src/elasticsearch-state-storage/index.ts:98

Parameters

ParameterType
docDataEntity

Returns

Promise<DataEntity<Record<string, any>, _DataEntityMetadata<Record<string, any>>> | undefined>


getFromCache()

getFromCache(doc): DataEntity<Record<string, any>, _DataEntityMetadata<Record<string, any>>> | undefined

Defined in: teraslice-state-storage/src/elasticsearch-state-storage/index.ts:80

Parameters

ParameterType
docDataEntity

Returns

DataEntity<Record<string, any>, _DataEntityMetadata<Record<string, any>>> | undefined


getFromCacheByKey()

getFromCacheByKey(key): DataEntity<Record<string, any>, _DataEntityMetadata<Record<string, any>>> | undefined

Defined in: teraslice-state-storage/src/elasticsearch-state-storage/index.ts:85

Parameters

ParameterType
keystring | number

Returns

DataEntity<Record<string, any>, _DataEntityMetadata<Record<string, any>>> | undefined


getIdentifier()

getIdentifier(doc, metaField): string

Defined in: teraslice-state-storage/src/elasticsearch-state-storage/index.ts:44

Parameters

ParameterType
docDataEntity
metaFieldstring

Returns

string


initialize()

initialize(): Promise<void>

Defined in: teraslice-state-storage/src/elasticsearch-state-storage/index.ts:34

Returns

Promise<void>


isCached()

isCached(doc): boolean

Defined in: teraslice-state-storage/src/elasticsearch-state-storage/index.ts:89

Parameters

ParameterType
docDataEntity

Returns

boolean


isKeyCached()

isKeyCached(key): boolean

Defined in: teraslice-state-storage/src/elasticsearch-state-storage/index.ts:94

Parameters

ParameterType
keystring | number

Returns

boolean


mget()

mget(docArray): Promise<MGetCacheResponse>

Defined in: teraslice-state-storage/src/elasticsearch-state-storage/index.ts:106

Parameters

ParameterType
docArrayDataEntity<Record<string, any>, _DataEntityMetadata<Record<string, any>>>[]

Returns

Promise<MGetCacheResponse>


mset()

mset(docArray): Promise<void>

Defined in: teraslice-state-storage/src/elasticsearch-state-storage/index.ts:56

Parameters

ParameterType
docArrayDataEntity<Record<string, any>, _DataEntityMetadata<Record<string, any>>>[]

Returns

Promise<void>


set()

set(doc): void

Defined in: teraslice-state-storage/src/elasticsearch-state-storage/index.ts:70

Parameters

ParameterType
docDataEntity

Returns

void


setCacheByKey()

setCacheByKey(key, doc): void

Defined in: teraslice-state-storage/src/elasticsearch-state-storage/index.ts:76

Parameters

ParameterType
keystring | number
docDataEntity

Returns

void


shutdown()

shutdown(): Promise<void>

Defined in: teraslice-state-storage/src/elasticsearch-state-storage/index.ts:36

Returns

Promise<void>