Method performZooKeeperGetRequest

src/Server/KeeperHTTPStorageHandler.cpp:199–215

}

void KeeperHTTPStorageHandler::performZooKeeperGetRequest(const std::string & storage_path, HTTPServerResponse & response) const
{
    String result;
    if (!keeper_client->get()->tryGet(storage_path, result))
    {
        setErrorResponseForZKCode(Coordination::Error::ZNONODE, response);
        return;
    }

    response.setStatus(Poco::Net::HTTPResponse::HTTP_OK);
    response.setContentType("application/octet-stream");
    response.setContentLength(result.size());

    auto buffer = response.send();
    buffer->write(result.c_str(), result.size());
    buffer->next();
}

void KeeperHTTPStorageHandler::performZooKeeperSetRequest(
    const std::string & storage_path, HTTPServerRequest & request, HTTPServerResponse & response) const