nSrSSKJr SSKJr SSKJr SSKrSSKrSSKrSSKrSSK r SSK r SSK r SSK r SSK r SSKrSSKJr SSKJr SSKJr SS KJr SS KJr SS KJr SS KJr SS KJr SSKrSSKrSSKrSSKrSrSrSr Sr!Sr"Sr#Sr$Sr%Sr&Sr'Sr(Sr)Sr*Sr+Sr,Sr-"SS\.5r/"S S!\.5r0SCS"jr1SCS#jr2"S$S%\.5r3"S&S'\.5r4"S(S)\.5r5"S*S+\.5r6SDS,jr7S-r8S.r9S/r:S0r;S1rS4r?S5r@\9S65rA\9SES7j5rB\9S85rC\9SFS9j5rD\9SGS:j5rE\9S;5rF\9S<5rG\9S=5rH\9S>5rI\9S?5rJ\RS@5rL\9SA5rM\9SB5rNg)Hz&Used to collect anonymous SDK metrics.)absolute_import)division)unicode_literalsN)config)execution_utils)log) properties) console_attr) console_io)encoding) platformsInstallsCommandsHelpError ExecutionsTestExecutionsCustomloadruntotalremotelocalstartzhttps://play.googleapis.com/logevent_metadata error_typec\rSrSrSrSrg)_EventDc4XlX lX0lX@lgNcategoryactionlabelvalue)selfr#r$r%r&s "lib/googlecloudsdk/core/metrics.py__init___Event.__init__FsMKJJ)r$r#r%r&N__name__ __module__ __qualname____firstlineno__r)__static_attributes__r+r(rrDsr+rc\rSrSrSrSrSrg) CommonParamsMz+Parameters common to all metrics reporters.c[R"5nURS5(aSOSn[RR 5n[ R"5UlX0l [U5Ul [ RRUl X l[R "5Ul[$R&"SSS9Ul[*R,"5Ul[R.R0R2R55Ul[$R8"5Ul[<R>"5RA5Ul!g)Nz .google.comGoogleExternalT)error heuristic)"socket gethostnameendswithr PlatformCurrentrGetCID client_idcurrent_platform GetUserAgent user_agentINSTALLATION_CONFIGrelease_channel install_typer GetMetricsEnvironmentmetrics_environmentr IsInteractiveis_interactiveplatformpython_versionVALUESmetricsenvironment_versionGetmetrics_environment_versionIsRunFromShellScriptis_run_from_shell_scriptr GetConsoleAttrGetTermIdentifierterm_identifier)r'hostnamerGrBs r(r)CommonParams.__init__Ps!!#H'00??8ZL ))113]]_DN,"#34DO!55EED$)??AD$22ND"113D(2(9(9)01D1DSSU $$.$C$C$ED!'668JJLDr+) rArBrGrKrTrIrRrMrFrWrDN)r-r.r/r0__doc__r)r1r2r+r(r4r4Ms 3Mr+r4ch[[U=(d [R"5S-55$)Ni)introundtime) time_secss r( GetTimeMillisr`ds" UI,4 5 66r+cU=(d [RR5nSR[R UR 5S9$)zConstructs a user agent string from config and platform fragments. Args: current_platform: Optional platforms.Platform for pulling platform-specific user agent details. Returns: str, The user agent for the current client. zCloudSDK/{version} {fragment})versionfragment)r r>r?formatrCLOUD_SDK_VERSIONUserAgentFragment)rBs r(rCrChsK&E););)C)C)E ( / /&&113 0 55r+c\rSrSrSrSrg) _TimedEventycXlX lgr!name time_millis)r'rlrms r(r)_TimedEvent.__init__{s I"r+rkNr,r2r+r(rhrhys#r+rhc@\rSrSrSrSrSrSrS SjrSr S r S r g) _CommandTimerz.A class for timing the execution of a command.ctSUl/UlSUlSUlSUlSUlSUlSUlg)Nrunknown)_CommandTimer__start_CommandTimer__events!_CommandTimer__total_rpc_duration#_CommandTimer__total_local_duration_CommandTimer__category_CommandTimer__action_CommandTimer__label_CommandTimer__flag_namesr's r(r)_CommandTimer.__init__s=DLDM !D"#DDODMDLDr+c4XlX lX0lX@lgr!rxryrzr{)r'r#r$r% flag_namess r( SetContext_CommandTimer.SetContextsOML"r+c^URURURUR4$r!rr|s r( GetContext_CommandTimer.GetContexts# ??DMM4<<9J9J JJr+Nc[U5nU[LaX0lgURR [ X55 U[ La3X0R- UlU=RUR-slggr!) r` _START_EVENTrtruappendrh _TOTAL_EVENTrwrv)r'rl event_timerms r(Event_CommandTimer.Eventsf +K | l MMT78 |$/,,$>d! !!T%>%>>!r+c.U=RU- slgr!)rvr'duration_in_mss r(AddRPCDuration_CommandTimer.AddRPCDurations/r+c/nURH7nURURURUR- 45 M9 UR [ UR4[UR4/5 U$)z,Returns the timings for the recorded events.) rurrlrmrtextend _LOCAL_EVENTrw _REMOTE_EVENTrv)r'timingsevents r( GetTimings_CommandTimer.GetTimingssoG nnejj%"3"3dll"BCD NN t223 112 Nr+)__action __category__events __flag_names__label__start__total_local_duration__total_rpc_durationr!) r-r.r/r0rZr)rrrrrr1r2r+r(rprps$6# K ?0 r+rpcj\rSrSrSrSr\S5r\S5r\S5r S Sjr S r S r S r g) _ClearcutMetricsReporterz3A class for handling reporting metrics to Clearcut.c 6URUlSSURRR0S.SUR S.UlSUR4SUR4SUR4S UR4S UR4S UR4S UR4S UR4/nUVs/sH"nUS[R "US5S.PM$ snUl[$R&nUSUR S.Ul/Ulgs snf)NDESKTOPos) client_typedesktop_client_infoCONCORD) client_infolog_source_namezwieback_cookierFrG environment interactiverMrP from_scripttermrkeyr&CloudSDK)release_version console_typeclient_install_id)rD _user_agentrBoperating_systemidrA_clearcut_request_paramsrFrGrIrKrMrRrTrWsix text_type _clearcut_concord_event_metadatarre_clearcut_concord_event_params_clearcut_concord_timed_events)r' common_paramsrparamcloud_sdk_versions r(r)!_ClearcutMetricsReporter.__init__s7$//D%m44EEHH$ %(22 %D! M99: 334  99:  445 =778  I IJ  >>? ../ N"-#!%Qx#--a"9.!-#D)00,"*44+D' +-D'-#s8)DcUR$r!)rr|s r(r'_ClearcutMetricsReporter.event_metadatas  0 00r+cUR$r!)rr|s r( event_params%_ClearcutMetricsReporter.event_paramss  . ..r+cUR$r!)rr|s r(request_params'_ClearcutMetricsReporter.request_paramss  ( ((r+Nc[UR5nURUS'URUS'[ UR 5U[ '/nUb(URS[R"U5S.5 UbUR[US.5 UbURSUS.5 UR[LaURSURS.5 OUR[LaURSURS.5 OUR[La#UR[URS.5 OmUR[LaURS URS.5 O;UR[ La(URURUR"S.5 U[ R%U5 UR&RU[)545 g) Records the given event. Args: event: _Event, The event to process. flag_names: str, Comma separated list of flag names used with the action. error: class, The class (not the instance) of the Exception if a user tried to run a command that produced an error. error_extra_info_json: {str: json-serializable}, A json serializable dict of extra info that we want to log with the error. This enables us to write queries that can understand the keys and values in this dict. event_type event_nameNrrextra_error_infobinary_version help_modecomponent_version)dictrr#r$listr_CLEARCUT_EVENT_METADATA_KEYrrr_CLEARCUT_ERROR_TYPE_KEY_EXECUTIONS_CATEGORYr%_HELP_CATEGORY_ERROR_CATEGORY_INSTALLS_CATEGORY_CUSTOM_CATEGORYr&rrr`)r'rrr9error_extra_info_json concord_eventrs r(Record_ClearcutMetricsReporter.Records **+M"'..M,"',,M,26 3M./N==,  $ ~~--$4u{{KL > )K%++FG ? **U[[ AC - -$7%++NO + +EKK%++FG./66~F''.. 0=0ABr+cSnUR5n/nUH6nU(dUS[:XaUSnURUSUSS.5 M8 X$4$)z"Extracts relevant data from timer.Nrr)r latency_ms)rrr)r'timer total_latencyrsub_event_latenciestimings r(Timings _ClearcutMetricsReporter.TimingsshM G vayL8q   q "   --r+c[UR5n[5US'URU5up4SnURH-upgUS[ La U(aMX6S'XFS'US[ LnM/ /US'URH/uphUSR [R"USS9US .5 M1 [R"USS9n S UR0n [S X4$) z*Collect the required clearcut HTTP beacon.request_time_msFrrsub_event_latency_ms log_eventT sort_keys)source_extension_json event_time_msz user-agentPOST) rrr`rr_COMMANDS_CATEGORYrjsondumpsr_CLEARCUT_ENDPOINT) r'rclearcut_request event_latencyrcommand_latency_setr_rdataheaderss r( ToHTTPBeacon%_ClearcutMetricsReporter.ToHTTPBeacon,sD//0*7/&')-e)<&M ??  %); ; $1L!.A*+),7;MM @%'[!(,(K(K$ {#**#'::mt#L(, )L ::&$ 7DT--.G  66r+)rrrrrNNN)r-r.r/r0rZr)propertyrrrrrrr1r2r+r(rrsc;#-J 1 1 / / ) ) #' 2Bh."7r+rc\rSrSrSrSrSrSr\S5r \S5r \SSj5r \S5r Sr S rS rSS jrS rSS jrSSjrSrSrSSjrSrg)_MetricsCollectoriGz.A singleton class to handle metrics reporting.Nc"[R$r!)r _instancer2r+r(GetCollectorIfExists&_MetricsCollector.GetCollectorIfExistsNs  & &&r+c[R5(ag[R(d[5[l[R$)zEReturns the singleton _MetricsCollector instance or None if disabled.N)r _IsDisabledrr2r+r( GetCollector_MetricsCollector.GetCollectorRs7$$&&   & &$5$7!  & &&r+cU[l[R5(a S[lg[5[lg)aReset the singleton _MetricsCollector and reinitialize it. This should only be used for tests, where we want to collect some metrics but not others, and we have to reinitialize the collector with a different Google Analytics tracking id. Args: disable_cache: Metrics collector keeps an internal cache of the disabled state of metrics. This controls the value to reinitialize the cache. None means we will refresh the cache with the default values. True/False forces a specific value. N)r_disabled_cacher r) disable_caches r(ResetCollectorInstance(_MetricsCollector.ResetCollectorInstance\s1)6%$$&&$(!$5$7!r+c[RcS[R;aS[l[R$[R "5(dS[l[R$[R RRR5nUc[RRnU[l[R$)z6Returns whether metrics collection should be disabled. _ARGCOMPLETET) rr renvironr IsDefaultUniverserNcoredisable_usage_reportingGetBoolrrE)disableds r(r _MetricsCollector._IsDisabledps((0 2:: %,0)  , ,,++--,0)  , ,, $$))AAIIK  //GG(,4)  , ,,r+c[5n[U5/Ul[5Ul/UlSUl[RR5nUR5Ul [R"S5 g)zInitialize a new MetricsCollector. This should only be invoked through the static GetCollector() function or the static ResetCollectorInstance() function. rz Metrics collector initialized...N)r4r_metrics_reportersrp_timer_metrics _action_levelr r>r?AsyncPopenArgs_async_popen_argsrdebug)r'rrBs r(r)_MetricsCollector.__init__sn !NM !/D /DKDMD ))113-<<>DII01r+c.U=RS- slgNrrr|s r(IncrementActionLevel&_MetricsCollector.IncrementActionLevel!r+c.U=RS-slgr$r%r|s r(DecrementActionLevel&_MetricsCollector.DecrementActionLevelr(r+cfURS:XdU(dURRXS9 gg)zRecords the time when a particular event happened. Args: name: str, Name of the event. record_only_on_top_level: bool, Whether to record only on top level. event_time: float, Time when the event happened in secs since epoch. r)rN)rrr)r'rlrecord_only_on_top_levelrs r(RecordTimedEvent"_MetricsCollector.RecordTimedEvents/ Q&> kk4'?r+c:URRU5 g)zwRecords the time when a particular event happened. Args: duration_in_ms: int, Duration of the RPC in milli seconds. N)rrrs r(RecordRPCDuration#_MetricsCollector.RecordRPCDurations  KK~.r+cU[LaURS:wagU[La.URS:waURR 5upR nURR XX45 g)a;Sets the context for which the timer is collecting timed events. Args: category: str, Category of the action being timed. action: str, Name of the action being timed. label: str, Additional information about the action being timed. flag_names: str, Comma separated list of flag names used with the action. rN)rrrrrr)r'r#r$r%rrs r(SetTimerContext!_MetricsCollector.SetTimerContexts`%%$*<*<*A ?"t'9'9Q'> ..0oaAKK8U?r+cNURHnURUUUUS9 M g)rrr9rN)rr)r'rrr9rmetrics_reporters r(r_MetricsCollector.Records4 !33  5 74r+c~URH-nURUR5nUR"U6 M/ gr!)rrrCollectHTTPBeacon)r'r8 http_beacons r(CollectMetrics _MetricsCollector.CollectMetricss5 33$11$++>k k*4r+c>URRXX445 gaRecord a custom event to an arbitrary endpoint. Args: url: str, The full url of the endpoint to hit. method: str, The HTTP method to issue. body: str, The body to send with the request. headers: {str: str}, A map of headers to values to include in the request. N)rr)r'urlmethodbodyrs r(r;#_MetricsCollector.CollectHTTPBeacons MM#t56r+c6UR(dg[R"SS9nU [R"URU5 /UlSSS5 [ R "[5n[RR[RR[RRU5S55n[R"XBR5nUVs/sHn[ R "U5PM nn[R"R%5n[ R&"US[R(R[*R55 [,R."U4SU0UR0D6n[2R4"S5 U(a'WR95 [2R4"S 5 gg!,(df  GN=fs snf![6a [2R4"S5 Nhf=f) z=Reports the collected metrics using a separate async process.NF)deletezmetrics_reporter.py PYTHONPATHenvz$Metrics reporting process started...z*Metrics reporting process failed to start.z#Metrics reporting process finished.)rtempfileNamedTemporaryFilepickledumpr Decode__file__rpathrealpathjoindirnamerArgsForPythonToolrlEncodercopySetEncodedValuepathsepsys subprocessPopenr rr!OSError communicate) r'wait_for_reporttemp_metrics_file this_filereporting_script_pathexecution_argsaexec_envps r( ReportMetrics_MetricsCollector.ReportMetricssz ==  335A  kk$--!23dm )IGG,,  RWW__Y/1FGI$66557N 3AA.Qhooa(.NAzz H X|RZZ__SXX5NO>   > 5x 5!33 5a ii67 mmo ii56 5  B > ii<=>s#)G2 G069G5 G-5 HH)rr rrrr!)FNNNr)F)r-r.r/r0rZr r test_group staticmethodrr rr r)r&r*r.r1r4rr=r;rer1r2r+r(rrGs6/)*''''88&--"2.=B"& 5/@*#' 7.+ 7$7r+rc^[R5nU(dg[R(aU[La[Rn[ XX#S9nUR UUUUS9 U[ [4;aURXUS9 gU[[[4;aURXX$S9 gg)z$Common code for processing an event.Nr"r7r) rr rhrrrrrr4r_TEST_EXECUTIONS_CATEGORY) r#r$r%r&rr9r collectorrs r(_RecordEventAndSetTimerContextrns ,,.)  !!ho&E  ( (E ( L%   1 3 $&:;; h:FO^-// hM/r+cNUcgU(dgSR[U55$)Nz==NONE==,)rQsortedrks r(_GetFlagNameStringrs1s%   &$ %%r+c^U4SjnU$)z5Function decorator to capture and log any exceptions.cd>T"U0UD6$! [R"STRSS9 g=f)NzException captured in %sT)exc_info)rr!r-)argskwdsfuncs r(Wrapper'CaptureAndLogException..Wrapper>s6J 4 4  J ii*DMMDIs "/r2)ryrzs` r(CaptureAndLogExceptionr|<sJ .r+cd[RS5 U[l[[UUSS9 g)NFr)r&)rrrhrnrl) test_group_id test_methods r(StartTestMetricsrGs-**51!.  r+c[R5nU(aURSS9 S[l[R S5 g)NT)r])rrrerhrrms r(StopTestMetricsrQs;446) D1!%**40r+c`[R5(ag[R"5$)zGets the client id if metrics collection is enabled. Returns: str, The hex string of the client id if metrics is enabled, else an empty string. rp)rr rr@r2r+r(GetCIDIfMetricsEnabledrYs$""$$  r+cJ[R5(d [5$g)zGets the user agent if metrics collection is enabled. Returns: The complete user agent string if metrics is enabled, else None. N)rr rCr2r+r(GetUserAgentIfMetricsEnabledris  & & ( ( > r+c[R5nU(a6UR[5 UR 5 UR 5 gg)z(Reports the metrics that were collected.N)rrr.rr=rers r(Shutdownrvs@ 446) |,  r+cnU(a'SRURUR5$g! g=f)zGets a friendly exception name for the given error. Args: error: An exception class. Returns: str, The name of the exception to log. z{0}.{1}rsN)rdr.r-)r9s r(_GetExceptionNamers8    e.. ??  s%04c<U(a[R"USS9$g)aQSerializes the extra info into a json string for logging. Args: error_extra_info: {str: json-serializable}, A json serializable dict of extra info that we want to log with the error. This enables us to write queries that can understand the keys and values in this dict. Returns: str, The value to pass to Clearcut or None. TrN)rr)error_extra_infos r(_GetErrorExtraInfors ::&$ 77 r+c$[[X5 g)zLogs that an SDK component was installed. Args: component_id: str, The component id that was installed. version_string: str, The version of the component. N)rnr) component_idversion_strings r(rrs!,8r+c \[[X[U5[U5[ U5S9 g)aPLogs that a gcloud command was run. Args: command_path: [str], The '.' separated name of the calliope command. version_string: [str], The version of the command. flag_names: [str], The names of the flags that were used during this execution. error: class, The class (not the instance) of the Exception if a user tried to run a command that produced an error. error_extra_info: {str: json-serializable}, A json serializable dict of extra info that we want to log with the error. This enables us to write queries that can understand the keys and values in this dict. r7N)rnrrsrr) command_pathrrr9rs r(rrs+ !,#J/ e $./?@ Br+c$[[X5 g)zLogs that help for a gcloud command was run. Args: command_path: str, The '.' separated name of the calliope command. mode: str, The way help was invoked (-h, --help, help). N)rnr)rmodes r(rrs!Dr+c \[[U[U5[U5[ U5S9 g)aLogs that a top level Exception was caught for a gcloud command. Args: command_path: str, The '.' separated name of the calliope command. error: class, The class (not the instance) of the exception that was caught. flag_names: [str], The names of the flags that were used during this execution. error_extra_info: {str: json-serializable}, A json serializable dict of extra info that we want to log with the error. This enables us to write queries that can understand the keys and values in this dict. )rrN)rnrrrsr)rr9rrs r(rrs+!|%6u%=#J/./?@Br+c$[[X5 g)zLogs that a top level SDK script was run. Args: command_name: str, The script name. version_string: str, The version of the command. N)rnr) command_namers r(rrs!L:r+c&[[XU5 g)zRecord a custom key/value metric for a given command. Args: command_path: str, The '.' separated name of the calliope command. key: str, The key recorded for the event. value: str. The value recorded for the event. N)rnr)rrr&s r(CustomKeyValuers!!1 ,,.) K8<> ""$r+c[R5nU(a%UR5 UR[SS9 gg)z3Record the time when command running was completed.TrN)rr r*r. _RUN_EVENTrs r(Ranrs> ,,.) ""$ J8<>r+c^[R5nU(aURU5 gg)zRecord the time when a custom event was completed. Args: event_name: The name of the event. This must match the pattern "[a-zA-Z0-9_]+". N)rr r.)rrms r(CustomTimedEventrs( ,,.) z*r+c#F# [US-5 Sv [U5 g7f)zRecord duration of a span of time. Two timestamps will be sent, and the duration in between will be considered as the client side latency of this span. Args: span_name: str, The name of the span to time. Yields: None _startN)r) span_names r(RecordDurationr+s9x'(9s!cp[R5nU(aUR[U55 gg)zoRecord the time taken to perform an RPC. Args: duration_in_secs: float, The duration of the RPC in seconds. N)rr r1r`)duration_in_secsrms r( RPCDurationr=s. ,,.)  .> ?@r+c`[R5nU(aURXX#5 ggr@)rr r;)rArBrCrrms r( CustomBeaconrIs* ,,.) T;r+r!)rNNN)rsNNNrg)rs)OrZ __future__rrr contextlibrrrKrLr;rYrXrIr^googlecloudsdk.corerrrr googlecloudsdk.core.consoler r googlecloudsdk.core.utilr r rsix.moves.urllib.errorsix.moves.urllib.parsesix.moves.urllib.requestrrrrrrlrrrrrrrrrrobjectrr4r`rCrhrprrrnrsr|rrrrrrrrrrrrrrrrrcontextmanagerrrrr2r+r(rsn -&'    &/#*42-.  #,      6/'VM6M.75"#&#0F0fQ7vQ7hJ7J7\26&*N:&1  $  88@D*.BB,EEBB&::MM 6 6%%>> + + "AA <