Definition at line 41 of file federated_topic.hpp.
Public Member Functions | |
| std::vector< NYdb::NFederatedTopic::TReadSessionEvent::TEvent > | GetEvents (std::optional< std::size_t > max_events_count={}, size_t max_size_bytes=std::numeric_limits< size_t >::max()) |
| Get read session events. | |
| bool | Close (std::chrono::milliseconds timeout) |
| Close read session. | |
| NYdb::NFederatedTopic::IFederatedReadSession & | GetNativeTopicReadSession () |
| Get native read session. | |
| bool ydb::FederatedTopicReadSession::Close | ( | std::chrono::milliseconds | timeout | ) |
Close read session.
Waits for all commit acknowledgments to arrive. Force close after timeout
| std::vector< NYdb::NFederatedTopic::TReadSessionEvent::TEvent > ydb::FederatedTopicReadSession::GetEvents | ( | std::optional< std::size_t > | max_events_count = {}, |
| size_t | max_size_bytes = std::numeric_limits< size_t >::max() ) |
Get read session events.
Waits until event occurs
| max_events_count | maximum events count in batch |
| max_size_bytes | total size limit for data messages in batch if not specified, read session chooses event batch size automatically |
| NYdb::NFederatedTopic::IFederatedReadSession & ydb::FederatedTopicReadSession::GetNativeTopicReadSession | ( | ) |
Get native read session.
