Home Reference Source Repository 
import AutoFlashBulk from 'schema-mapper-driver-elasticsearch/lib/autoFlushBulk.js'
public class | source

AutoFlashBulk

Constructor Summary

Public Constructor
public

constructor(client: *)

Member Summary

Public Members
public
public

client: *

public
public
public
public
public

timer: *

Method Summary

Public Methods
public

getBulkConnection(projectName: *, projectVersion: *): *

public
public

putItem(id: *, item: *, projectName: *, projectVersion: *, schemaName: *): *

Public Constructors

public constructor(client: *) source

Params:

NameTypeAttributeDescription
client *

Public Members

public bulkQueue: * source

public client: * source

public connections: * source

public highWaterMark: number source

public isProcessing: boolean source

public itemCount: number source

public timer: * source

Public Methods

public getBulkConnection(projectName: *, projectVersion: *): * source

Params:

NameTypeAttributeDescription
projectName *
projectVersion *

Return:

*

public processQueue() source

public putItem(id: *, item: *, projectName: *, projectVersion: *, schemaName: *): * source

Params:

NameTypeAttributeDescription
id *
item *
projectName *
projectVersion *
schemaName *

Return:

*