7?0com/dexels/navajo/monitor/alert/EarlyWarningTask/com/dexels/navajo/monitor/alert/BaseWarningTaskloggerLorg/slf4j/Logger;callsThresholdJexceptionsThresholdruntimeThresholdexceptionsPerCallThresholdFemailRecipientsLjava/lang/String; knownScriptsLjava/util/List; Signature$Ljava/util/List;previousRunDateLjava/util/Date;()VCode org/slf4j/LoggerFactory  getLogger%(Ljava/lang/Class;)Lorg/slf4j/Logger;  LineNumberTableLocalVariableTable $ "&java/util/ArrayList %$ ) +java/util/Date *$ . this2Lcom/dexels/navajo/monitor/alert/EarlyWarningTask;modified(Ljava/util/Map;)V8(Ljava/util/Map;)V5true7MONITOR_MASTER 9;:java/lang/System <=getenv&(Ljava/lang/String;)Ljava/lang/String; ?A@java/lang/String BCequalsIgnoreCase(Ljava/lang/String;)Z E 12 H50 J KL getSettingG(Ljava/util/Map;Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String; NPOjava/lang/Long QR parseLong(Ljava/lang/String;)J T W10000 Y  \1000 ^  a0.1 cedjava/lang/Float fg parseFloat(Ljava/lang/String;)F i kemailTo m Kn5(Ljava/util/Map;Ljava/lang/String;)Ljava/lang/String; p  r st scheduler/Ljava/util/concurrent/ScheduledExecutorService; vxw-java/util/concurrent/ScheduledExecutorService yshutdown {}|java/util/concurrent/Executors ~newScheduledThreadPool2(I)Ljava/util/concurrent/ScheduledExecutorService;2com/dexels/navajo/monitor/alert/EarlyWarningTask$1 "5(Lcom/dexels/navajo/monitor/alert/EarlyWarningTask;)V, java/util/concurrent/TimeUnit SECONDSLjava/util/concurrent/TimeUnit; v scheduleWithFixedDelay](Ljava/lang/Runnable;JJLjava/util/concurrent/TimeUnit;)Ljava/util/concurrent/ScheduledFuture;settingsLjava/util/Map;LocalVariableTypeTable5Ljava/util/Map; StackMapTablemailEarlyWarnings5(Ljava/lang/String;Ljava/util/List;Ljava/util/Date;)VJ(Ljava/lang/String;Ljava/util/List;Ljava/util/Date;)V * after(Ljava/util/Date;)Z java/util/List clear stream()Ljava/util/stream/Stream; testR(Lcom/dexels/navajo/monitor/alert/EarlyWarningTask;)Ljava/util/function/Predicate; java/util/stream/Stream filter9(Ljava/util/function/Predicate;)Ljava/util/stream/Stream; java/util/stream/Collectors toList()Ljava/util/stream/Collector; collect0(Ljava/util/stream/Collector;)Ljava/lang/Object; isEmpty()Zjava/lang/StringBuilder,No early warning alerts to email for tenant "(Ljava/lang/String;)V append-(Ljava/lang/String;)Ljava/lang/StringBuilder;! toString()Ljava/lang/String; org/slf4j/Logger info   emailBody $

Early warnings for 

#
    iterator()Ljava/util/Iterator; java/util/Iterator next()Ljava/lang/Object;org/bson/Documentscript get&(Ljava/lang/Object;)Ljava/lang/Object; add(Ljava/lang/Object;)Z exceptionsjava/lang/IntegertotalexceptionsPerCalljava/lang/Doubleavgtime-
  • %s: %s, %s, %s, %s
    • java/lang/Object%d calls  intValue()I ! "#style9(Ljava/lang/String;Ljava/lang/Object;Z)Ljava/lang/String;% %d exceptions' ratio: %.4f ) *+ doubleValue()D- avg: %d ms N/ 0 longValue ?2 34format9(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String; 6 7hasNext9
;__BODY__ ?= >? replaceAll8(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;A$Navajo Monitor - early warning alert CED3com/dexels/navajo/server/impl/NavajoConfigComponent FG getInstance)()Lcom/dexels/navajo/server/NavajoConfig; ?I JKvalueOf&(Ljava/lang/Object;)Ljava/lang/String;M ( OQP%com/dexels/navajo/server/NavajoConfig R getDeploymentT)V: X YZ sendEmail9(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)VtenantalertsrunDatecontentsbodyLjava/lang/StringBuilder;objLorg/bson/Document;Ljava/lang/Integer;callsLjava/lang/Double;avgTimeLjava/lang/Long;subject%Ljava/util/List;k[Ljava/lang/Object;m!o qsargLjava/lang/Object;isErrorZ checkTenant$(Ljava/lang/String;)Ljava/util/List;9(Ljava/lang/String;)Ljava/util/List;|date ~ getQueryDateToday()Ljava/util/Date;  "'(Ljava/lang/String;Ljava/lang/Object;)V[  9(Ljava/lang/String;Ljava/lang/Object;)Lorg/bson/Document; $  J(I)Ljava/lang/Integer; sumtotaltime externalCallslastcall_id$script$sum $exceptions$total$externalCalls $sumtotaltime$last $lastcall$divide java/util/Arrays asList%([Ljava/lang/Object;)Ljava/util/List;$gte N J(J)Ljava/lang/Long; % c J(F)Ljava/lang/Float;$or$match$project$group   mongoClient,Lcom/dexels/navajo/mongo/client/MongoClient; *com/dexels/navajo/mongo/client/MongoClient getMongoDatabase$()Lcom/mongodb/client/MongoDatabase;metrics.script  com/mongodb/client/MongoDatabase  getCollection8(Ljava/lang/String;)Lcom/mongodb/client/MongoCollection; "com/mongodb/client/MongoCollection  aggregate8(Ljava/util/List;)Lcom/mongodb/client/AggregateIterable; java/lang/Boolean J(Z)Ljava/lang/Boolean; $com/mongodb/client/AggregateIterable  allowDiskUse;(Ljava/lang/Boolean;)Lcom/mongodb/client/AggregateIterable;  into.(Ljava/util/Collection;)Ljava/util/Collection; accept()Ljava/util/function/Consumer;  forEach (Ljava/util/function/Consumer;)VpipelineLjava/util/ArrayList; matchPipe projectPipe groupPipefinalProjectPipefinalMatchPipefinalMatchPipeElements collection$Lcom/mongodb/client/MongoCollection;out&Lcom/mongodb/client/AggregateIterable;result*Ljava/util/ArrayList;9Lcom/mongodb/client/MongoCollection;;Lcom/mongodb/client/AggregateIterable; java/util/Calendar F()Ljava/util/Calendar;  setTime(Ljava/util/Date;)V  set(II)V  calendarLjava/util/Calendar;lambda$0(Lorg/bson/Document;)Z  containsdocumentlambda$1(Lorg/bson/Document;)V  put8(Ljava/lang/String;Ljava/lang/Object;)Ljava/lang/Object;   getDouble&(Ljava/lang/Object;)Ljava/lang/Double;  java/lang/Math !"round(D)J SourceFileEarlyWarningTask.javaBootstrapMethods ')("java/lang/invoke/LambdaMetafactory *+ metafactory(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;& /  .(Ljava/lang/Object;)V2 5 4 InnerClasses:%java/lang/invoke/MethodHandles$Lookup<java/lang/invoke/MethodHandlesLookup NestMembers!     )  !"Q*#*%Y'(**Y,- %&! /0123"468>*+D**+FGIMS**+UVIMX**+Z[IM]**+_`Ibh**+jlo*q *qu*zq*qY* W F) *,/#031C2D3P2S4^6e7n:v;G;H!/0 _0 O-*- *(*--,*M,!Y+ɶŶ˹*:Y:,sYط+ڶŶ˶WܶW,:2:?:*(W: : : N: WY* + - Ŷ˶WYSY*  *X SY*$  *S SY*&  (*h SY*,  .*] S1W58W:˶<:@:B+YHLŸBNSŶ:YHU+Ŷ:**oW *K LNO*P5O6R?S\T]VcWlXuYZ[\]^_`acd$e>dBfRgqhijikf[mopqr'tBuNv! O/0O[O\O]c^l_`#abc dc e fg Vh O\iHE?*? ?*??N?jj? ?*??N ?jj? ?*??N?jj? ?*??N ?jj? ?*??N?jj? ?*??N ?jj? ?*??N?jj?N ?*??N ?jj?N ?*??*?A?"#J&Yl+Y,S1nŶ˰Yp+Y,S1rŶ˰ yz{#z'}!*J/0J3JtuJvw'xyzP %Y'MY{*}N-+WY:WWWWWWY:YWYWYWYWYWY:Y?YSYSWY?YSYSWWWWWWY:%Y':YY*SWYY*XWYY*hWYY*]WW,Y-W,YW,YW,YW,YW*ǹ:  ,չ: %Y':     2 )5AMZgt!>BO[gt.?Par{!z /0[b)b7bb0b'5 "  4'5 " i |0L+*Y,+ + + ++  $+!0/0,   W*(+ O!/0b@ W%**W**(W $! %b#$%,-01,36789;=>