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:
6.0.24.1.dev2-6.0 ▾
|
python3-tvault-contego
/
usr
/
lib
/
python3.9
/
site-packages
/
contego
/
__pycache__
/
rpc.cpython-39.pyc
|
|---|
a
ÑՉgù* ã @ s g d ¢Z ddlZddlmZ ddlZddlmZ ddl m
Z
ddl m Z ddl
ZddlZddlmZ ejjZe e¡ZdadadadaejjgZ g Z dd d
d Z d d
Z ddl m!Z! dd Z"dd Z#dd Z$dd Z%dd Z&dd Z'G dd d ej(Z)G d d d ej*Z+d5d d Z,d6d!d"Z-d#d$ Z.d7d%d&Z/d8d'd(Z0d)d* Z1d+d, Z2G d-d. d.e3Z4G d/d0 d0e3Z5G d1d2 d2e
j6Z7d3d4 Z8dS )9) ÚinitÚcleanupÚ set_defaultsÚadd_extra_exmodsÚclear_extra_exmodsÚget_allowed_exmodsÚRequestContextSerializerÚ
get_clientÚ
get_serverÚ get_notifierÚTRANSPORT_ALIASESé N)Úlog)Ú jsonutils)Ú
periodic_task)Ú timeutils)Ú_ZrabbitZqpidZzmq)zcontego.rpc.impl_kombuzcontego.rpc.impl_qpidzcontego.rpc.impl_zmqc C s t | ¡ d S ©N)Ú messagingZset_transport_defaults)Zcontrol_exchange© r ú//usr/lib/python3.9/site-packages/contego/rpc.pyr 2 s r )Úcfgc C s, t jdg d¢ddddg}|}| |¡ d S )NÚnotification_format)Ú unversionedÚ versionedÚbothr ZDEFAULTÚ )ÚchoicesÚdefaultZdeprecated_groupÚhelp)r ZStrOptÚ
register_opts)ÚconfZnotification_optsZALL_OPTSr r r r 6 s ûÿ
r c C s° t | t }tj| |datj| |datt }| j dkr^tj
t|da tj
t|dda nN| j dkrtj
t|da tj
t|dgda n"tj
t|dda tj
t|dgda d S ) N©Úallowed_remote_exmodsr )Ú
serializerZnoop)r# Zdriverr Zversioned_notifications)r# Ztopics)
r r r Ú
get_transportÚ TRANSPORTZget_notification_transportÚNOTIFICATION_TRANSPORTr ÚJsonPayloadSerializerr ZNotifierÚLEGACY_NOTIFIERÚNOTIFIER)r Úexmodsr# r r r r E s< ÿ
ÿÿ
ÿþþþr c C sT t d us J td usJ td us$J td us0J t ¡ t ¡ d a a aad S r )r% r& r( r) r r r r r r b s r c G s t | ¡ d S r )Ú EXTRA_EXMODSÚextend)Úargsr r r r p s r c C s t d d
= d S r )r+ r r r r r t s r c C s t t S r )ÚALLOWED_EXMODSr+ r r r r r x s r c @ s e Zd Zedd ZdS )r' c C s t j|ddS )NT)Zconvert_instances)r Z to_primitive)ÚcontextÚentityr r r Úserialize_entity} s z&JsonPayloadSerializer.serialize_entityN)Ú__name__Ú
__module__Ú __qualname__Ú staticmethodr1 r r r r r' | s r' c @ s4 e Zd Zdd Zdd Zdd Zdd Zd d
Zd S ) r c C s
|| _ d S r )Ú_base)ÚselfÚbaser r r Ú__init__ s z!RequestContextSerializer.__init__c C s | j s
|S | j ||¡S r )r6 r1 ©r7 r/ r0 r r r r1 s z)RequestContextSerializer.serialize_entityc C s | j s
|S | j ||¡S r )r6 Údeserialize_entityr: r r r r; s z+RequestContextSerializer.deserialize_entityc C s | ¡ S r )Zto_dict©r7 r/ r r r Úserialize_context s z*RequestContextSerializer.serialize_contextc C s t jj |¡S r )Úcontegor/ ÚRequestContextZ from_dictr< r r r Údeserialize_context s z,RequestContextSerializer.deserialize_contextN)r2 r3 r4 r9 r1 r; r= r@ r r r r r s
r c C s t j t| t¡S r )r Z TransportURLÚparseÚCONFr )Zurl_strr r r Úget_transport_url s rC c C sJ t jj}t jjgg }tj||d}|d us0J t|}tj|| ||dS )Nr! ©Ú version_capr# ) r> r rB Ú exceptionr2 r r$ r Ú RPCClient)ÚtargetrE r# r r* r% r r r r s ýr c C s t jddd} t| }|S )NZdmapiz1.0)ZtopicÚversion)r ZTargetr )rH Úclientr r r Úget_dmapi_rpc_client© s rK c C s( t d us J t|}tjt | |d|dS )NZeventlet)Úexecutorr# )r% r r Zget_rpc_server)rH Z endpointsr# r r r r ¯ s ür c C s2 t d us J |s"d| |p tjf }tt j|dS )Nz%s.%s©Ú publisher_id)r( rB ÚhostÚLegacyValidatingNotifierÚprepare)ZservicerO rN r r r r
¹ s
ÿr
c C s t d us J t j| dS )NrM )r) rQ rM r r r Úget_versioned_notifierÁ s rR c C s t }tjt| |dS )N)Úurlr" )r r r$ rB )rS r* r r r Úcreate_transportÆ s
þrT c @ s: e Zd ZdZdZdgZedZdd Zdd Z d d
Z
d S ) rP zDWraps an oslo.messaging Notifier and checks for allowed event_types.Fzaggregate.addhost.endze%(event_type)s is not a versioned notification and not whitelisted. See ./doc/source/notification.rstc C s* || _ dD ]}t| |t | j|¡ q
d S )N)ÚdebugÚinfoÚwarnÚerrorZcritical)ÚnotifierÚsetattrÚ functoolsÚpartialÚ_notify)r7 rY Úpriorityr r r r9 á s
ÿz!LegacyValidatingNotifier.__init__c C s ddht | ¡ kS )NrF r- )ÚsetÚkeys)r7 Úpayloadr r r Ú _is_wrap_exception_notificationç s z8LegacyValidatingNotifier._is_wrap_exception_notificationc C sX || j vr@| |¡s@| jr.t| jd|i nt | jd|i¡ t| j|||| d S )NÚ
event_type) Ú'allowed_legacy_notification_event_typesrb ÚfatalÚAssertionErrorÚmessageÚLOGZwarningÚgetattrrY )r7 r^ Zctxtrc ra r r r r] ð s
ÿz LegacyValidatingNotifier._notifyN) r2 r3 r4 Ú__doc__re rd r rg r9 rb r] r r r r rP Í s ÿ rP c @ s e Zd Zdd Zedd ZdS )Ú
ClientWrapperc C s || _ t ¡ | _d S r )Ú_clientr ÚutcnowÚlast_access_time)r7 rJ r r r r9 ü s zClientWrapper.__init__c C s t ¡ | _| jS r )r rm rn rl )r7 r r r rJ s
zClientWrapper.clientN)r2 r3 r4 r9 ÚpropertyrJ r r r r rk û s rk c s8 e Zd ZdZ fddZd ddZejdd Z ZS )
Ú ClientRouterzËCreates and caches RPC clients that route to cells or the default.
The default client connects to the API cell message queue. The rest of the
clients connect to compute cell message queues.
c sZ t t| t¡ i | _t|| jd< |j| _|j| _t|dd | _ |
t j j
dd¡ d S )Nr r# F)Z overwrite)Úsuperrp r9 rB Úclientsrk rH rE ri r# Zrun_periodic_tasksr> r/ r? )r7 Zdefault_client©Ú __class__r r r9 s zClientRouter.__init__Nc C sh |r |j }nd}z| j| j}W nB tyb t|j}tj|| j| j | j
d}t || j|< Y n0 |S )Nr rD ) Zuuidrr rJ ÚKeyErrorrT Z
transport_urlr rG rH rE r# rk )r7 r/ Z cell_mappingÚ client_idrJ Z transportr r r rl s
þzClientRouter._clientc sL d fdd}t | j ¡ }|D ]$\}}|dkr"|||jr"| j|= q"d S )Né< c s" t | ¡r t d| |¡ dS dS )Nz;Removing stale RPC client: %s as it was last accessed at %sTF)r Z
is_older_thanrh rU )rv rn ©Útimeoutr r Ústale, s ÿz1ClientRouter._remove_stale_clients.<locals>.staler )Úlistrr Úitemsrn )r7 r/ rz Z
items_copyrv Zclient_wrapperr rx r Ú_remove_stale_clients( s
ÿz"ClientRouter._remove_stale_clients)N) r2 r3 r4 rj r9 rl r r} Ú
__classcell__r r rs r rp s
rp c s t ¡ fdd}|S )zCCalls decorated method only if versioned notifications are enabled.c s* t ¡ r"tjjdv r" | i |¤S d S d S )N)r r )r) Z
is_enabledrB Z
notificationsr )r- Úkwargs©Úfr r Úwrapped= s
ÿz)if_notifications_enabled.<locals>.wrapped)r[ Úwraps)r r r r r Úif_notifications_enabled; s r )N)NN)N)NN)9Ú__all__r[ Zoslo_logr
ZloggingZoslo_messagingr Zoslo_serializationr Z oslo_servicer Z
oslo_utilsr Z contego.confr> Zcontego.exceptionZ contego.i18nr r rB Z getLoggerr2 rh r% r( r& r) rF r. r+ r r Z oslo_configr r r r r r r ZNoOpSerializerr' Z
Serializerr rC r rK r r
rR rT ÚobjectrP rk Z
PeriodicTasksrp r r r r r Ú<module> sT
ý
. 5