Moved "separate include targets" commit from ydb repo

Author: ildar-khisambeev

examples/topic_reader/eventloop/main.cpp

@@ -1,4 +1,4 @@
-#include <ydb-cpp-sdk/client/topic/topic.h>
+#include <ydb-cpp-sdk/client/topic/client.h>
 
 #include <src/library/getopt/last_getopt.h>
 

examples/topic_reader/simple/main.cpp

@@ -1,4 +1,4 @@
-#include <ydb-cpp-sdk/client/topic/topic.h>
+#include <ydb-cpp-sdk/client/topic/client.h>
 
 #include <src/library/getopt/last_getopt.h>
 

examples/topic_reader/transaction/application.h

@@ -3,7 +3,7 @@
 #include "options.h"
 
 #include <ydb-cpp-sdk/client/driver/driver.h>
-#include <ydb-cpp-sdk/client/topic/topic.h>
+#include <ydb-cpp-sdk/client/topic/client.h>
 #include <ydb-cpp-sdk/client/table/table.h>
 
 #include <memory>

include/ydb-cpp-sdk/client/federated_topic/federated_topic.h

@@ -1,6 +1,6 @@
 #pragma once
 
-#include <ydb-cpp-sdk/client/topic/topic.h>
+#include <ydb-cpp-sdk/client/topic/client.h>
 
 #include <src/api/protos/ydb_federation_discovery.pb.h>
 

include/ydb-cpp-sdk/client/proto/accessor.h

@@ -13,7 +13,7 @@
 #include <ydb-cpp-sdk/client/import/import.h>
 #include <ydb-cpp-sdk/client/monitoring/monitoring.h>
 #include <ydb-cpp-sdk/client/table/table.h>
-#include <ydb-cpp-sdk/client/topic/topic.h>
+#include <ydb-cpp-sdk/client/topic/client.h>
 
 namespace NYdb {
 

include/ydb-cpp-sdk/client/topic/client.h

@@ -0,0 +1,64 @@
+#pragma once
+
+#include "control_plane.h"
+#include "read_session.h"
+#include "write_session.h"
+
+namespace NYdb::NTopic {
+
+struct TTopicClientSettings : public TCommonClientSettingsBase<TTopicClientSettings> {
+    using TSelf = TTopicClientSettings;
+
+    //! Default executor for compression tasks.
+    FLUENT_SETTING_DEFAULT(IExecutor::TPtr, DefaultCompressionExecutor, CreateThreadPoolExecutor(2));
+
+    //! Default executor for callbacks.
+    FLUENT_SETTING_DEFAULT(IExecutor::TPtr, DefaultHandlersExecutor, CreateThreadPoolExecutor(1));
+};
+
+// Topic client.
+class TTopicClient {
+public:
+    class TImpl;
+
+    TTopicClient(const TDriver& driver, const TTopicClientSettings& settings = TTopicClientSettings());
+
+    void ProvideCodec(ECodec codecId, THolder<ICodec>&& codecImpl);
+
+    // Create a new topic.
+    TAsyncStatus CreateTopic(const std::string& path, const TCreateTopicSettings& settings = {});
+
+    // Update a topic.
+    TAsyncStatus AlterTopic(const std::string& path, const TAlterTopicSettings& settings = {});
+
+    // Delete a topic.
+    TAsyncStatus DropTopic(const std::string& path, const TDropTopicSettings& settings = {});
+
+    // Describe a topic.
+    TAsyncDescribeTopicResult DescribeTopic(const std::string& path, const TDescribeTopicSettings& settings = {});
+
+    // Describe a topic consumer.
+    TAsyncDescribeConsumerResult DescribeConsumer(const std::string& path, const std::string& consumer, const TDescribeConsumerSettings& settings = {});
+
+    // Describe a topic partition
+    TAsyncDescribePartitionResult DescribePartition(const std::string& path, i64 partitionId, const TDescribePartitionSettings& settings = {});
+
+    //! Create read session.
+    std::shared_ptr<IReadSession> CreateReadSession(const TReadSessionSettings& settings);
+
+    //! Create write session.
+    std::shared_ptr<ISimpleBlockingWriteSession> CreateSimpleBlockingWriteSession(const TWriteSessionSettings& settings);
+    std::shared_ptr<IWriteSession> CreateWriteSession(const TWriteSessionSettings& settings);
+
+    // Commit offset
+    TAsyncStatus CommitOffset(const std::string& path, ui64 partitionId, const std::string& consumerName, ui64 offset,
+        const TCommitOffsetSettings& settings = {});
+
+protected:
+    void OverrideCodec(ECodec codecId, THolder<ICodec>&& codecImpl);
+
+private:
+    std::shared_ptr<TImpl> Impl_;
+};
+
+} // namespace NYdb::NTopic

include/ydb-cpp-sdk/client/topic/codecs/codecs.h renamed to include/ydb-cpp-sdk/client/topic/codecs.h

@@ -21,6 +21,17 @@ enum class ECodec : ui32 {
     CUSTOM = 10000,
 };
 
+inline const std::string& GetCodecId(const ECodec codec) {
+    static std::unordered_map<ECodec, std::string> idByCodec{
+        {ECodec::RAW, std::string(1, '\0')},
+        {ECodec::GZIP, "\1"},
+        {ECodec::LZOP, "\2"},
+        {ECodec::ZSTD, "\3"}
+    };
+    Y_ABORT_UNLESS(idByCodec.contains(codec));
+    return idByCodec[codec];
+}
+
 class ICodec {
 public:
     virtual ~ICodec() = default;
@@ -122,6 +133,4 @@ class TCodecMap {
     TAdaptiveLock Lock;
 };
 
-#define CODEC_MAP_ALREADY_PROVIDED
-
 } // namespace NYdb::NTopic