EsBulkProxy

Contains a buffer that automatically flushes and calls a specified action when the size hits the given threshold.

struct EsBulkProxy {

Client client;

ulong threshold;

ulong recordCount;

string buffer;

void flush();

void append(string input);

void appendAction(string index, string method, string type, string id, string data);

void appendIndex(string index, string type, string id, string data);

void appendIndex(string index, string type, string id, Json record);

}

Alias This

Members

Functions

append void append(string input): Undocumented in source. Be warned that the author may not have intended to support it.
appendAction void appendAction(string index, string method, string type, string id, string data): Undocumented in source. Be warned that the author may not have intended to support it.
appendIndex void appendIndex(string index, string type, string id, string data): Undocumented in source. Be warned that the author may not have intended to support it.
appendIndex void appendIndex(string index, string type, string id, Json record): Undocumented in source. Be warned that the author may not have intended to support it.
flush void flush(): Undocumented in source. Be warned that the author may not have intended to support it.

Variables

buffer string buffer;: Undocumented in source.
client Client client;: Undocumented in source.
recordCount ulong recordCount;: Undocumented in source.
threshold ulong threshold;: Undocumented in source.

Meta

Source

See Implementation

elasticsearch bulk_proxy static variables

ESBulkUploadThreshold

structs

EsBulkProxy