Function sourceAppendRecord

pj_datastore/src/plugin_data_host.cpp:1295–1307

}

bool sourceAppendRecord(
    void* ctx, TopicHandle topic, int64_t timestamp, const PJ_named_field_value_t* fields, uint64_t field_count,
    PJ_error_t* out_error) noexcept {
  return guardHostCallback(out_error, [&] {
    auto* impl = static_cast<DatastoreSourceWriteHostState*>(ctx);
    auto core = impl->core.load(std::memory_order_acquire);
    if (!core->appendRecord(topic, timestamp, fields, field_count)) {
      propagateError(out_error, core->lastError());
      return false;
    }
    return true;
  });
}

bool sourceAppendBoundRecord(
    void* ctx, TopicHandle topic, int64_t timestamp, const PJ_bound_field_value_t* fields, uint64_t field_count,