10#include <userver/clients/dns/resolver_fwd.hpp>
11#include <userver/clients/http/error.hpp>
12#include <userver/clients/http/plugin.hpp>
13#include <userver/clients/http/response.hpp>
14#include <userver/clients/http/response_future.hpp>
15#include <userver/concurrent/queue.hpp>
16#include <userver/crypto/certificate.hpp>
17#include <userver/crypto/private_key.hpp>
18#include <userver/http/http_version.hpp>
19#include <userver/utils/impl/source_location.hpp>
21USERVER_NAMESPACE_BEGIN
24class TracingManagerBase;
28namespace clients::http {
31class StreamedResponse;
36class DestinationStatistics;
37struct TestsuiteConfig;
44enum class HttpMethod { kGet, kPost, kHead, kPut, kDelete, kPatch, kOptions };
52using USERVER_NAMESPACE::
http::HttpVersion;
77ProxyAuthType ProxyAuthTypeFromString(std::string_view auth_name);
89 RequestStats&& req_stats,
90 const std::shared_ptr<DestinationStatistics>& dest_stats,
93 const tracing::TracingManagerBase& tracing_manager
104 Request&
get(std::string url) &;
105 Request get(std::string url) &&;
110 Request&
head(std::string url) &;
111 Request head(std::string url) &&;
116 Request&
post(std::string url, std::string data = {}) &;
117 Request post(std::string url, std::string data = {}) &&;
119 Request&
post(std::string url, Form&& form) &;
120 Request post(std::string url, Form&& form) &&;
125 Request&
put(std::string url, std::string data = {}) &;
126 Request put(std::string url, std::string data = {}) &&;
132 Request&
patch(std::string url, std::string data = {}) &;
133 Request patch(std::string url, std::string data = {}) &&;
137 Request delete_method() &&;
140 Request delete_method(std::string url) &&;
143 Request delete_method(std::string url, std::string data) &&;
147 Request set_custom_http_request_method(std::string method) &&;
150 Request&
url(std::string url) &;
151 Request url(std::string url) &&;
153 Request&
data(std::string data) &;
154 Request data(std::string data) &&;
157 Request form(Form&& form) &&;
160 Request headers(
const Headers& headers) &&;
171 Request proxy_headers(
const Headers& headers) &&;
186 Request cookies(
const Cookies& cookies) &&;
188 Request&
cookies(
const std::unordered_map<std::string, std::string>& cookies) &;
189 Request cookies(
const std::unordered_map<std::string, std::string>& cookies) &&;
192 Request follow_redirects(
bool follow =
true) &&;
195 Request timeout(
long timeout_ms) &&;
196 Request& timeout(std::chrono::milliseconds timeout_ms) & {
return timeout(timeout_ms.count()
); }
197 Request timeout(std::chrono::milliseconds timeout_ms) && {
return std::move(
this->timeout(timeout_ms.count()
)); }
200 Request verify(
bool verify =
true) &&;
226 Request&
retry(
short retries = 3,
bool on_fails =
true) &;
227 Request retry(
short retries = 3,
bool on_fails =
true) &&;
237 Request use_ipv4() &&;
240 Request use_ipv6() &&;
245 Request connect_to(
const ConnectTo& connect_to) &&;
247 template <
typename T>
248 std::enable_if_t<std::is_same_v<ConnectTo, T>, Request&> connect_to(T&&) {
249 static_assert(!
sizeof(T),
"ConnectTo argument must not be temporary, it must outlive Request");
260 Request SetLoggedUrl(std::string url) &&;
266 Request SetDestinationMetricName(
const std::string& destination) &&;
270 void SetTestsuiteConfig(
const std::shared_ptr<
const TestsuiteConfig>& config) &;
272 void SetAllowedUrlsExtra(
const std::vector<std::string>& urls) &;
281 Request DisableReplyDecoding() &&;
283 void SetCancellationPolicy(CancellationPolicy cp);
288 Request SetTracingManager(
const tracing::TracingManagerBase&) &&;
300 utils::impl::SourceLocation location =
utils::impl::SourceLocation::Current()
308 const std::shared_ptr<
concurrent::StringStreamQueue>& queue,
309 utils::impl::SourceLocation location =
utils::impl::SourceLocation::Current()
319 [[nodiscard]] std::shared_ptr<Response>
perform(
320 utils::impl::SourceLocation location =
utils::impl::SourceLocation::Current()
325 const std::string& GetUrl() && =
delete;
329 const std::string& GetData() && =
delete;
335 std::shared_ptr<RequestState> pimpl_;