feat(logs): wire stateful encoding into log agent pipeline#49220
Draft
DDuongNguyen wants to merge 1 commit into04-10-feat_logs_add_pattern_extraction_to_grpc_stateful_senderfrom
Conversation
This was referenced Apr 10, 2026
Contributor
Author
381377c to
aaabc7d
Compare
0c750f0 to
3a5d6f0
Compare
aaabc7d to
f397434
Compare
3a5d6f0 to
6eb9d20
Compare
6eb9d20 to
899a7e2
Compare
f397434 to
095d10d
Compare
This was referenced Apr 15, 2026
This was referenced Apr 25, 2026
Draft
Draft
Draft
This was referenced Apr 29, 2026
Draft
Draft
Draft
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.

What does this PR do?
Wires the stateful encoding feature into the log agent's pipeline and status reporting:
pkg/logs/pipeline/):pipeline.goandprovider.goupdated to instantiate the gRPC sender with pattern encoding whenuse_grpcis enabledcomp/logs/agent/agentimpl/):agent.goandagent_test.goupdated for the new sender construction pathpkg/logs/status/, status templates): Adds stateful encoding state (active patterns, cluster count, cache stats) toagent statusoutputpkg/logs/message/message.go): Extends theMessagestruct to carry pattern metadata through the pipelineMotivation
All the building blocks (tokens, tokenizer, eviction, clustering, sender) are in place — this PR connects them to the actual log agent lifecycle so the feature activates when configured.
Describe how you validated your changes
use_grpc: trueconfigurationHow to Review this PR
pkg/logs/pipeline/provider.go— the main wiring point where the gRPC sender is selectedcomp/logs/agent/agentimpl/agent.go— agent lifecycle changespkg/logs/status/builder.go— new status fieldsAdditional Notes
This is the thinnest PR in the stack by design — it only wires existing components together. If any upstream PR needs changes, this one will likely need a trivial rebase.