@@ -103,15 +103,23 @@ public HttpResponse<Flowable<byte[]>> pseudonymizeField(
103103 * @param request JSON string representing a {@link DepseudoFieldRequest} object.
104104 * @return HTTP response containing a {@link HttpResponse<Flowable>} object.
105105 */
106+ @ WithSpan ("depseudonymize column" )
107+ @ AddingSpanAttributes
106108 @ Operation (summary = "Depseudonymize field" , description = "Depseudonymize a field." )
107109 @ Produces (MediaType .APPLICATION_JSON )
108110 @ Secured ({PseudoServiceRole .ADMIN })
109111 @ Post (value = "/depseudonymize/field" , consumes = MediaType .APPLICATION_JSON )
110112 @ ExecuteOn (TaskExecutors .BLOCKING )
111113 public HttpResponse <Flowable <byte []>> depseudonymizeField (
112- @ Schema (implementation = DepseudoFieldRequest .class ) String request
114+ @ SpanAttribute ( "depseudonymize column request" ) @ Schema (implementation = DepseudoFieldRequest .class ) String request
113115 ) {
114116 DepseudoFieldRequest req = Json .toObject (DepseudoFieldRequest .class , request );
117+ Span currentSpan = Span .current ();
118+ if (currentSpan .getSpanContext ().isValid () && req != null ) {
119+ currentSpan .setAttribute ("pseudo.field" , req .getName ());
120+ currentSpan .setAttribute ("pseudo.pattern" , req .getPattern ());
121+ currentSpan .setAttribute ("pseudo.values.count" , req .getValues () == null ? 0 : req .getValues ().size ());
122+ }
115123 log .info (Strings .padEnd (String .format ("*** Depseudonymize field: %s " , req .getName ()), 80 , '*' ));
116124 PseudoField pseudoField = new PseudoField (req .getName (), req .getPattern (), req .getPseudoFunc (), req .getKeyset ());
117125 try {
0 commit comments