@@ -735,38 +735,42 @@ public void maybeTrack(final String rawRequest, Headers requestHeaders) {
735735 .incrementAndGet ();
736736 } else if (Regex .simpleMatch ("PUT /*/*" , request )
737737 && requestComponents .customQueryParameters ().containsKey (S3BlobStore .CUSTOM_QUERY_PARAMETER_COPY_SOURCE )) {
738- trackRequest ("CopyObject" );
739- metricsCount .computeIfAbsent (
740- new S3BlobStore .StatsKey (S3BlobStore .Operation .COPY_OBJECT , purpose ),
741- k -> new AtomicLong ()
742- ).incrementAndGet ();
743- } else if (isMultiPartUpload (request )) {
744- trackRequest ("PutMultipartObject" );
745- metricsCount .computeIfAbsent (
746- new S3BlobStore .StatsKey (S3BlobStore .Operation .PUT_MULTIPART_OBJECT , purpose ),
747- k -> new AtomicLong ()
748- ).incrementAndGet ();
749- } else if (Regex .simpleMatch ("PUT /*/*" , request )) {
750- trackRequest ("PutObject" );
751- metricsCount .computeIfAbsent (new S3BlobStore .StatsKey (S3BlobStore .Operation .PUT_OBJECT , purpose ), k -> new AtomicLong ())
752- .incrementAndGet ();
753- } else if (Regex .simpleMatch ("POST /*/?delete" , request )) {
754- trackRequest ("DeleteObjects" );
755- metricsCount .computeIfAbsent (new S3BlobStore .StatsKey (S3BlobStore .Operation .DELETE_OBJECTS , purpose ), k -> new AtomicLong ())
756- .incrementAndGet ();
757- } else if (Regex .simpleMatch ("DELETE /*/*?uploadId=*" , request )) {
758- trackRequest ("AbortMultipartObject" );
759- metricsCount .computeIfAbsent (
760- new S3BlobStore .StatsKey (S3BlobStore .Operation .ABORT_MULTIPART_OBJECT , purpose ),
761- k -> new AtomicLong ()
762- ).incrementAndGet ();
763- } else if (Regex .simpleMatch ("HEAD /*/*" , request )) {
764- trackRequest ("HeadObject" );
765- metricsCount .computeIfAbsent (new S3BlobStore .StatsKey (S3BlobStore .Operation .HEAD_OBJECT , purpose ), k -> new AtomicLong ())
766- .incrementAndGet ();
767- } else {
768- logger .info ("--> rawRequest not tracked [{}] with parsed purpose [{}]" , request , purpose .getKey ());
769- }
738+ trackRequest ("CopyObject" );
739+ metricsCount .computeIfAbsent (
740+ new S3BlobStore .StatsKey (S3BlobStore .Operation .COPY_OBJECT , purpose ),
741+ k -> new AtomicLong ()
742+ ).incrementAndGet ();
743+ } else if (isMultiPartUpload (request )) {
744+ trackRequest ("PutMultipartObject" );
745+ metricsCount .computeIfAbsent (
746+ new S3BlobStore .StatsKey (S3BlobStore .Operation .PUT_MULTIPART_OBJECT , purpose ),
747+ k -> new AtomicLong ()
748+ ).incrementAndGet ();
749+ } else if (Regex .simpleMatch ("PUT /*/*" , request )) {
750+ trackRequest ("PutObject" );
751+ metricsCount .computeIfAbsent (new S3BlobStore .StatsKey (S3BlobStore .Operation .PUT_OBJECT , purpose ), k -> new AtomicLong ())
752+ .incrementAndGet ();
753+ } else if (Regex .simpleMatch ("POST /*/?delete" , request )) {
754+ trackRequest ("DeleteObjects" );
755+ metricsCount .computeIfAbsent (
756+ new S3BlobStore .StatsKey (S3BlobStore .Operation .DELETE_OBJECTS , purpose ),
757+ k -> new AtomicLong ()
758+ ).incrementAndGet ();
759+ } else if (Regex .simpleMatch ("DELETE /*/*?uploadId=*" , request )) {
760+ trackRequest ("AbortMultipartObject" );
761+ metricsCount .computeIfAbsent (
762+ new S3BlobStore .StatsKey (S3BlobStore .Operation .ABORT_MULTIPART_OBJECT , purpose ),
763+ k -> new AtomicLong ()
764+ ).incrementAndGet ();
765+ } else if (Regex .simpleMatch ("HEAD /*/*" , request )) {
766+ trackRequest ("HeadObject" );
767+ metricsCount .computeIfAbsent (
768+ new S3BlobStore .StatsKey (S3BlobStore .Operation .HEAD_OBJECT , purpose ),
769+ k -> new AtomicLong ()
770+ ).incrementAndGet ();
771+ } else {
772+ logger .info ("--> rawRequest not tracked [{}] with parsed purpose [{}]" , request , purpose .getKey ());
773+ }
770774 }
771775
772776 Map <S3BlobStore .StatsKey , AtomicLong > getMetricsCount () {
0 commit comments