Skip to content

Commit f67e269

Browse files
committed
added GetOpenTelemetryTraceParent() to IRequestCtxBaseMtSafe
1 parent 377bc60 commit f67e269

File tree

3 files changed

+17
-0
lines changed

3 files changed

+17
-0
lines changed

ydb/core/grpc_services/base/base.h

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -598,6 +598,10 @@ class TRefreshTokenImpl
598598
return {};
599599
}
600600

601+
TMaybe<TString> GetOpenTelemetryTraceParent() const override {
602+
return {};
603+
}
604+
601605
TMaybe<TString> GetSdkBuildInfo() const {
602606
return {};
603607
}
@@ -817,6 +821,10 @@ class TGRpcRequestBiStreamWrapper
817821
return GetPeerMetaValues(NYdb::YDB_TRACE_ID_HEADER);
818822
}
819823

824+
TMaybe<TString> GetOpenTelemetryTraceParent() const override {
825+
return GetPeerMetaValues(NYdb::OTEL_TRACE_HEADER);
826+
}
827+
820828
const TMaybe<TString> GetSdkBuildInfo() const {
821829
return GetPeerMetaValues(NYdb::YDB_SDK_BUILD_INFO_HEADER);
822830
}
@@ -1139,6 +1147,10 @@ class TGRpcRequestWrapperImpl
11391147
return GetPeerMetaValues(NYdb::YDB_TRACE_ID_HEADER);
11401148
}
11411149

1150+
TMaybe<TString> GetOpenTelemetryTraceParent() const override {
1151+
return GetPeerMetaValues(NYdb::OTEL_TRACE_HEADER);
1152+
}
1153+
11421154
const TMaybe<TString> GetSdkBuildInfo() const {
11431155
return GetPeerMetaValues(NYdb::YDB_SDK_BUILD_INFO_HEADER);
11441156
}

ydb/core/grpc_services/base/iface.h

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,7 @@ using TAuditLogHook = std::function<void (ui32 status, const TAuditLogParts&)>;
2121
class IRequestCtxBaseMtSafe {
2222
public:
2323
virtual TMaybe<TString> GetTraceId() const = 0;
24+
virtual TMaybe<TString> GetOpenTelemetryTraceParent() const = 0;
2425
// Returns client provided database name
2526
virtual const TMaybe<TString> GetDatabaseName() const = 0;
2627
// Returns "internal" token (result of ticket parser authentication)

ydb/core/grpc_services/local_rpc/local_rpc.h

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -191,6 +191,10 @@ class TLocalRpcCtx : public NGRpcService::IRequestOpCtx {
191191
return Nothing();
192192
}
193193

194+
TMaybe<TString> GetOpenTelemetryTraceParent() const override {
195+
return Nothing();
196+
}
197+
194198
TInstant GetDeadline() const override {
195199
return TInstant::Max();
196200
}

0 commit comments

Comments
 (0)