SrSSKJr SSKJr SSKJr SSKrSSKrSSKrSSK rSSK rSSK rSSK rSSK rSSKrSSKrSSKrSSKJr SSKJr SSKJr SSKrS rS rS rS r"S S\5rSr"SS\5rg)zA library for logs tailing.)absolute_import)division)unicode_literalsN)apis) gapic_util)logzMhttps://cloud.google.com/logging/docs/reference/tools/gcloud-logging#tailing.c [RRS[RRS[RRS[RR S[RR S0nUR5[RR:XagU"U5 U"SRURUR5S5UR555 g) z(Handles _MultiThreadedRendezvous errors.zInvalid argument.z&There are too many tail sessions open.zInternal error.z-Access is denied or has changed for resource.zTThe maximum duration for tail has been met. The command may be repeated to continue.Nz{} ({})zUnknown error encountered.) grpc StatusCodeINVALID_ARGUMENTRESOURCE_EXHAUSTEDINTERNALPERMISSION_DENIED OUT_OF_RANGEcode CANCELLEDformatgetdetails) rendezvous output_debugoutput_warningerror_messages_by_codes -lib/googlecloudsdk/api_lib/logging/tailing.py_HandleGrpcRendezvousr0s oo&&  oo(( 2 oo  oo'' 9 oo"" 6 __$//333 z!!  !2!=?cR[R"SS5nURRRnUR R SUR RS0nUR5H.upVURUSRU55nU"Xv5 M0 g)zHandles supression counts.loggingv2zLogging API backend rate limitz,client not consuming messages quickly enoughzUNKNOWN REASON: {}N) rGetGapicClientClasstypesTailLogEntriesResponseSuppressionInfoReason RATE_LIMIT NOT_CONSUMEDitemsrr)counts_by_reasonhandler client_classsuppression_infosuppression_reason_stringsreasoncount reason_strings r_HandleSuppressionCountsr1Ks)))T:,"((??OO(( *** 8   (--/mf.22$++F35M M!0rcH\rSrSrSrSrSrSrSrSr Sr S r S r S r g ) _SuppressionInfoAccumulator\zKAccumulates and outputs information about suppression for the tail session.cXlX lX0l[R"5Ul[R"5UlU"5UlgN)_get_now_warning_error collectionsCounter_count_by_reason_delta_count_by_reason_cumulative _last_flush)selfget_nowr output_errors r__init__$_SuppressionInfoAccumulator.__init___s=M"MK"-"5"5"7D'2':':' total_seconds&_SUPPRESSION_INFO_FLUSH_PERIOD_SECONDSrFs r _ShouldFlush(_SuppressionInfoAccumulator._ShouldFlushks, MMOd.. . ]_E FFrcDURSRX!55 g)Nz Suppressed {} entries due to {}.)r9rr?r0r/s r_OutputSuppressionDeltaMessage:_SuppressionInfoAccumulator._OutputSuppressionDeltaMessageosKK299%OPrcDURSRX!55 g)Nz+In total, suppressed {} messages due to {}.)r8rrOs r#_OutputSuppressionCumulativeMessage?_SuppressionInfoAccumulator._OutputSuppressionCumulativeMessagersMM?FF rcUR5Ul[URUR5 U=R UR- slURR 5 gr6)r7r>r1r<rPr=clearrFs r_Flush"_SuppressionInfoAccumulator._FlushvsS}}DT88!@@B$$(C(CC$%%'rcUR5 [URUR5 UR(aUR 5 ggr6)rWr1r=rSrGrFs rFinish"_SuppressionInfoAccumulator.Finish}s?KKMT==!EEG '' ((*(rc U=R[R"UVs0sHo"RUR_M sn5- slUR 5(aUR 5 ggs snfr6)r<r:r;r.suppressed_countrLrW)r?r,infos rAdd_SuppressionInfoAccumulator.Addsf;#6#68HI8Hd++ +8HI$KK  kkm Js A6 )r=r<r9r7r>r8N)__name__ __module__ __qualname____firstlineno____doc__rBrGrLrPrSrWrZr___static_attributes__rrr3r3\s0S!HFQ(+rr3c## UR5 [XU5nSnUR(aVUR5nUR UR5 URHn U v M UR(aMVU(a [XcU5 UR5 UR5 g![R a nUnSnAMPSnAff=f7f)aStreams entries back from the Logging API. Args: get_now: A callable that returns the current time. output_warning: A callable that outputs the argument as a warning. output_error: A callable that outputs the argument as an error. output_debug: A callable that outputs the argument as debug info. tail_stub: The `BidiRpc` stub to use. Yields: Entries included in the tail session. N) openr3 is_activerecvr RpcErrorr_r,entriesrrZclose) r@rrAr tail_stubsuppression_info_accumulatorerrorresponseeentrys r_StreamEntriesrus ..!< |"- % !h!$$X%>%>?!! k"  %~>%%' // == e  s50C B<AC 4C <CCC CC c\rSrSrSrSrS\RR\R\R\ RR4Sjr SrSrg) LogTailerzStreams logs using gRPC.cJ[R"SS5UlSUlg)Nrr )rGetGapicClientInstanceclientrorFs rrBLogTailer.__init__s--i>DKDNrNc## URRR5nURR U5 X(l[ R"URURRRRUS9Ul U(a[R"US9Ul[XtUX`R5Hn U v M g7f)aTails log entries from the Cloud Logging API. Args: resource_names: The resource names to tail. logs_filter: The Cloud Logging filter identifying entries to include in the session. buffer_window_seconds: The amount of time that Cloud Logging should buffer entries to get correct ordering, or None if the backend should use its default. output_warning: A callable that outputs the argument as a warning. output_error: A callable that outputs the argument as an error. output_debug: A callable that outputs the argument as debug. get_now: A callable that returns the current time. Yields: Entries for the tail session. )initial_request)secondsN)r{r"TailLogEntriesRequestresource_namesextendfilterr MakeBidiRpcr transporttail_log_entriesrodatetime timedelta buffer_windowru) r?r logs_filterbuffer_window_secondsrrArr@requestrts rTailLogsLogTailer.TailLogss2kk557G !!.1 N++ T[[((22CC!DN&009NOg ,nn> k>sCCc\UR(aURR5 ggr6)rornrFs rStopLogTailer.Stops ~~ nnr)r{ro)rarbrcrdrerBrerrPrintrqdebugrnowrrrfrgrrrwrwsB &*!ggmmIIII((,,$Lrrw)re __future__rrrr:r+google.appengine.logging.v1.request_log_pb2google"google.appengine.v1.audit_data_pb2&google.appengine.v1beta.audit_data_pb23google.cloud.appengine_v1alpha.proto.audit_data_pb2 google.cloud.audit.audit_log_pb2/google.cloud.bigquery.logging.v1.audit_data_pb2"google.iam.admin.v1.audit_data_pb2$google.iam.v1.logging.audit_data_pb2google.type.money_pb2googlecloudsdk.api_lib.utilrgooglecloudsdk.corerrr rKrErr1objectr3rurwrgrrrsz"&'3)-:'6)+-*# *+&a6"",&,^"J//r