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.8.15-5.2 ▾
|
python3-tvault-contego-el9
/
usr
/
lib
/
python3.9
/
site-packages
/
contego
/
__pycache__
/
rpc.cpython-39.opt-1.pyc
|
|---|
a
j;gm* ã @ 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+d3d d Z,d4d!d"Z-d5d#d$Z.d6d%d&Z/d'd( Z0d)d* Z1G d+d, d,e2Z3G d-d. d.e2Z4G d/d0 d0e
j5Z6d1d2 Z7dS )7) Ú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 s$ 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 s> t jj}t jjgg }tj||d}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 |}tjt| |d|dS )NZeventlet)Úexecutorr# )r r Zget_rpc_serverr% )rH Z endpointsr# r r r r © s ür c C s& |sd| |pt jf }ttj|dS )Nz%s.%s©Ú publisher_id)rB ÚhostÚLegacyValidatingNotifierr( Úprepare)ZservicerL rK r r r r
³ s
ÿr
c C s t j| dS )NrJ )r) rN rJ r r r Úget_versioned_notifier» s rO c C s t }tjt| |dS )N)Úurlr" )r r r$ rB )rP r* r r r Úcreate_transportÀ s
þrQ c @ s: e Zd ZdZdZdgZedZdd Zdd Z d d
Z
d S ) rM 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 rV Ú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_typesr_ ÚfatalÚAssertionErrorÚmessageÚLOGZwarningÚgetattrrV )r7 r[ Zctxtr` r^ r r r rZ ê s
ÿz LegacyValidatingNotifier._notifyN) r2 r3 r4 Ú__doc__rb ra r rd r9 r_ rZ r r r r rM Ç s ÿ rM c @ s e Zd Zdd Zedd ZdS )Ú
ClientWrapperc C s || _ t ¡ | _d S r )Ú_clientr ÚutcnowÚlast_access_time)r7 Úclientr r r r9 ö s zClientWrapper.__init__c C s t ¡ | _| jS r )r rj rk ri )r7 r r r rl ú s
zClientWrapper.clientN)r2 r3 r4 r9 Úpropertyrl r r r r rh õ s rh 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)Úsuperrn r9 rB Úclientsrh rH rE rf 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 ) Zuuidrp rl ÚKeyErrorrQ Z
transport_urlr rG rH rE r# rh )r7 r/ Z cell_mappingÚ client_idrl Z transportr r r ri 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_thanre rR )rt rk ©Útimeoutr r Ústale& s ÿz1ClientRouter._remove_stale_clients.<locals>.staler )Úlistrp Úitemsrk )r7 r/ rx Z
items_copyrt Zclient_wrapperr rv r Ú_remove_stale_clients" s
ÿz"ClientRouter._remove_stale_clients)N) r2 r3 r4 rg r9 ri r r{ Ú
__classcell__r r rq r rn s
rn 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 Úwrapped7 s
ÿz)if_notifications_enabled.<locals>.wrapped)rX Úwraps)r r r r~ r Úif_notifications_enabled5 s r )N)NN)N)NN)8Ú__all__rX Zoslo_logr
ZloggingZoslo_messagingr Zoslo_serializationr Z oslo_servicer Z
oslo_utilsr Z contego.confr> Zcontego.exceptionZ contego.i18nr r rB Z getLoggerr2 re r% r( r& r) rF r. r+ r r Z oslo_configr r r r r r r ZNoOpSerializerr' Z
Serializerr rC r r r
rO rQ ÚobjectrM rh Z
PeriodicTasksrn r r r r r Ú<module> sR
ý
. 5