You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@thrift.apache.org by Akshya Gupta <ag...@snaproute.com> on 2017/10/27 00:39:06 UTC
Integrating apache thrift with opentracing for golang
Hello,
I was trying to integrate the tracing capabilities of opentracing into the thrift RPC for golang.
But I am not sure which files I would need to modify. My thoughts were to create a new TProtocol (like TCompactProtocol) which would accept the tracer and the span context created by the opentracing and then whenever an rpc message is sent or received, a span trace would be sent to the tracer.
I saw that there is a java-thrift implementation https://github.com/opentracing-contrib/java-thrift <https://github.com/opentracing-contrib/java-thrift>
But the implementation for golang would be a bit different I guess, hence the question
Thanks
Aks.
--
This message and its attachments are intended only for the addressee and
may contain legally privileged and/or confidential information. If you are
not the intended recipient, you are hereby notified that you must not use,
disseminate, or copy this material in any form, or take any action based
upon it. If you have received this message by error, please immediately
delete it and its attachments and notify the sender at SnapRoute, Inc. by
electronic mail message reply. Thank you.
Re: Integrating apache thrift with opentracing for golang
Posted by Daniel Wu <qi...@dianrong.com>.
Actually you can just add a protocol add an extra header just like Finagle. You don’t change anything to thrift and you can communicate between raw binary protocol and your own protocol.
On 27/10/2017, 8:39 AM, "Akshya Gupta" <ag...@snaproute.com> wrote:
Hello,
I was trying to integrate the tracing capabilities of opentracing into the thrift RPC for golang.
But I am not sure which files I would need to modify. My thoughts were to create a new TProtocol (like TCompactProtocol) which would accept the tracer and the span context created by the opentracing and then whenever an rpc message is sent or received, a span trace would be sent to the tracer.
I saw that there is a java-thrift implementation https://github.com/opentracing-contrib/java-thrift <https://github.com/opentracing-contrib/java-thrift>
But the implementation for golang would be a bit different I guess, hence the question
Thanks
Aks.
--
This message and its attachments are intended only for the addressee and
may contain legally privileged and/or confidential information. If you are
not the intended recipient, you are hereby notified that you must not use,
disseminate, or copy this material in any form, or take any action based
upon it. If you have received this message by error, please immediately
delete it and its attachments and notify the sender at SnapRoute, Inc. by
electronic mail message reply. Thank you.
Re: Integrating apache thrift with opentracing for golang
Posted by Daniel Wu <qi...@dianrong.com>.
You can extends TBinaryProtocol, create your own protocol class, then replace the protocol when you start your server, that’s pretty simple.
To create your own protocol:
public class TTracingBinaryProtocol extends TBinaryProtocol {
public TTracingBinaryProtocol(TTransport trans, long stringLengthLimit, long containerLengthLimit,
boolean strictRead, boolean strictWrite) {
super(trans, stringLengthLimit, containerLengthLimit, strictRead, strictWrite);
}
@Override
public TMessage readMessageBegin() throws TException {
int size = readI32();
// handle the header here, if it is Tracing Protocl, read the trace id and other info, then call the super method.
}
public static class Factory extends TBinaryProtocol.Factory {
public TProtocol getProtocol(TTransport trans) {
return new TTracingBinaryProtocol(trans, stringLengthLimit_, containerLengthLimit_, strictRead_, strictWrite_);
}
}
}
To use your own protocol:
TThreadedSelectorServer server = new TThreadedSelectorServer(
new TThreadedSelectorServer.Args(randomPort.transport).processor(processor).
protocolFactory(new TTracingBinaryProtocol.Factory()).selectorThreads(2).workerThreads(48));
server.serve();
On 27/10/2017, 9:36 AM, "Akshya Gupta" <ag...@snaproute.com> wrote:
Thanks so much. That's what I figured. Maybe I need to put a change in
processor also to pass on the attached context. I think with newer version
of thrift, passing a context is anyways necessary. But we are using 0.9.3
Let me give it a shot
On Oct 26, 2017 6:34 PM, "Daniel Wu" <qi...@dianrong.com> wrote:
> Actually you can just add a protocol add an extra header just like
> Finagle. You don’t change anything to thrift and you can communicate
> between raw binary protocol and your own protocol.
>
> On 27/10/2017, 8:39 AM, "Akshya Gupta" <ag...@snaproute.com> wrote:
>
> Hello,
>
> I was trying to integrate the tracing capabilities of opentracing into
> the thrift RPC for golang.
>
> But I am not sure which files I would need to modify. My thoughts were
> to create a new TProtocol (like TCompactProtocol) which would accept the
> tracer and the span context created by the opentracing and then whenever an
> rpc message is sent or received, a span trace would be sent to the tracer.
>
> I saw that there is a java-thrift implementation https://github.com/
> opentracing-contrib/java-thrift <https://github.com/
> opentracing-contrib/java-thrift>
> But the implementation for golang would be a bit different I guess,
> hence the question
>
> Thanks
> Aks.
> --
>
> This message and its attachments are intended only for the addressee
> and
> may contain legally privileged and/or confidential information. If you
> are
> not the intended recipient, you are hereby notified that you must not
> use,
> disseminate, or copy this material in any form, or take any action
> based
> upon it. If you have received this message by error, please immediately
> delete it and its attachments and notify the sender at SnapRoute, Inc.
> by
> electronic mail message reply. Thank you.
>
>
>
>
>
>
--
This message and its attachments are intended only for the addressee and
may contain legally privileged and/or confidential information. If you are
not the intended recipient, you are hereby notified that you must not use,
disseminate, or copy this material in any form, or take any action based
upon it. If you have received this message by error, please immediately
delete it and its attachments and notify the sender at SnapRoute, Inc. by
electronic mail message reply. Thank you.
Re: Integrating apache thrift with opentracing for golang
Posted by Akshya Gupta <ag...@snaproute.com>.
Thanks so much. That's what I figured. Maybe I need to put a change in
processor also to pass on the attached context. I think with newer version
of thrift, passing a context is anyways necessary. But we are using 0.9.3
Let me give it a shot
On Oct 26, 2017 6:34 PM, "Daniel Wu" <qi...@dianrong.com> wrote:
> Actually you can just add a protocol add an extra header just like
> Finagle. You don’t change anything to thrift and you can communicate
> between raw binary protocol and your own protocol.
>
> On 27/10/2017, 8:39 AM, "Akshya Gupta" <ag...@snaproute.com> wrote:
>
> Hello,
>
> I was trying to integrate the tracing capabilities of opentracing into
> the thrift RPC for golang.
>
> But I am not sure which files I would need to modify. My thoughts were
> to create a new TProtocol (like TCompactProtocol) which would accept the
> tracer and the span context created by the opentracing and then whenever an
> rpc message is sent or received, a span trace would be sent to the tracer.
>
> I saw that there is a java-thrift implementation https://github.com/
> opentracing-contrib/java-thrift <https://github.com/
> opentracing-contrib/java-thrift>
> But the implementation for golang would be a bit different I guess,
> hence the question
>
> Thanks
> Aks.
> --
>
> This message and its attachments are intended only for the addressee
> and
> may contain legally privileged and/or confidential information. If you
> are
> not the intended recipient, you are hereby notified that you must not
> use,
> disseminate, or copy this material in any form, or take any action
> based
> upon it. If you have received this message by error, please immediately
> delete it and its attachments and notify the sender at SnapRoute, Inc.
> by
> electronic mail message reply. Thank you.
>
>
>
>
>
>
--
This message and its attachments are intended only for the addressee and
may contain legally privileged and/or confidential information. If you are
not the intended recipient, you are hereby notified that you must not use,
disseminate, or copy this material in any form, or take any action based
upon it. If you have received this message by error, please immediately
delete it and its attachments and notify the sender at SnapRoute, Inc. by
electronic mail message reply. Thank you.