| 1462 | } |
| 1463 | |
| 1464 | bool toolboxAppendArrowStream( |
| 1465 | void* ctx, TopicHandle topic, struct ArrowArrayStream* stream, PJ_string_view_t timestamp_column, |
| 1466 | PJ_error_t* out_error) noexcept { |
| 1467 | return guardHostCallback(out_error, [&] { |
| 1468 | auto* impl = static_cast<DatastoreToolboxHostState*>(ctx); |
| 1469 | if (!impl->core.write.appendArrowStream(topic, stream, timestamp_column)) { |
| 1470 | propagateError(out_error, impl->core.write.lastError()); |
| 1471 | return false; |
| 1472 | } |
| 1473 | if (stream != nullptr && stream->release != nullptr) { |
| 1474 | stream->release(stream); |
| 1475 | } |
| 1476 | return true; |
| 1477 | }); |
| 1478 | } |
| 1479 | |
| 1480 | bool toolboxAcquireCatalogSnapshot(void* ctx, PJ_catalog_snapshot_t* out_snapshot, PJ_error_t* out_error) noexcept { |
| 1481 | return guardHostCallback(out_error, [&] { |
nothing calls this directly
no test coverage detected