| 1449 | } |
| 1450 | |
| 1451 | bool toolboxAppendBoundRecord( |
| 1452 | void* ctx, TopicHandle topic, int64_t timestamp, const PJ_bound_field_value_t* fields, uint64_t field_count, |
| 1453 | PJ_error_t* out_error) noexcept { |
| 1454 | return guardHostCallback(out_error, [&] { |
| 1455 | auto* impl = static_cast<DatastoreToolboxHostState*>(ctx); |
| 1456 | if (!impl->core.write.appendBoundRecord(topic, timestamp, fields, field_count)) { |
| 1457 | propagateError(out_error, impl->core.write.lastError()); |
| 1458 | return false; |
| 1459 | } |
| 1460 | return true; |
| 1461 | }); |
| 1462 | } |
| 1463 | |
| 1464 | bool toolboxAppendArrowStream( |
| 1465 | void* ctx, TopicHandle topic, struct ArrowArrayStream* stream, PJ_string_view_t timestamp_column, |
nothing calls this directly
no test coverage detected