Elasticlient
|
Class for bulk document indexing. More...
#include <bulk.h>
Public Member Functions | |
Bulk (const std::shared_ptr< Client > &client) | |
Bulk (const std::vector< std::string > &hostUrlList, std::int32_t connectionTimeout) | |
~Bulk () | |
Bulk (Bulk &&other) | |
std::size_t | perform (const IBulkData &bulk) |
std::size_t | getErrorCount () const |
Return number of errors in last bulk being ran. | |
const std::shared_ptr< Client > & | getClient () const |
Return Client class with current config. | |
Class for bulk document indexing.
elasticlient::Bulk::Bulk | ( | const std::shared_ptr< Client > & | client | ) |
elasticlient::Bulk::Bulk | ( | const std::vector< std::string > & | hostUrlList, |
std::int32_t | connectionTimeout | ||
) |
Initialize bulk indexer and creates Client instance for specified hostUrlList and connectionTimeout.
hostUrlList | list of URLs of Elastic nodes in one cluster. |
connectionTimeout | Elasticsearch node connection timeout. |
elasticlient::Bulk::~Bulk | ( | ) |
Destroy bulk indexer, writing documents not yet indexed, discarding possible errors. If you are interested in errors, call flush() and getErrorCount() methods before destruction is made.
std::size_t elasticlient::Bulk::perform | ( | const IBulkData & | bulk | ) |
Run the bulk.