feat core: add plugin service-mesh-proxy

Tests: testing
commit_hash:c5307c7e7e1d8d72a974458bcc955c2ccf5fe92e

Author: smorivan

core/include/userver/clients/http/component.hpp

@@ -69,7 +69,7 @@ class HttpClient final : public ComponentBase {
     static yaml_config::Schema GetStaticConfigSchema();
 
 private:
-    void OnConfigUpdate(const dynamic_config::Snapshot& config);
+    void OnConfigUpdate(const dynamic_config::Diff& diff);
 
     void WriteStatistics(utils::statistics::Writer& writer);
 

core/include/userver/clients/http/plugin.hpp

@@ -9,6 +9,7 @@
 #include <vector>
 
 #include <userver/utils/not_null.hpp>
+#include <userver/utils/zstring_view.hpp>
 
 USERVER_NAMESPACE_BEGIN
 
@@ -35,6 +36,10 @@ class PluginRequest final {
 
     void SetTimeout(std::chrono::milliseconds ms);
 
+    void SetProxy(utils::zstring_view value);
+
+    bool IsProxySet() const;
+
     const std::string& GetOriginalUrl() const;
 
 private:

core/include/userver/dynamic_config/storage/component.hpp

@@ -110,6 +110,8 @@ class DynamicConfig::NoblockSubscriber final {
 
     concurrent::AsyncEventSource<const dynamic_config::Snapshot&>& GetEventSource() noexcept;
 
+    concurrent::AsyncEventSource<const dynamic_config::Diff&>& GetDiffSource() noexcept;
+
 private:
     DynamicConfig& config_component_;
 };

core/src/clients/http/component.cpp

@@ -96,7 +96,7 @@ HttpClient::HttpClient(const ComponentConfig& component_config, const ComponentC
     http_client_.SetConfig(bootstrap_config);
 
     auto& config_component = context.FindComponent<components::DynamicConfig>();
-    subscriber_scope_ = components::DynamicConfig::NoblockSubscriber{config_component}.GetEventSource().AddListener(
+    subscriber_scope_ = components::DynamicConfig::NoblockSubscriber{config_component}.GetDiffSource().AddListener(
         this, kName, &HttpClient::OnConfigUpdate
     );
 
@@ -126,7 +126,19 @@ HttpClient::~HttpClient() {
 
 clients::http::Client& HttpClient::GetHttpClient() { return http_client_; }
 
-void HttpClient::OnConfigUpdate(const dynamic_config::Snapshot& config) {
+void HttpClient::OnConfigUpdate(const dynamic_config::Diff& diff) {
+    const auto& config = diff.current;
+    const auto& prev_config_opt = diff.previous;
+    if (prev_config_opt) {
+        const auto& prev_config = *prev_config_opt;
+        if (config[::dynamic_config::HTTP_CLIENT_CONNECTION_POOL_SIZE] ==
+                prev_config[::dynamic_config::HTTP_CLIENT_CONNECTION_POOL_SIZE] &&
+            config[::dynamic_config::USERVER_HTTP_PROXY] == prev_config[::dynamic_config::USERVER_HTTP_PROXY] &&
+            config[::dynamic_config::HTTP_CLIENT_CONNECT_THROTTLE] ==
+                prev_config[::dynamic_config::HTTP_CLIENT_CONNECT_THROTTLE]) {
+            return;
+        }
+    }
     http_client_.SetConfig(clients::http::impl::Config{
         config[::dynamic_config::HTTP_CLIENT_CONNECTION_POOL_SIZE],
         config[::dynamic_config::USERVER_HTTP_PROXY],

core/src/clients/http/plugin.cpp

@@ -32,6 +32,10 @@ void PluginRequest::SetTimeout(std::chrono::milliseconds ms) {
     state_.SetEasyTimeout(ms);
 }
 
+void PluginRequest::SetProxy(utils::zstring_view value) { state_.proxy(value); }
+
+bool PluginRequest::IsProxySet() const { return state_.IsProxySet(); }
+
 const std::string& PluginRequest::GetOriginalUrl() const { return state_.easy().get_original_url(); }
 
 Plugin::Plugin(std::string name) : name_(std::move(name)) {}

core/src/clients/http/request_state.cpp

@@ -358,6 +358,8 @@ void RequestState::proxy(utils::zstring_view value) {
     easy().set_proxy(value);
 }
 
+bool RequestState::IsProxySet() const { return proxy_url_.has_value(); }
+
 void RequestState::proxy_auth_type(curl::easy::proxyauth_t value) { easy().set_proxy_auth(value); }
 
 void RequestState::http_auth_type(
@@ -1024,7 +1026,10 @@ void RequestState::WithRequestStats(const Func& func) {
 void RequestState::ResolveTargetAddress(clients::dns::Resolver& resolver) {
     const auto deadline = engine::Deadline::FromDuration(remote_timeout_);
 
-    const MaybeOwnedUrl target{proxy_url_, easy()};
+    const static std::string kEmptyString;
+    const std::string& proxy_url = proxy_url_ ? *proxy_url_ : kEmptyString;
+    const MaybeOwnedUrl target{proxy_url, easy()};
+
     const std::string hostname = target.Get().GetHostPtr().get();
 
     // CURLOPT_RESOLV hostnames cannot contain colons (as IPv6 addresses do), skip

core/src/clients/http/request_state.hpp

@@ -140,6 +140,8 @@ class RequestState : public std::enable_shared_from_this<RequestState> {
 
     void SetTracingManager(const tracing::TracingManagerBase&);
 
+    bool IsProxySet() const;
+
     PluginRequest GetEditableRequestInstance();
 
 private:
@@ -237,7 +239,7 @@ class RequestState : public std::enable_shared_from_this<RequestState> {
     std::array<char, CURL_ERROR_SIZE> errorbuffer_{};
 
     clients::dns::Resolver* resolver_{nullptr};
-    std::string proxy_url_;
+    std::optional<std::string> proxy_url_;
     impl::PluginPipeline plugin_pipeline_;
 
     struct StreamData {

core/src/dynamic_config/storage/component.cpp

@@ -59,6 +59,8 @@ class DynamicConfig::Impl final {
     dynamic_config::Source GetSource();
     auto& GetChannel() { return cache_.GetChannel(); }
 
+    auto& GetDiffChannel() { return cache_.GetDiffChannel(); }
+
     const dynamic_config::DocsMap& GetDefaultDocsMap() const;
     bool AreUpdatesEnabled() const;
 
@@ -321,6 +323,10 @@ concurrent::AsyncEventSource<const dynamic_config::Snapshot&>& DynamicConfig::No
     return config_component_.impl_->GetChannel();
 }
 
+concurrent::AsyncEventSource<const dynamic_config::Diff&>& DynamicConfig::NoblockSubscriber::GetDiffSource() noexcept {
+    return config_component_.impl_->GetDiffChannel();
+}
+
 DynamicConfig::DynamicConfig(const ComponentConfig& config, const ComponentContext& context)
     : DynamicConfigUpdatesSinkBase(config, context), impl_(std::make_unique<Impl>(config, context)) {
     if (!impl_->AreUpdatesEnabled()) {

core/src/dynamic_config/storage_data.cpp

@@ -50,6 +50,8 @@ void StorageData::Update(SnapshotData config, AfterAssignHook after_assign_hook)
 
 StorageData::SnapshotChannel& StorageData::GetChannel() { return snapshot_channel_; }
 
+StorageData::DiffChannel& StorageData::GetDiffChannel() { return diff_channel_; }
+
 concurrent::AsyncEventSubscriberScope
 StorageData::DoUpdateAndListen(concurrent::FunctionId id, std::string_view name, SnapshotChannel::Function&& func) {
     auto updater = [&, func_copy = func] { func_copy(GetSnapshot()); };

core/src/dynamic_config/storage_data.hpp

@@ -26,6 +26,8 @@ class StorageData final {
 
     SnapshotChannel& GetChannel();
 
+    DiffChannel& GetDiffChannel();
+
     concurrent::AsyncEventSubscriberScope
     DoUpdateAndListen(concurrent::FunctionId id, std::string_view name, SnapshotChannel::Function&& func);