o
    `jC                     @   s(   d dl Z d dlmZ G dd deZdS )    N)AbstractSampledStatc                       s4   e Zd ZdZdZ fddZdd Zdd Z  ZS )	Minz;An AbstractSampledStat that gives the min over its samples.)_initial_value_samples_currentc                    s   t  ttj d S N)super__init__floatsysmaxsize)self	__class__ Z/home/djax/ivt_ai_plugin/venv/lib/python3.10/site-packages/kafka/metrics/stats/min_stat.pyr	   
   s   zMin.__init__c                 C   s   t |j||_d S r   )minvalue)r   sampleconfigr   nowr   r   r   update   s   z
Min.updatec                 C   s$   |st tjS t tdd |D S )Nc                 s   s    | ]}|j V  qd S r   )r   ).0r   r   r   r   	<genexpr>   s    zMin.combine.<locals>.<genexpr>)r
   r   r   r   )r   samplesr   r   r   r   r   combine   s   
zMin.combine)	__name__
__module____qualname____doc__	__slots__r	   r   r   __classcell__r   r   r   r   r      s    r   )r    kafka.metrics.stats.sampled_statr   r   r   r   r   r   <module>   s    