limitless solomon read actor draft (#15200)

Author: evanevanevanevannnn

ydb/core/base/events.h

@@ -184,6 +184,7 @@ struct TKikimrEvents : TEvents {
         ES_INCREMENTAL_RESTORE_SCAN = 4261,
         ES_FEATURE_FLAGS = 4262,
         ES_PRIORITY_QUEUE = 4263,
+        ES_SOLOMON_PROVIDER = 4264,
     };
 };
 

ydb/core/external_sources/external_source_factory.cpp

@@ -82,7 +82,7 @@ IExternalSourceFactory::TPtr CreateExternalSourceFactory(const std::vector<TStri
         },
         {
             ToString(NYql::EDatabaseType::Solomon),
-            CreateExternalDataSource(TString{NYql::SolomonProviderName}, {"NONE", "TOKEN"}, {}, hostnamePatternsRegEx)
+            CreateExternalDataSource(TString{NYql::SolomonProviderName}, {"NONE", "TOKEN"}, {"use_ssl", "grpc_port"}, hostnamePatternsRegEx)
         }
     }); 
 }

ydb/core/fq/libs/actors/run_actor.cpp

@@ -1980,7 +1980,7 @@ class TRunActor : public NActors::TActorBootstrapped<TRunActor> {
         {
             auto solomonConfig = gatewaysConfig.GetSolomon();
             auto solomonGateway = NYql::CreateSolomonGateway(solomonConfig);
-            dataProvidersInit.push_back(GetSolomonDataProviderInitializer(solomonGateway, false));
+            dataProvidersInit.push_back(GetSolomonDataProviderInitializer(solomonGateway, Params.CredentialsFactory, false));
         }
 
         SessionId = TStringBuilder()

ydb/core/fq/libs/init/init.cpp

@@ -45,7 +45,7 @@
 #include <ydb/library/yql/providers/pq/async_io/dq_pq_read_actor.h>
 #include <ydb/library/yql/providers/pq/async_io/dq_pq_write_actor.h>
 #include <ydb/library/yql/providers/pq/gateway/native/yql_pq_gateway.h>
-#include <ydb/library/yql/providers/solomon/async_io/dq_solomon_write_actor.h>
+#include <ydb/library/yql/providers/solomon/actors/dq_solomon_write_actor.h>
 #include <ydb/library/yql/providers/common/http_gateway/yql_http_default_retry_policy.h>
 
 

ydb/core/fq/libs/init/ya.make

@@ -52,7 +52,7 @@ PEERDIR(
     ydb/library/yql/providers/s3/actors
     ydb/library/yql/providers/s3/proto
     ydb/library/yql/providers/s3/provider
-    ydb/library/yql/providers/solomon/async_io
+    ydb/library/yql/providers/solomon/actors
     ydb/library/yql/providers/solomon/gateway
     ydb/library/yql/providers/solomon/proto
     ydb/library/yql/providers/solomon/provider

ydb/core/fq/libs/test_connection/test_monitoring.cpp

@@ -9,7 +9,7 @@
 #include <yql/essentials/providers/common/structured_token/yql_token_builder.h>
 #include <yql/essentials/utils/url_builder.h>
 
-#include <ydb/library/yql/providers/solomon/async_io/dq_solomon_write_actor.h>
+#include <ydb/library/yql/providers/solomon/actors/dq_solomon_write_actor.h>
 #include <ydb/library/yql/utils/actors/http_sender_actor.h>
 
 #include <ydb/library/actors/core/actor_bootstrapped.h>

ydb/core/fq/libs/test_connection/ya.make

@@ -18,7 +18,7 @@ PEERDIR(
     ydb/core/fq/libs/control_plane_storage
     ydb/core/fq/libs/test_connection/events
     ydb/library/yql/providers/pq/cm_client
-    ydb/library/yql/providers/solomon/async_io
+    ydb/library/yql/providers/solomon/actors
 )
 
 YQL_LAST_ABI_VERSION()

ydb/core/kqp/compute_actor/kqp_compute_actor.cpp

@@ -12,7 +12,7 @@
 #include <ydb/library/yql/providers/generic/actors/yql_generic_provider_factories.h>
 #include <ydb/library/formats/arrow/protos/ssa.pb.h>
 #include <ydb/library/yql/dq/proto/dq_tasks.pb.h>
-#include <ydb/library/yql/providers/solomon/async_io/dq_solomon_read_actor.h>
+#include <ydb/library/yql/providers/solomon/actors/dq_solomon_read_actor.h>
 
 
 namespace NKikimr {

ydb/core/kqp/compute_actor/ya.make

@@ -27,7 +27,7 @@ PEERDIR(
     ydb/library/yql/dq/actors/compute
     ydb/library/yql/providers/generic/actors
     ydb/library/yql/providers/s3/actors_factory
-    ydb/library/yql/providers/solomon/async_io
+    ydb/library/yql/providers/solomon/actors
     yql/essentials/public/issue
 )
 

ydb/core/kqp/gateway/behaviour/external_data_source/manager.cpp

@@ -85,7 +85,9 @@ TString GetOrEmpty(const NYql::TCreateObjectSettings& container, const TString&
         "use_tls",
         "schema", // managed PG, GP
         "service_name", // oracle
-        "folder_id" // logging
+        "folder_id", // logging
+        "use_ssl", // solomon
+        "grpc_port" // solomon
     };
 
     auto& featuresExtractor = settings.GetFeaturesExtractor();