soa/service/zookeeper_configuration_service.h

#ifndef __service__zookeeper_configuration_service_h__
#define __service__zookeeper_configuration_service_h__


#include "service_base.h"
#include <memory>


namespace Datacratic {

struct ZookeeperConnection;

/*****************************************************************************/
/* ZOOKEEPER CONFIGURATION SERVICE                                           */
/*****************************************************************************/

struct ZookeeperConfigurationService
    : public ConfigurationService {

    ZookeeperConfigurationService();

    ZookeeperConfigurationService(const std::string & host,
                                  const std::string & prefix,
                                  int timeout = 5);
    
    ~ZookeeperConfigurationService();

    void init(const std::string & host,
              const std::string & prefix,
              int timeout = 5);

    virtual Json::Value getJson(const std::string & value,
                                Watch watch = Watch());
    
    virtual void set(const std::string & key,
                     const Json::Value & value);

    virtual std::string setUnique(const std::string & key,
                                  const Json::Value & value);

    virtual std::vector<std::string>
    getChildren(const std::string & key,
                Watch watch = Watch());

    virtual bool forEachEntry(const OnEntry & onEntry,
                              const std::string & startPrefix = "") const;

    virtual void removePath(const std::string & path);

private:
    std::unique_ptr<ZookeeperConnection> zoo;
    std::string prefix;
};


} // namespace Datacratic


#endif /* __service__zookeeper_configuration_service_h__ */