@@ -9,24 +9,35 @@ interface IDigmaSpanData {
99 namespace ?: string ;
1010 spanCodeObjectId ?: string ;
1111 methodCodeObjectId ?: string ;
12+ environment ?: string ;
1213}
1314
1415const getSpanDataForDigma = ( span : Span ) : IDigmaSpanData => {
15- const tagsToGet : Omit < IDigmaSpanData , 'id' | 'name' | 'serviceName' > = {
16+ const tagsToGet = {
1617 instrumentationLibrary : 'otel.library.name' ,
1718 function : 'code.function' ,
1819 namespace : 'code.namespace' ,
1920 spanCodeObjectId : 'digma.span.code.object.id' ,
2021 methodCodeObjectId : 'digma.method.code.object.id' ,
2122 } ;
2223
24+ const processTagsToGet = {
25+ environment : 'digma.environment' ,
26+ } ;
27+
2328 const tagsValues = Object . entries ( tagsToGet ) . reduce ( ( acc , [ key , value ] ) => {
2429 const tag = span . tags . find ( ( x : any ) => x . key === value ) ;
2530 return tag ? { ...acc , [ key ] : tag . value } : acc ;
2631 } , { } ) ;
2732
33+ const processTagsValues = Object . entries ( processTagsToGet ) . reduce ( ( acc , [ key , value ] ) => {
34+ const tag = span . process . tags . find ( ( x : any ) => x . key === value ) ;
35+ return tag ? { ...acc , [ key ] : tag . value } : acc ;
36+ } , { } ) ;
37+
2838 return {
2939 ...tagsValues ,
40+ ...processTagsValues ,
3041 id : span . spanID ,
3142 name : span . operationName ,
3243 serviceName : span . process . serviceName ,
0 commit comments