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.2.64-4.2 ▾
|
python3-tvault-contego
/
usr
/
lib
/
python3.6
/
site-packages
/
contego
/
__pycache__
/
rpc.cpython-36.pyc
|
|---|
3
nS
bm* ã @ s d ddddddddd d
g Z d d lZd d
lmZ d d lZd dlmZ d dl m
Z
d dl m Z d d l
Zd d lZd dlmZ ejjZejeZd ad ad ad aejjgZ g Z ddddZ dd Z d dl m!Z! dd Z"dd Z#dd Z$d d Z%d d Z&d d Z'G d d d ej(Z)G d!d dej*Z+d3d"d#Z,d4d$dZ-d5d%dZ.d6d&d Z/d'd( Z0d)d* Z1G d+d, d,e2Z3G d-d. d.e2Z4G d/d0 d0e
j5Z6d1d2 Z7d S )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 j| d S )N)Ú messagingZset_transport_defaults)Zcontrol_exchange© r ú/usr/lib/python3.6/rpc.pyr 2 s )Úcfgc C s. t jddddgddddg}|}| j| d S )NÚnotification_formatÚ unversionedÚ versionedÚbothZDEFAULTÚ )Ú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.
c C sT t d k s ttd k sttd k s$ttd k s0tt j tj d a a aad S )N)r# ÚAssertionErrorr$ r& r' r r r r r r b s c G s t j| d S )N)Ú EXTRA_EXMODSÚextend)Úargsr r r r p s c C s t d d
= d S )N)r* r r r r r t s c C s t t S )N)ÚALLOWED_EXMODSr* r r r r r x s 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__Ú staticmethodr0 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 )N)Ú_base)ÚselfÚbaser r r Ú__init__ s z!RequestContextSerializer.__init__c C s | j s
|S | j j||S )N)r5 r0 )r6 r. r/ r r r r0 s z)RequestContextSerializer.serialize_entityc C s | j s
|S | j j||S )N)r5 Údeserialize_entity)r6 r. r/ r r r r9 s z+RequestContextSerializer.deserialize_entityc C s |j S )N)Zto_dict)r6 r. r r r Úserialize_context s z*RequestContextSerializer.serialize_contextc C s t jjj|S )N)Úcontegor. ÚRequestContextZ from_dict)r6 r. r r r Údeserialize_context s z,RequestContextSerializer.deserialize_contextN)r1 r2 r3 r8 r0 r9 r: r= r r r r r s
c C s t jjt| tS )N)r Z TransportURLÚparseÚCONFr )Zurl_strr r r Úget_transport_url s r@ c C sJ t jj}t jjgg }tj||d}|d k s0tt|}tj || ||dS )N)r )Ú version_capr! )
r; r r? Ú exceptionr1 r r" r) r Ú RPCClient)ÚtargetrA r! r r( r# r r r r s c C s( t d k s tt|}tjt | |d|dS )NZeventlet)Úexecutorr! )r# r) r r Zget_rpc_server)rD Z endpointsr! r r r r © s c C s2 t d k s t|s"d| |p tjf }tt j|dS )Nz%s.%s)Ú publisher_id)r& r) r? ÚhostÚLegacyValidatingNotifierÚprepare)ZservicerG rF r r r r
³ s
c C s t d k s tt j| dS )N)rF )r' r) rI )rF r r r Úget_versioned_notifier» s rJ c C s t }tjt| |dS )N)Úurlr )r r r" r? )rK r( r r r Úcreate_transportÀ s rL c @ s: e Zd ZdZdZdgZedZdd Zdd Z d d
Z
d S ) rH 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. || _ x"dD ]}t| |tj| j| q W d S )NÚdebugÚinfoÚwarnÚerrorÚcritical)rM rN rO rP rQ )ÚnotifierÚsetattrÚ functoolsÚpartialÚ_notify)r6 rR Úpriorityr r r r8 Û s
z!LegacyValidatingNotifier.__init__c C s ddht |j kS )NrB r, )ÚsetÚkeys)r6 Úpayloadr r r Ú _is_wrap_exception_notificationá s z8LegacyValidatingNotifier._is_wrap_exception_notificationc C sZ || j krB| j| rB| jr0t| jd|i ntj| jd|i t| j|||| d S )NÚ
event_type) Ú'allowed_legacy_notification_event_typesr[ Úfatalr) ÚmessageÚLOGZwarningÚgetattrrR )r6 rW Zctxtr\ rZ r r r rV ê s
z LegacyValidatingNotifier._notifyN) r1 r2 r3 Ú__doc__r^ r] r r_ r8 r[ rV r r r r rH Ç s rH c @ s e Zd Zdd Zedd ZdS )Ú
ClientWrapperc C s || _ tj | _d S )N)Ú_clientr ÚutcnowÚlast_access_time)r6 Úclientr r r r8 ö s zClientWrapper.__init__c C s t j | _| jS )N)r re rf rd )r6 r r r rg ú s
zClientWrapper.clientN)r1 r2 r3 r8 Úpropertyrg r r r r rc õ s rc 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| jt i | _t|| jd< |j| _|j| _t|dd | _ | j
t j j
dd d S )Nr r! F)Z overwrite)Úsuperri r8 r? Úclientsrc rD rA ra r! Zrun_periodic_tasksr; r. r< )r6 Zdefault_client)Ú __class__r r r8 s zClientRouter.__init__Nc C sj |r |j }nd}y| j| j}W nD tk
rd t|j}tj|| j| j | j
d}t || j|< Y nX |S )Nr )rA r! ) Zuuidrk rg ÚKeyErrorrL Z
transport_urlr rC rD rA r! rc )r6 r. Z cell_mappingÚ client_idrg Z transportr r r rd s
zClientRouter._clientc sP d fdd}t | jj }x,|D ]$\}}|dkr$|||jr$| j|= q$W d S )Né< c s" t j| r tjd| | dS dS )Nz;Removing stale RPC client: %s as it was last accessed at %sTF)r Z
is_older_thanr` rM )rn rf )Útimeoutr r Ústale& s
z1ClientRouter._remove_stale_clients.<locals>.staler )Úlistrk Úitemsrf )r6 r. rq Z
items_copyrn Zclient_wrapperr )rp r Ú_remove_stale_clients" s z"ClientRouter._remove_stale_clients)N) r1 r2 r3 rb r8 rd r rt Ú
__classcell__r r )rl r ri s
ri c s t j fdd}|S )zCCalls decorated method only if versioned notifications are enabled.c s& t j r tjjdkr | |S d S d S )Nr r )r r )r' Z
is_enabledr? Z
notificationsr )r, Úkwargs)Úfr r Úwrapped7 s
z)if_notifications_enabled.<locals>.wrapped)rT Úwraps)rw rx r )rw r Úif_notifications_enabled5 s rz )N)NN)N)NN)8Ú__all__rT Zoslo_logr
ZloggingZoslo_messagingr Zoslo_serializationr Z oslo_servicer Z
oslo_utilsr Z contego.confr; Zcontego.exceptionZ contego.i18nr r r? Z getLoggerr1 r` r# r& r$ r' rB r- r* r r Z oslo_configr r r r r r r ZNoOpSerializerr% Z
Serializerr r@ r r r
rJ rL ÚobjectrH rc Z
PeriodicTasksri rz r r r r Ú<module> sd
. 5