Why Gemfury?
Push, build, and install
RubyGems
npm packages
Python packages
Maven artifacts
PHP packages
Go Modules
Debian packages
RPM packages
NuGet packages
Repository URL to install this package:
|
Version:
5.2.7-5.2 ▾
|
python3-tvault-contego-el9
/
usr
/
lib
/
python3.9
/
site-packages
/
contego
/
objects
/
__pycache__
/
service.cpython-39.pyc
|
|---|
a
)^eà5 ã @ sð d dl mZ d dlmZ d dlmZ d dlmZ d dlm Z d dl
m Z d dl
m Z d dlm
Z
d d lmZ d dlm Z d d
lmZ e e¡ZejZd d ifZG d
d dZe jjG dd de j e j e j Ze jjG dd de j e j Z dS )é )Úlog)Ú versionutils)Ú uuidutils)Ú exception)Ú_LW)Úbase)Úfields)Údb)Úversion)ÚserviceZ contego_rpcú1.0c @ s$ e Zd ZdZi ZdZdZdd ZdS )ÚServicer Fg ð?c O s d|v rt jdddt| _d S ©Nr
ÚinitzVersion field is immutable©ÚactionÚreason)r ÚObjectActionErrorÚSERVICE_VERSIONr
©ÚselfÚargsÚkwargs© r ú;/usr/lib/python3.9/site-packages/contego/objects/service.pyÚ__init__* s þúService.__init__N)Ú__name__Ú
__module__Ú __qualname__ÚVERSIONÚ_MIN_VERSION_CACHEÚ_SERVICE_VERSION_CACHINGr r r r r r r
s
r
c s² e Zd ZdZejdde ¡ ejddejddejdde ¡ e ¡ ejddejdde d¡ej
dde ¡ e ¡ d
Zi Z dZ fdd Z
fd
d Zd d
Zedd Zdd Zejdd Zejdd Zejdd Zejdd Zeejd4ddZejd5d d Z ejd d Z ej d d! Z ej d"d# Z d$d% Z!d&d' Z"ej d(d) Z#e$d*d+ Z%e$d,d- Z&eejd6d.d/Z'ejd7d0d1Z(ejd8d2d3Z) Z*S )9r
r T)Z read_only)ZnullableÚ ComputeNode)
ÚidÚuuidÚhostÚbinaryÚtopicZ report_countÚdisabledÚdisabled_reasonÚavailability_zoneÚ compute_nodeÚ last_seen_upÚ forced_downr
Fc s6 d|v rt jdddtt| j|i |¤ t| _d S r )r r Úsuperr
r r r
r ©Ú __class__r r r L s
þr c s t t| |||¡ t |¡}|dk r4d|v r4|d= |dk rJd|v rJ|d= |dk r`d|v r`|d= |dk rvd|v rv|d= |d k r| | j||¡ d S )
N)é é r% )r2 é r
)r2 é r. )r2 é
r- )r2 é
)r/ r
Ú!obj_make_compatible_from_manifestr Zconvert_version_to_tupleÚ_do_compute_nodeÚ_context)r Ú primitiveÚtarget_versionÚversion_manifestZ_target_versionr0 r r r8 ^ s
ÿ
ÿz)Service.obj_make_compatible_from_manifestc C sN z"|d }t j ||d ¡d }W n ty6 Y d S 0 |j||d|d< d S )Nr# r& r )r< r= r, )ÚobjectsÚComputeNodeListÚget_all_by_hostÚ ExceptionZobj_to_primitive)r Úcontextr; r= r< Zcomputer r r r9 q s ÿÿ þzService._do_compute_nodec C s d}|j D ]d}||v r ||vr q
|dkr,q
q
|dkrLt|t |¡|| q
|dkrb| |¡sbq
q
|| ||< q
| |_| ¡ |S )N)r+ r, r
r% )r Úsetattrr Z get_attrnameÚgetr: Zobj_reset_changes)rB r Ú
db_serviceZ
allow_missingÚkeyr r r Ú_from_db_object s
zService._from_db_objectc C s | j stjd| ¡ dt d|| ¡ | jd¡ |dkrLtjdd| d| jdkrjt j
| j | j ¡}ntj
| jd |d
| _d S ) NÚ
obj_load_attr)ÚmethodZobjtypez-Lazy-loading '%(attr)s' on %(name)s id %(id)s)ÚattrÚnamer$ r, z attribute %s not lazy-loadabler ztvault-contego)Ú
service_idr )r: r ZOrphanedObjectErrorZobj_nameÚLOGÚdebugr$ r r' r> r? r@ r& ZServiceNotFoundr, )r ÚattrnameZ
compute_nodesr r r rH s* ÿþÿþ
ÿzService.obj_load_attrc C s t ||¡}| || |¡S ©N)r Z service_getrG )ÚclsrB rL rE r r r Ú get_by_id° s zService.get_by_idc C s t ||¡}| || |¡S rP )r Zservice_get_by_uuidrG )rQ rB Z service_uuidrE r r r Ú get_by_uuidµ s zService.get_by_uuidc C s t |||¡}| || |¡S rP )r Z service_get_by_host_and_topicrG )rQ rB r& r( rE r r r Úget_by_host_and_topicº s z Service.get_by_host_and_topicc C s: zt |||¡}W n tjy( Y d S 0 | || |¡S rP )r Ú service_get_by_host_and_binaryr ZHostBinaryNotFoundrG ©rQ rB r& r' rE r r r Úget_by_host_and_binary¿ s ÿz Service.get_by_host_and_binaryc C s t | |¡S rP )r Zservice_get_by_compute_host)rB r& Ú use_slaver r r Ú _db_service_get_by_compute_hostÈ s z'Service._db_service_get_by_compute_hostc C s | j |||d}| || |¡S ©N©rX )rY rG )rQ rB r& rX rE r r r Úget_by_compute_hostÍ s ÿzService.get_by_compute_hostc C s t |||¡}| || |¡S rP )r rU rG rV r r r Ú get_by_argsÓ s zService.get_by_argsc C sn | d¡rtjddd| ¡ }d|vr>t ¡ |d< |d | _t | j |¡}|
| j | |¡ | t j
j¡ d S )Nr$ Úcreatezalready createdr r% )Zobj_attr_is_setr r Úobj_get_changesr Z
generate_uuidr% r Zservice_creater: rG Ú_send_notificationr ÚNotificationActionZCREATE©r ÚupdatesrE r r r r^ Ø s
ÿ
zService.createc C sD | ¡ }| dd ¡ t | j| j|¡}| | j| |¡ | |¡ d S )Nr$ )r_ Úpopr Zservice_updater: r$ rG Ú _send_status_update_notificationrb r r r Úsaveç s
z Service.savec C s( t | ¡ h d£¡r$| tjj¡ d S )N> r* r) r. )ÚsetÚkeysÚ intersectionr` r ra ZUPDATE)r rc r r r re ð s ÿz(Service._send_status_update_notificationc C s> t | ¡}t jtj | ¡tjd|dtjj |d
| j ¡ d S )Nr )Úobjectr )Z publisherZ
event_typeÚpriorityÚpayload) Úservice_notificationZServiceStatusPayloadZServiceStatusNotificationÚ notificationZNotificationPublisherZfrom_service_objZ EventTyper ZNotificationPriorityÚINFOÚemitr: )r r rl r r r r` õ s
ÿþùùzService._send_notificationc C s" t | j| j¡ | tjj¡ d S rP )r Zservice_destroyr: r$ r` r ra ZDELETE)r r r r Údestroy s zService.destroyc C s | ¡ d| _d S )NT)Úclear_min_version_cacher" ©rQ r r r Úenable_min_version_cache s z Service.enable_min_version_cachec C s
i | _ d S rP ©r! rs r r r rr
s z Service.clear_min_version_cachec C s t | |¡S rP )r Zservice_get_minimum_version)rB ÚbinariesrX r r r Ú _db_service_get_minimum_version s z'Service._db_service_get_minimum_versionc s j r t fdd|D rP j|||d}|rbdd | ¡ D } j |¡ n fdd|D }|rtt| ¡ }nd}t|}|S )Nc 3 s | ]}| j vV qd S rP ru ©Ú.0r' rs r r Ú <genexpr> s ÿz4Service.get_minimum_version_multi.<locals>.<genexpr>r[ c S s i | ]\}}||pd qS )r r )ry r' r
r r r Ú
<dictcomp> s ÿz5Service.get_minimum_version_multi.<locals>.<dictcomp>c s i | ]}| j | qS r ru rx rs r r r{ ! s ÿr ) r" Úanyrw Úitemsr! ÚupdateÚminÚvaluesÚint)rQ rB rv rX Z min_versionsr
r rs r Úget_minimum_version_multi s* ÿÿÿþ
ÿz!Service.get_minimum_version_multic C s | j ||g|dS rZ )r )rQ rB r' rX r r r Úget_minimum_version. s
ÿzService.get_minimum_version)F)F)F)F)F)+r r r r r Z IntegerFieldZ UUIDFieldZ StringFieldZ BooleanFieldZ ObjectFieldZ
DateTimeFieldr! r" r r8 r9 Ú staticmethodrG rH r Úremotable_classmethodrR rS rT rW r Zselect_db_reader_moderY r\ r] Z remotabler^ rf re r` rq Ú classmethodrt rr rw r r Ú
__classcell__r r r0 r r
4 sr
ó
c @ sh e Zd ZdZde d¡iZejdd ZejdddZ ejd d
Z
ejdd d
Z ejdd Z d S )Ú ServiceListr r> r
c C s" t ||¡}t || |tj|¡S rP )r Zservice_get_all_by_topicr Ú
obj_make_listr> r
)rQ rB r( Ú db_servicesr r r Ú get_by_topic> s ÿzServiceList.get_by_topicFc C s& t j|||d}t || |tj|¡S )N©Úinclude_disabled)r Zservice_get_all_by_binaryr r r> r
)rQ rB r' r r r r r Ú
get_by_binaryD s ÿÿzServiceList.get_by_binaryc C s" t ||¡}t || |tj|¡S rP )r Zservice_get_all_by_hostr r r> r
)rQ rB r& r r r r Ú get_by_hostK s ÿzServiceList.get_by_hostNc C s4 t j||d}|r t ||¡}t || |tj|¡S )N)r) )r Zservice_get_allZavailability_zonesZset_availability_zonesr r r> r
)rQ rB r) Z set_zonesr r r r Úget_allQ s ÿÿzServiceList.get_allc C s& t j||dd}t || |tj|¡S )NFr )r Z#service_get_all_computes_by_hv_typer r r> r
)rQ rB Zhv_typer r r r Úget_all_computes_by_hv_typeZ s ÿÿz'ServiceList.get_all_computes_by_hv_type)F)NF)
r r r r r ZListOfObjectsFieldr r
r r r r r r r r r r 5 s
ÿ
r N)!Zoslo_logr ZloggingZ
oslo_utilsr r Zcontegor Z contego.i18nr Zcontego.objectsr r r r
Z contego.notifications.objectsrn r rm Z getLoggerr rM Zversion_stringr ZSERVICE_VERSION_HISTORYr
ZContegoObjectRegistryÚregisterZContegoPersistentObjectZ
ContegoObjectZContegoObjectDictCompatZObjectListBaser r r r r Ú<module> s.
þÿ