| 1368 | } |
| 1369 | |
| 1370 | bool parserAppendBoundRecord( |
| 1371 | void* ctx, int64_t timestamp, const PJ_bound_field_value_t* fields, uint64_t field_count, |
| 1372 | PJ_error_t* out_error) noexcept { |
| 1373 | return guardHostCallback(out_error, [&] { |
| 1374 | auto* impl = static_cast<DatastoreParserWriteHostState*>(ctx); |
| 1375 | auto core = impl->core.load(std::memory_order_acquire); |
| 1376 | if (!core->appendBoundRecord(impl->topic, timestamp, fields, field_count)) { |
| 1377 | propagateError(out_error, core->lastError()); |
| 1378 | return false; |
| 1379 | } |
| 1380 | return true; |
| 1381 | }); |
| 1382 | } |
| 1383 | |
| 1384 | bool parserAppendArrowStream( |
| 1385 | void* ctx, struct ArrowArrayStream* stream, PJ_string_view_t timestamp_column, PJ_error_t* out_error) noexcept { |
nothing calls this directly
no test coverage detected