diff options
| author | Dan Goodliffe <dan@randomdan.homeip.net> | 2026-07-04 12:11:38 +0100 |
|---|---|---|
| committer | Dan Goodliffe <dan@randomdan.homeip.net> | 2026-07-04 19:36:30 +0100 |
| commit | 61e106fe6a15f76b73125682e91d5c17ee875be2 (patch) | |
| tree | 14727c98dff6b4d5097951c1ec4d238627e5c52e /src/ingestor.hpp | |
| parent | 409e41d1d97b180233be778a2d23ba0b4328b5c2 (diff) | |
| download | webstat-61e106fe6a15f76b73125682e91d5c17ee875be2.tar.bz2 webstat-61e106fe6a15f76b73125682e91d5c17ee875be2.tar.xz webstat-61e106fe6a15f76b73125682e91d5c17ee875be2.zip | |
Include extra details when storing unparsable and uninsertable lines.
Now includes the hostnameId, timestamp and optionally error message.
Updates idx_entities_retryinsert to account for details not being NULL.
Also fixes the issue where the entities inserted and rollback would
still be recorded in the entity cache if the access log insert failed.
This would have lead to PK violations later on.
Diffstat (limited to 'src/ingestor.hpp')
| -rw-r--r-- | src/ingestor.hpp | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/src/ingestor.hpp b/src/ingestor.hpp index ce4ac09..dacfdf7 100644 --- a/src/ingestor.hpp +++ b/src/ingestor.hpp @@ -117,6 +117,8 @@ namespace WebStat { void fillKnownEntities(std::span<Entity *>) const; void storeNewEntities(DB::Connection *, std::span<Entity *>) const; void storeNewEntity(DB::Connection *, Entity &) const; + EntityId storeUnparsableLine(DB::Connection *, std::string_view) const; + EntityId storeUninsertableLine(DB::Connection *, std::string_view, const std::exception &) const; void onNewUserAgent(const Entity &) const; auto withCurlLock(auto &&...); bool haveCurlOperations(); |