bulk.h

Go to the documentation of this file.

 
#pragma once
 
#include <memory>
#include <string>
#include <vector>
#include <cstdint>
 
 
namespace elasticlient {
 
 
// Forward Client class existence.
class Client;
 
 
class IBulkData {
  public:
    virtual ~IBulkData();
 
    virtual std::string indexName() const = 0;
 
    virtual bool empty() const = 0;
 
    virtual std::size_t size() const = 0;
 
    virtual std::string body() const = 0;
};
 
 
class SameIndexBulkData: public IBulkData {
    class Implementation;
    std::unique_ptr<Implementation> impl;
 
  public:
    explicit SameIndexBulkData(const std::string &indexName, std::size_t size = 100);
    ~SameIndexBulkData();
 
    virtual std::string indexName() const override;
 
    bool indexDocument(const std::string &docType,
                       const std::string &id,
                       const std::string &doc);
 
    bool indexDocument(const std::string &docType,
                       const std::string &id,
                       const std::string &doc,
                       bool validate);
 
    bool createDocument(const std::string &docType,
                        const std::string &id,
                        const std::string &doc);
 
    bool createDocument(const std::string &docType,
                        const std::string &id,
                        const std::string &doc,
                        bool validate);
 
    bool updateDocument(
            const std::string &docType,
            const std::string &id,
            const std::string &doc);
 
    bool updateDocument(
            const std::string &docType,
            const std::string &id,
            const std::string &doc,
            bool validate);
 
    void clear();
 
    virtual bool empty() const override;
 
    virtual std::size_t size() const override;
 
    virtual std::string body() const override;
};
 
 
class Bulk {
    class Implementation;
    std::unique_ptr<Implementation> impl;
 
  public:
    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;
 
    const std::shared_ptr<Client> &getClient() const;
 
};
 
 
}  // namespace elasticlient