fj pdZddlZddlZddlmZddlmZddlm Z ddl m Z ddl m Z Gd d ZdS) zG This module contains basic part of continuous tracingg implementation N)List)gettext)continuous_storage) XRayErrorContinuousTaskcdeZdZdZdZdefdZdeefdZ deefdZ de ddfd Z dS) ContinuousCommonz+ Base class for continuous tracing ct|_tjd|_||_dS)N continuous)rstoragelogging getLoggerloggerload_tracing_configuration tracing_confselfs M/opt/cloudlinux/venv/lib64/python3.11/site-packages/xray/continuous/common.py__init__zContinuousCommon.__init__s5) ' 55  ;;==returnc|jd tj|j5fdDcdddS#1swxYwYdS#t $rC}|jddt|itcYd}~Sd}~wwxYw)zS Load full continuous tracing configuration from the local storage z(Loading continuous tracing configurationc"i|] }|| Sr.0itemdbs r z?ContinuousCommon.load_tracing_configuration..'s===4bh===rNz/Failed to load continuous tracing configurationerrextra) rinfoshelveopenrkeysOSErrorerrorstrdict)rer s @rrz+ContinuousCommon.load_tracing_configuration s CDDD T\** >b====27799=== > > > > > > > > > > > > > > > > > >    K  Ac!ffo  ' ' '66MMMMMM  s@A0 A# A0#A''A0*A'+A00 B=:8B82B=8B=cbtd|jDS)zC Return existing configuration in the form of list c&h|]}tdi|S)rr)rrs r z8ContinuousCommon.get_continuous_tasks..3s& K K K^ # #d # # K K Kr)sortedrvaluesrs rget_continuous_tasksz%ContinuousCommon.get_continuous_tasks.s9 K K0A0H0H0J0J K K KMM Mrc\ tj|j5|jD]}|j||<fdDcdddS#1swxYwYdS#t $r1}t tdt|zd}~wwxYw)zJ Dump continuous tracing configuration into local storage c g|] }| Srrrs r z?ContinuousCommon.dump_tracing_configuration..=s777T4777rNz+Failed to dump continuous configuration: %s) r&r'rrr(r)r_r+)rrr-r s @rdump_tracing_configurationz+ContinuousCommon.dump_tracing_configuration5s KT\** 8b -77D#06BtHH7777RWWYY777 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 K K K?@@3q66IKK K Ks:A0:A# A0#A''A0*A'+A00 B+:,B&&B+domainNc  |j|=tj|j5}||=ddddS#1swxYwYdS#t$rD|jd||jdttd|zt$rB}ttd |t|d}~wwxYw)zD Remove continuous tracing configuration for domain Nz$Continuous monitoring is not enabled)r9tracing_entriesr#z+Continuous monitoring for %s is not enabledz4Failed to remove continuous configuration for {}: {}) rr&r'rKeyErrorrr*rr7r)formatr+)rr9r r-s rremove_tracing_configurationz-ContinuousCommon.remove_tracing_configurationBsc b!&)T\** bvJ                   K K K K  D/58<8I%K%K  L L L?@@6IKK K b b bHOOPVX[\]X^X^__``bb b bs3!A4 A8A8AAC=CC) __name__ __module__ __qualname____doc__rr,rrr r3r8r+r>rrrr r s>>> D    Md>&:MMMM KDJ K K K Kb3b4bbbbbbrr )rBrr&typingrxrayrr7internal.constantsrinternal.exceptionsrinternal.typesr r rrrrHs 333333++++++++++++<b<b<b<b<b<b<b<b<b<br