-
Notifications
You must be signed in to change notification settings - Fork 613
Addressing tracing issues in FanoutMessageHandler & MessageReceiver #2862
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Addressing tracing issues in FanoutMessageHandler & MessageReceiver #2862
Conversation
/retest pull-knative-eventing-unit-tests |
/hold |
/test pull-knative-eventing-unit-tests |
3 similar comments
/test pull-knative-eventing-unit-tests |
/test pull-knative-eventing-unit-tests |
/test pull-knative-eventing-unit-tests |
@@ -164,5 +164,8 @@ func (f *MessageHandler) makeFanoutRequest(ctx context.Context, message binding. | |||
if sub.DeadLetterSinkURI != nil { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Does this part makes sense? I'm not sure I understood how to use the duck type Destination
and I don't get if the Subscribable
should contain the DeadLetterSinkURI
in sub.Delivery.DeadLetterSink
, sub.DeadLetterSinkURI
or both
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
#2876 should address it
pkg/tracing/traceparent.go
Outdated
|
||
// ParseSpanFromTraceparentAttribute works the same as AddSpanFromTraceparentAttribute, but takes | ||
// the extension value as function parameter | ||
func ParseSpanFromTraceparentAttribute(ctx context.Context, name string, tp string) (context.Context, error) { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I need this method to extract the traceparent directly from the kafka message in KafkaChannel
/assign @n3wscott |
723b06d
to
703a4a4
Compare
/unhold |
/hold Waiting for #2876 |
Signed-off-by: Francesco Guardiani <francescoguard@gmail.com>
Signed-off-by: Francesco Guardiani <francescoguard@gmail.com>
…orking Signed-off-by: Francesco Guardiani <francescoguard@gmail.com>
Signed-off-by: Francesco Guardiani <francescoguard@gmail.com>
Signed-off-by: Francesco Guardiani <francescoguard@gmail.com>
428557b
to
3d32eb7
Compare
/assign @ian-mi |
The following is the coverage report on the affected files.
|
/hold Let me give a shot to the transformer that populates the span |
/lgtm |
/unhold |
[APPROVALNOTIFIER] This PR is APPROVED This pull-request has been approved by: n3wscott, slinkydeveloper The full list of commands accepted by this bot can be found here. The pull request process is described here
Needs approval from an approver in each of these files:
Approvers can indicate their approval by writing |
Also enabled logging on
FanoutMessageHandler
, in order to detect future flakyness on that testSigned-off-by: Francesco Guardiani francescoguard@gmail.com