scroll.h

Go to the documentation of this file.

 
#pragma once
 
#include <string>
#include <memory>
#include <vector>
#include <cstdint>
 
 
// Forward Json::Value existence.
namespace Json {
    class Value;
}
 
 
namespace elasticlient {
 
 
// Forward Client class existence.
class Client;
 
 
class Scroll {
  protected:
    class Implementation;
    std::unique_ptr<Implementation> impl;
 
  public:
    explicit Scroll(const std::shared_ptr<Client> &client,
                    std::size_t scrollSize = 100,
                    const std::string &scrollTimeout = "1m");
 
    explicit Scroll(const std::vector<std::string> &hostUrlList,
                    std::size_t scrollSize = 100,
                    const std::string &scrollTimeout = "1m",
                    std::int32_t connectionTimeout = 6000);
 
    Scroll(Scroll &&);
 
    virtual ~Scroll();
 
    void clear();
 
    void init(const std::string &indexName,
              const std::string &docType,
              const std::string &searchBody);
 
    bool next(Json::Value &parsedResult);
 
    const std::shared_ptr<Client> &getClient() const;
 
  protected:
    virtual bool createScroll(Json::Value &parsedResult);
};
 
 
class ScrollByScan : public Scroll {
  public:
    ScrollByScan(ScrollByScan &&);
 
    explicit ScrollByScan(const std::shared_ptr<Client> &client,
                          std::size_t scrollSize = 100,
                          const std::string &scrollTimeout = "1m",
                          int primaryShardsCount = 0);
 
    explicit ScrollByScan(const std::vector<std::string> &hostUrlList,
                          std::size_t scrollSize = 100,
                          const std::string &scrollTimeout = "1m",
                          int primaryShardsCount = 0,
                          std::int32_t connectionTimeout = 6000);
 
  protected:
    virtual bool createScroll(Json::Value &parsedResult) override;
};
 
 
} // namespace elasticlient