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:
4.3.1.2-4.3 ▾
|
python3-tvault-contego
/
usr
/
lib
/
python3.6
/
site-packages
/
contego
/
objects
/
__pycache__
/
service.cpython-36.pyc
|
|---|
3
ÒƜ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 ejeZejZd 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_rpcz1.0c @ s$ e Zd ZdZi ZdZdZdd ZdS )ÚServicez1.0Fg ð?c O s d|krt jdddt| _d S )Nr
ÚinitzVersion field is immutable)ÚactionÚreason)r ÚObjectActionErrorÚSERVICE_VERSIONr
)ÚselfÚargsÚkwargs© r ú /usr/lib/python3.6/service.pyÚ__init__* s
zService.__init__N)Ú__name__Ú
__module__Ú __qualname__ÚVERSIONÚ_MIN_VERSION_CACHEÚ_SERVICE_VERSION_CACHINGr r r r r r r s
r c s² e Zd ZdZejddej ejddejddejddej ej ejddejddej dej
ddej ej 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 z1.0T)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 s2 d|krt jdddtt| j|| t| _d S )Nr
r
zVersion field is immutable)r r )r r Úsuperr r r r
)r r r )Ú __class__r r r L s
zService.__init__c s t t| j||| tj|}|d k r4d|kr4|d= |d k rJd|krJ|d= |d
k r`d|kr`|d= |dk rvd |krv|d = |dk r| j| j|| d S )Né é r é r
é r) é
r( é
)r, r- )r, r. )r, r/ )r, r0 )r, r1 )r* r Ú!obj_make_compatible_from_manifestr Zconvert_version_to_tupleÚ_do_compute_nodeÚ_context)r Ú primitiveÚtarget_versionÚversion_manifestZ_target_version)r+ r r r2 ^ s
z)Service.obj_make_compatible_from_manifestc C sN y"|d }t jj||d d }W n tk
r6 d S X |j||d|d< d S )Nr r! r )r6 r7 r' )ÚobjectsÚComputeNodeListÚget_all_by_hostÚ ExceptionZobj_to_primitive)r Úcontextr5 r7 r6 Zcomputer r r r3 q s zService._do_compute_nodec C s d}xp|j D ]f}||kr"||kr"q |dkr.q q |dkrNt|tj||| q |dkrf|j| rfq q || ||< q W | |_|j |S )Nr& r' r
r )r& )r Úsetattrr Z get_attrnameÚgetr4 Zobj_reset_changes)r< r Ú
db_serviceZ
allow_missingÚkeyr r r Ú_from_db_object s zService._from_db_objectc C s | j stjd| j dtjd|| j | jd |dkrLtjdd| d| jdkrjt j
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-loadable)r r ztvault-contego)Ú
service_idr )r4 r ZOrphanedObjectErrorZobj_nameÚLOGÚdebugr r r" r8 r9 r: r! ZServiceNotFoundr' )r ZattrnameZ
compute_nodesr r r rB s
zService.obj_load_attrc C s t j||}| j|| |S )N)r Z service_getrA )Úclsr< rF r? r r r Ú get_by_id° s zService.get_by_idc C s t j||}| j|| |S )N)r Zservice_get_by_uuidrA )rI r< Z service_uuidr? r r r Ú get_by_uuidµ s zService.get_by_uuidc C s t j|||}| j|| |S )N)r Z service_get_by_host_and_topicrA )rI r< r! r# r? r r r Úget_by_host_and_topicº s z Service.get_by_host_and_topicc C s: yt j|||}W n tjk
r( d S X | j|| |S )N)r Ú service_get_by_host_and_binaryr ZHostBinaryNotFoundrA )rI r< r! r" r? r r r Úget_by_host_and_binary¿ s z Service.get_by_host_and_binaryc C s t j| |S )N)r Zservice_get_by_compute_host)r< r! Ú use_slaver r r Ú _db_service_get_by_compute_hostÈ s z'Service._db_service_get_by_compute_hostc C s | j |||d}| j|| |S )N)rO )rP rA )rI r< r! rO r? r r r Úget_by_compute_hostÍ s zService.get_by_compute_hostc C s t j|||}| j|| |S )N)r rM rA )rI r< r! r" r? r r r Ú get_by_argsÓ s zService.get_by_argsc C sn | j drtjddd| j }d|kr>tj |d< |d | _tj| j |}| j
| j | | | j t j
j d S )Nr Úcreatezalready created)r r r )Zobj_attr_is_setr r Úobj_get_changesr Z
generate_uuidr r Zservice_creater4 rA Ú_send_notificationr ÚNotificationActionZCREATE)r Úupdatesr? r r r rS Ø s
zService.createc C sD | j }|jdd tj| j| j|}| j| j| | | j| d S )Nr )rT Úpopr Zservice_updater4 r rA Ú _send_status_update_notification)r rW r? r r r Úsaveç s
z Service.savec C s* t |j jdddhr&| jtjj d S )Nr$ r% r) )ÚsetÚkeysÚ intersectionrU r rV ZUPDATE)r rW r r r rY ð s z(Service._send_status_update_notificationc C s> t j| }t jtjj| tjd|dtjj |dj
| j d S )Nr )Úobjectr )Z publisherZ
event_typeZpriorityÚpayload) Úservice_notificationZServiceStatusPayloadZServiceStatusNotificationÚ notificationZNotificationPublisherZfrom_service_objZ EventTyper ZNotificationPriorityÚINFOÚemitr4 )r r r_ r r r rU õ s
zService._send_notificationc C s" t j| j| j | jtjj d S )N)r Zservice_destroyr4 r rU r rV ZDELETE)r r r r Údestroy s zService.destroyc C s | j d| _d S )NT)Úclear_min_version_cacher )rI r r r Úenable_min_version_cache s z Service.enable_min_version_cachec C s
i | _ d S )N)r )rI r r r re
s z Service.clear_min_version_cachec C s t j| |S )N)r Zservice_get_minimum_version)r< ÚbinariesrO r r r Ú _db_service_get_minimum_version s z'Service._db_service_get_minimum_versionc s j s t fdd|D rR j|||d}|rddd |j D } jj| n fdd|D }|rvt|j }nd}t|}|S )Nc 3 s | ]}| j kV qd S )N)r )Ú.0r" )rI r r ú <genexpr> s z4Service.get_minimum_version_multi.<locals>.<genexpr>)rO c S s i | ]\}}|pd |qS )r r )ri r" r
r r r ú
<dictcomp> s z5Service.get_minimum_version_multi.<locals>.<dictcomp>c s i | ]} j | |qS r )r )ri r" )rI r r rk ! s r ) r Úanyrh Úitemsr ÚupdateÚminÚvaluesÚint)rI r< rg rO Z min_versionsr
r )rI r Úget_minimum_version_multi s
z!Service.get_minimum_version_multic C s | j ||g|dS )N)rO )rr )rI r< r" rO 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 r2 r3 Ú staticmethodrA rB r Úremotable_classmethodrJ rK rL rN r Zselect_db_reader_moderP rQ rR Z remotablerS rZ rY rU rd Ú classmethodrf re rh rr rs Ú
__classcell__r r )r+ r r 4 sZ
c @ sh e Zd ZdZdejdiZejdd ZejdddZ ejd d
Z
ejdd d
Z ejdd Z d S )Ú ServiceListz1.0r8 r c C s" t j||}tj|| |tj|S )N)r Zservice_get_all_by_topicr Ú
obj_make_listr8 r )rI r< r# Ú db_servicesr r r Ú get_by_topic> s zServiceList.get_by_topicFc C s& t j|||d}tj|| |tj|S )N)Úinclude_disabled)r Zservice_get_all_by_binaryr ry r8 r )rI r< r" r| rz r r r Ú
get_by_binaryD s zServiceList.get_by_binaryc C s" t j||}tj|| |tj|S )N)r Zservice_get_all_by_hostr ry r8 r )rI r< r! rz r r r Ú get_by_hostK s zServiceList.get_by_hostNc C s4 t j||d}|r tj||}tj|| |tj|S )N)r$ )r Zservice_get_allZavailability_zonesZset_availability_zonesr ry r8 r )rI r< r$ Z set_zonesrz r r r Úget_allQ s zServiceList.get_allc C s& t j||dd}tj|| |tj|S )NF)r| )r Z#service_get_all_computes_by_hv_typer ry r8 r )rI r< Zhv_typerz 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 ru r{ r} r~ r r r r r r rx 5 s rx N)!Zoslo_logr ZloggingZ
oslo_utilsr r Zcontegor Z contego.i18nr Zcontego.objectsr r r r
Z contego.notifications.objectsra r r` Z getLoggerr rG Zversion_stringr ZSERVICE_VERSION_HISTORYr ZContegoObjectRegistryÚregisterZContegoPersistentObjectZ
ContegoObjectZContegoObjectDictCompatZObjectListBaserx r r r r Ú<module> s*