a
    $Fwj                     @  sz   d dl mZ d dlmZmZ d dlmZ d dlmZ eddG dd dZeG d	d
 d
Z	eddG dd dZ
dS )    )annotations)	dataclassfield)datetime)AnyT)frozenc                   @  sZ   e Zd ZU ded< ded< ded< ded< ded< d	Zd
ed< d	Zd
ed< dZded< d	S )TickstrsymbolmarketfloatpriceZvolumer   	timestampNfloat | NonebidaskUNKNOWNsource)__name__
__module____qualname____annotations__r   r   r    r   r   8/home/opc/hanz-radar/runtime/src/hanz_realtime/models.pyr      s   
r   c                   @  s   e Zd ZU ded< ded< dZded< dZded	< dZd
ed< dZded< dZded< dZ	ded< dZ
ded< dZded< dZded< eedZded< eedZded< dS )SymbolStater	   r
   r   Nr   
last_priceg        r   last_volumezdatetime | Nonelast_timestampr   int
tick_countcumulative_volumeprice_change_pct
spread_pctvelocityanomaly_score)default_factoryzset[str]dirty_flagszdict[str, Any]metadata)r   r   r   r   r   r   r   r   r    r!   r"   r#   r$   r   setr&   dictr'   r   r   r   r   r      s   
r   c                   @  s6   e Zd ZU ded< ded< ded< ded< ded< d	S )
	QueueItemr	   r
   r   r   Zscorereasonr   
updated_atN)r   r   r   r   r   r   r   r   r*   %   s
   
r*   N)
__future__r   dataclassesr   r   r   typingr   r   r   r*   r   r   r   r   <module>   s   