| 1354 | } |
| 1355 | |
| 1356 | bool parserAppendRecord( |
| 1357 | void* ctx, int64_t timestamp, const PJ_named_field_value_t* fields, uint64_t field_count, |
| 1358 | PJ_error_t* out_error) noexcept { |
| 1359 | return guardHostCallback(out_error, [&] { |
| 1360 | auto* impl = static_cast<DatastoreParserWriteHostState*>(ctx); |
| 1361 | auto core = impl->core.load(std::memory_order_acquire); |
| 1362 | if (!core->appendRecord(impl->topic, timestamp, fields, field_count)) { |
| 1363 | propagateError(out_error, core->lastError()); |
| 1364 | return false; |
| 1365 | } |
| 1366 | return true; |
| 1367 | }); |
| 1368 | } |
| 1369 | |
| 1370 | bool parserAppendBoundRecord( |
| 1371 | void* ctx, int64_t timestamp, const PJ_bound_field_value_t* fields, uint64_t field_count, |
nothing calls this directly
no test coverage detected