You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Is your feature request related to a problem? Please describe.
Components should acknowledge that they have received the data from the upstream and take over the responsibility to move them forward without blocking the upstream
Describe the solution you'd like
The benefit of blocking is that in many cases an error can be propagated back upstream which can be reacted to. For example in a simple otlp->otlp forwarding pipeline, the result can ultimately be returned from the otlp receiver to the client trying to send the data. Then the client has the ability to react as they see appropriate. However, this only works for synchronous components, and to my knowledge we could do a better job declaring components as sync vs async (again maybe in consumer.Capabilities or metadata.yaml). This would make it easier to validate expectations. @djaglowski
Describe alternatives you've considered
No response
Additional context
No response
The text was updated successfully, but these errors were encountered:
My proposal is basically that we should add a sync vs async flag to consumer.Capabilities so that we can reason about and ultimately make observable the behavior of the downstream components.
Examples:
Ensure a collector is running synchronously end-to-end in order to guarantee that errors are back propagated from exporters to receivers.
Easily identify components which may be (1) added substantial latency to the data or (2) burying errors.
Component(s)
No response
Is your feature request related to a problem? Please describe.
Components should acknowledge that they have received the data from the upstream and take over the responsibility to move them forward without blocking the upstream
Describe the solution you'd like
Describe alternatives you've considered
No response
Additional context
No response
The text was updated successfully, but these errors were encountered: