Files
zeekayandHanzo Dev c16ed9fe26 Go 1.27.1, and the code it can say more simply
Modules declare go 1.27.1 and the build images follow. go fix applied the
modernizers; omitzero is not applied, since it changes what the JSON says.

Co-authored-by: Hanzo Dev <[email protected]>
2026-09-17 02:34:35 -07:00
..

O11y Logs Pipeline Processor

An otel processor for powering Hanzo O11y logs pipelines.

The goal of this processor is to achieve a seamless logs pipelines experience for Hanzo O11y users while exposing the same interface as the logstransform processor in opentelemetry-collector-contrib

The implementation mostly borrows from, adapts and enhances the official logstransform processor (and stanza) code to achieve goals of Hanzo O11y pipelines

On success, query service should be able to add logs pipelines to otel collector config using this processor without having to do much translation or augmentation of the user defined config

The following non-exhaustive list of capabilities/improvements on top of what logstransform provides are included

  • sync ConsumeLogs i.e. ConsumeLogs should only return after the ConsumeLogs of the next processor in the pipeline has returned. This helps with reliability of logs processing through the collector. The otel-collector-contrib logstransform processor doesn't have a sync implementation for ConsumeLogs
  • Enhanced addressing capabilities.
    • should be able to refer to top level otlp log fields (like severity) in operator conditions
    • should be able to use body.field in operator config if body is JSON without having to first parse body into an temporary attribute