@@ -268,9 +268,9 @@ void PrintClient(const ServiceDescriptor* service, Printer* out) {
268
268
vars[" output_type" ] = NodeObjectPath (output_type);
269
269
if (method->client_streaming () ||
270
270
method->server_streaming ()){
271
- out->Print (vars, " this.$method_name$Trace = rsocket_rpc_tracing.trace(tracer, \" $service_short_name$.$method_name$\" , {\" proteus .service\" : \" $service_name$\" }, {\" proteus.type \" : \" client\" });\n " );
271
+ out->Print (vars, " this.$method_name$Trace = rsocket_rpc_tracing.trace(tracer, \" $service_short_name$.$method_name$\" , {\" rsocket .service\" : \" $service_name$\" }, {\" rsocket.rpc.role \" : \" client\" });\n " );
272
272
} else {
273
- out->Print (vars, " this.$method_name$Trace = rsocket_rpc_tracing.traceSingle(tracer, \" $service_short_name$.$method_name$\" , {\" proteus .service\" : \" $service_name$\" }, {\" proteus.type \" : \" client\" });\n " );
273
+ out->Print (vars, " this.$method_name$Trace = rsocket_rpc_tracing.traceSingle(tracer, \" $service_short_name$.$method_name$\" , {\" rsocket .service\" : \" $service_name$\" }, {\" rsocket.rpc.role \" : \" client\" });\n " );
274
274
}
275
275
}
276
276
out->Outdent ();
@@ -338,9 +338,9 @@ void PrintServer(const ServiceDescriptor* service, Printer* out) {
338
338
vars[" output_type" ] = NodeObjectPath (output_type);
339
339
if (method->client_streaming () ||
340
340
method->server_streaming ()){
341
- out->Print (vars, " this.$method_name$Trace = rsocket_rpc_tracing.traceAsChild(tracer, \" $service_short_name$.$method_name$\" , {\" proteus .service\" : \" $service_name$\" }, {\" proteus.type \" : \" server\" });\n " );
341
+ out->Print (vars, " this.$method_name$Trace = rsocket_rpc_tracing.traceAsChild(tracer, \" $service_short_name$.$method_name$\" , {\" rsocket .service\" : \" $service_name$\" }, {\" rsocket.rpc.role \" : \" server\" });\n " );
342
342
} else {
343
- out->Print (vars, " this.$method_name$Trace = rsocket_rpc_tracing.traceSingleAsChild(tracer, \" $service_short_name$.$method_name$\" , {\" proteus .service\" : \" $service_name$\" }, {\" proteus.type \" : \" server\" });\n " );
343
+ out->Print (vars, " this.$method_name$Trace = rsocket_rpc_tracing.traceSingleAsChild(tracer, \" $service_short_name$.$method_name$\" , {\" rsocket .service\" : \" $service_name$\" }, {\" rsocket.rpc.role \" : \" server\" });\n " );
344
344
}
345
345
}
346
346
out->Print (" this._channelSwitch = (payload, restOfMessages) => {\n " );
0 commit comments