* add types to public API

* check consumer arg type

Author: rekby

ydb/_topic_reader/topic_reader.py

@@ -38,6 +38,10 @@ class PublicReaderSettings:
     decoder_executor: Optional[concurrent.futures.Executor] = None
     update_token_interval: Union[int, float] = 3600
 
+    def __post_init__(self):
+        if not isinstance(self.consumer, str):
+            raise TypeError("Unsupported type for consumer: '%s'" % type(self.consumer))
+
     def _init_message(self) -> StreamReadMessage.InitRequest:
         return StreamReadMessage.InitRequest(
             topics_read_settings=[

ydb/topic.py

@@ -13,8 +13,10 @@
     "TopicReaderAsyncIO",
     "TopicReaderSettings",
     "TopicStatWindow",
+    "TopicWriteResult",
     "TopicWriter",
     "TopicWriterAsyncIO",
+    "TopicWriterInitInfo",
     "TopicWriterMessage",
     "TopicWriterSettings",
 ]
@@ -42,6 +44,8 @@
     PublicWriterSettings as TopicWriterSettings,
     PublicMessage as TopicWriterMessage,
     RetryPolicy as TopicWriterRetryPolicy,
+    PublicWriterInitInfo as TopicWriterInitInfo,
+    PublicWriteResult as TopicWriteResult,
 )
 
 from ydb._topic_writer.topic_writer_asyncio import WriterAsyncIO as TopicWriterAsyncIO