Stashing parser

Stashing parser spojuje logy, které jsou rozloženy přes více řádků.

Deklarace

Stashing procesor shromažďuje logy se stejným identifier v seřazeném seznamu délky total_parts, počínaje 0 až total_parts - 1, přičemž indexová pozice je získána z current_part. Když jsou všechny logy shromážděny, je vytvořena jediná událost s shromážděnou částí content.

---
define:
  type: parsec/parser/stashing

stash:
  identifier: <PROCESS_ID>  # jaké pole se používá jako identifikátor
  total_parts: <TOTAL_LOG_PARTS>  # jaké pole se používá pro celkový počet očekávaných logů
  current_part: <LOG_PART>  # jaké pole se používá pro počítání aktuální části
  content: <MESSAGE>  # jaký obsah je uložen

  # volitelné
  max_age: 15m  # po této době je neúplná událost odeslána ostatním
  max_size: 50000  # když je číslo překročeno, neúplná událost je odeslána ostatním

Example

Vstupní logy:

-------timestamp-------   identifier    current_part/total_parts   -----content-----
2025-09-01T12:00:00.000   1024          0/3                        user: harry_potter,
2025-09-01T12:00:00.100   1024          1/3                        ip: 120.10.20.30,
2025-09-01T12:00:00.200   1024          2/3                        action: login

Výstup:

2025-09-01T12:00:00.000   1024 0/3  user: harry_potter, ip: 120.10.20.30, action: login