Repository navigation

output: engine: output_throttle: Implement throttle operations for output plugins - #12393

Open

cosmo0920 wants to merge 49 commits into

masterfrom

cosmo0920-implement-output-throttle-operations

Open

output: engine: output_throttle: Implement throttle operations for output plugins#12393
cosmo0920 wants to merge 49 commits into
masterfrom
cosmo0920-implement-output-throttle-operations

Commits on Oct 23, 2026
- utils: add strict time conversion helper
  cosmo0920
  committed
  e52d111
- tests: internal: cover strict time conversion
  cosmo0920
  committed
  f073610
- output_throttle: add portable output cooldown gate
  cosmo0920
  committed
  eeead3b
- task: track deferred route ownership
  cosmo0920
  committed
  372af5a
- output: manage throttled dispatch and queue ownership
  cosmo0920
  committed
  a791275
- output_thread: recover deferred dispatch results safely
  cosmo0920
  committed
  4909c62
- engine_dispatch: defer throttled routes and resolve failures
  cosmo0920
  committed
  cc45546
- engine: resume throttled work without spending retry attempts
  cosmo0920
  committed
  d4f44a5
- tests: internal: cover dispatch failure ownership on all platforms
  cosmo0920
  committed
  c931fe3
- tests: internal: cover output cooldown and dispatch recovery
  cosmo0920
  committed
  b554ef8
- tests: internal: cover worker shutdown signaling failures
  cosmo0920
  committed
  8d116ea
- tests: runtime: cover throttle retries and route serialization
  cosmo0920
  committed
  ebf7bea
- benchmarks: measure output throttle gate overhead
  cosmo0920
  committed
  b9b2643
- http_retry_after: parse response delay hints safely
  cosmo0920
  committed
  03b92b4
- tests: internal: cover retry delay parsing and malformed headers
  cosmo0920
  committed
  6346a92
- tests: internal: fuzz HTTP retry delay parsing
  cosmo0920
  committed
  73b7541
- out_http: classify throttled responses and honor retry delays
  cosmo0920
  committed
  4fb6ebf
- tests: integration: cover HTTP throttle timing and body requests
  cosmo0920
  committed
  c0e9c46
- search_bulk: expose item throttle evidence
  cosmo0920
  committed
  9d0d7eb
- out_es: adapt to bulk throttle evidence interface
  cosmo0920
  committed
  1705fe2
- out_opensearch: adapt to bulk throttle evidence interface
  cosmo0920
  committed
  3dbffbb
- tests: internal: adapt bulk response calls to throttle evidence
  cosmo0920
  committed
  3b268fc
- tests: internal: cover search bulk throttle evidence
  cosmo0920
  committed
  ab1ad1f
- out_es: honor bulk throttle responses and retry delay hints
  cosmo0920
  committed
  142dfcf
- out_es: document throttle response audit
  cosmo0920
  committed
  f832393
- out_opensearch: honor bulk throttle responses and retry delay hints
  cosmo0920
  committed
  024c6ca
- out_opensearch: document throttle response audit
  cosmo0920
  committed
  6cd2f33
- tests: integration: cover search bulk throttle headers and trailers
  cosmo0920
  committed
  4963b1b
- out_opentelemetry: honor HTTP and gRPC throttle signals
  cosmo0920
  committed
  3dedc03
- out_opentelemetry: document throttle response audit
  cosmo0920
  committed
  4e82fec
- tests: integration: cover OTLP retry hints and unpadded metadata
  cosmo0920
  committed
  518d394
- tests: integration: expose Valgrind failure contexts
  cosmo0920
  committed
  9d8e224
- output_thread: retain dispatch ownership across wake failures
  cosmo0920
  committed
  89c45cb
- tests: internal: cover queued worker dispatch recovery
  cosmo0920
  committed
  0713122
- tests: integration: verify successive body-key throttle cooldowns
  cosmo0920
  committed
  9fba0d9
- engine: schedule deferred routes after serialized output completion
  cosmo0920
  committed
  fce9421
- output: wait for completion before resuming deferred routes
  cosmo0920
  committed
  998545e
- task: avoid accessing destroyed outputs during cleanup
  cosmo0920
  committed
  6d34392
- tests: internal: cover task cleanup after output destruction
  cosmo0920
  committed
  0b6fa88
- tests: runtime: bound throttle tests and stop engines gracefully
  cosmo0920
  committed
  3a0ec21
- tests: integration: reserve distinct service monitoring ports
  cosmo0920
  committed
  9526852
- out_opentelemetry: preserve split metric throttling
  cosmo0920
  committed
  80f319c
- tests: integration: cover split metric throttling and shutdown
  cosmo0920
  committed
  944fb9e
- tests: runtime: wait for dummy records before stopping
  cosmo0920
  committed
  427a2cd
- tests: runtime: stop stackdriver gracefully on macos
  cosmo0920
  committed
  548cd93
- tests: internal: bound input chunk shutdown on macos
  cosmo0920
  committed
  28a5522
- workflows: bound macos tests and retain failure logs
  cosmo0920
  committed
  f28d7c7
- lib: finish cooperative shutdown on macos
  cosmo0920
  committed
  b92c38a
- tests: runtime: verify stop waits for engine cleanup
  cosmo0920
  committed
  7da99e8

Commits

Commits on Oct 23, 2026