2222import java .time .Duration ;
2323import java .util .Map ;
2424import java .util .Optional ;
25- import java .util .function .Predicate ;
26-
27- import org .openjdk .jmc .flightrecorder .rules .IRule ;
2825
2926import io .cryostat .ConfigProperties ;
3027import io .cryostat .core .reports .InterruptibleReportGenerator ;
@@ -163,12 +160,6 @@ private Uni<Map<String, AnalysisResult>> fireRequest(InputStream stream, String
163160 return sidecar .generate (stream , getEffectiveFilter (filter ));
164161 }
165162
166- public static class ReportGenerationException extends RuntimeException {
167- public ReportGenerationException (Throwable cause ) {
168- super (cause );
169- }
170- }
171-
172163 @ Override
173164 public boolean keyExists (ActiveRecording recording ) {
174165 return false ;
@@ -187,14 +178,6 @@ private boolean usePresignedSidecar() {
187178 return useSidecar () && usePresignedTransfer ;
188179 }
189180
190- private Uni <Map <String , AnalysisResult >> process (
191- InputStream stream , Predicate <IRule > predicate ) {
192- return Uni .createFrom ()
193- .future (
194- reportGenerator .generateEvalMapInterruptibly (
195- new BufferedInputStream (stream ), predicate ));
196- }
197-
198181 private URI getPresignedPath (String jvmId , String filename ) throws URISyntaxException {
199182 logger .infov ("Handling presigned download request for {0}/{1}" , jvmId , filename );
200183 GetObjectRequest getRequest =
@@ -209,4 +192,10 @@ private URI getPresignedPath(String jvmId, String filename) throws URISyntaxExce
209192 .build ();
210193 return URI .create (presigner .presignGetObject (presignRequest ).url ().toString ()).normalize ();
211194 }
195+
196+ public static class ReportGenerationException extends RuntimeException {
197+ public ReportGenerationException (Throwable cause ) {
198+ super (cause );
199+ }
200+ }
212201}
0 commit comments