{SrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSK rSSK rSSK rSSK rSSK rSSKJr SSKJr SSKJr SSKrSrSrSrS r"S S \5rS r"S S\5rg)zA library for logs tailing.N)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_HandleGrpcRendezvousr.s 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_HandleSuppressionCountsr.Is)))T:,"((??OO(( *** 8   (--/mf.22$++F35M M!0rcH\rSrSrSrSrSrSrSrSr Sr S r S r S r g ) _SuppressionInfoAccumulatorZzKAccumulates 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':':'r tail_stubsuppression_info_accumulatorerrorresponseeentrys r_StreamEntriesrrs ..!< |"- % !h!$$X%>%>?!! k"  %~>%%' // == e  s50C B<AC 4C <CCC CC c\rSrSrSrSrSrS\RR\R\R\ RR4SjrSrSrg) LogTailerzStreams logs using gRPC.c[R"SS5Ul[R"5UlUR R UR5 SUlg)Nrr)rGetGapicClientInstanceclient contextlib ExitStack _exit_stack enter_contextrlrCs rr?LogTailer.__init__sF--i>DK!++-D""4;;/DNrcXUR5 URR5 gr3)Stopr{rkrCs rrkLogTailer.closesIIKrNc## 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)rxrTailLogEntriesRequestresource_namesextendfilterr MakeBidiRpcr transporttail_log_entriesrldatetime timedelta buffer_windowrr) r<r logs_filterbuffer_window_secondsrr>rr=requestrqs rTailLogsLogTailer.TailLogss2kk557G !!.1 N++ T[[((22CC!DN&009NOg ,nn> k>sCCc\UR(aURR5 ggr3)rlrkrCs rrLogTailer.Stops ~~ nnr)r{rxrl)r^r_r`rarbr?rkrerrPrintrndebugrnowrrrcrdrrrtrtsG &*!ggmmIIII((,,$Lrrt)rbr7ryr+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.corerrrrHrBrr.objectr0rrrtrdrrrsv"3)-:'6)+-*# *+&a6"",&,^"J66r