
    ji                         d dl  d dlmZmZmZmZ  edddd      Z edd	dd      Z ed
ddd      Z edddd      Z	 G d de      Z
 eddd      d        Zy)    )*)CmfMetricCounterCmfMetricGaugeCmfMetricSummaryCmfMetricRealtimeCollectorpool_open_connectionsu@   Количество запущенных подключенийredisT)namehelpmodule_nameadd_worker_tagpool_in_use_connectionsuD   Количество используемых подключенийpool_max_connectionsu!   Лимит подключенийopen_connectionsuU   Количество подключений (установок соединения)c                   ,    e Zd ZdZdZdZdZed        Zy)CmfRedisStatCollectorun   
    Сохраняем данные о количестве и свойствах подключения
       c                     t         j                  rt         j                  j                  sy t        j	                  t         j                  j                  j
                  j                         t        j	                  t         j                  j                  j
                  j                         t        j	                  t        t         j                  j                  j
                  j                               y )N)APPREDIS_DBr	   r   writeconnection_poolmax_connectionsr   _created_connectionsr   len_in_use_connections     ./cmf/metrics/redis_metrics.pyrunzCmfRedisStatCollector.run,   s    ||3<<#5#5""3<<#5#5#E#E#U#UV##CLL$6$6$F$F$[$[\%%c#,,*<*<*L*L*`*`&abr   N)	__name__
__module____qualname____doc__interval_minstart_delay_hard_minutesstart_delay_soft_minutesstaticmethodr    r   r   r   r   r   $   s.     L  c cr   r   z@hourly)	only_once
system_jobschedulec                  &    t         j                  syy)uV   
    Аналитические метрики, запрошенные из Redis
    N)configMETRICS_REDIS_DBr   r   r   redis_metricsr/   5   s    
 "" #r   N)cmf.includecmf.util.metricsr   r   r   r   r   r   r   r   r   cmf_deferred_jobr/   r   r   r   <module>r3      s     k k '	 	K	  )	"	O	  &		,	  $		`	 c6 c" DTIF Gr   