| 133 | } |
| 134 | |
| 135 | const TypeTreeNode* DataReader::getTypeTree(TopicId topic_id) const { |
| 136 | auto lock = engine_.lockEngine(); |
| 137 | const TopicStorage* storage = engine_.getTopicStorage(topic_id); |
| 138 | if (storage == nullptr) { |
| 139 | return nullptr; |
| 140 | } |
| 141 | SchemaId schema_id = storage->descriptor().schema_id; |
| 142 | return engine_.typeRegistry().lookup(schema_id); |
| 143 | } |
| 144 | |
| 145 | std::optional<TopicMetadata> DataReader::getMetadata(TopicId topic_id) const { |
| 146 | auto lock = engine_.lockEngine(); |