| 1436 | } |
| 1437 | |
| 1438 | bool toolboxAppendRecord( |
| 1439 | void* ctx, TopicHandle topic, int64_t timestamp, const PJ_named_field_value_t* fields, uint64_t field_count, |
| 1440 | PJ_error_t* out_error) noexcept { |
| 1441 | return guardHostCallback(out_error, [&] { |
| 1442 | auto* impl = static_cast<DatastoreToolboxHostState*>(ctx); |
| 1443 | if (!impl->core.write.appendRecord(topic, timestamp, fields, field_count)) { |
| 1444 | propagateError(out_error, impl->core.write.lastError()); |
| 1445 | return false; |
| 1446 | } |
| 1447 | return true; |
| 1448 | }); |
| 1449 | } |
| 1450 | |
| 1451 | bool toolboxAppendBoundRecord( |
| 1452 | void* ctx, TopicHandle topic, int64_t timestamp, const PJ_bound_field_value_t* fields, uint64_t field_count, |
nothing calls this directly
no test coverage detected