Why Gemfury?
Push, build, and install
RubyGems
npm packages
Python packages
Maven artifacts
PHP packages
Go Modules
Debian packages
RPM packages
NuGet packages
triliodata-3-3
Repository URL to install this package:
|
Version:
3.3.42 ▾
|
python3-tvault-contego
/
usr
/
lib
/
python3
/
dist-packages
/
contego
/
nova
/
__pycache__
/
api.cpython-35.pyc
|
|---|
ì ]E6 ã & @ s» d Z d d l Z y d d l Z Wn! e k
rE d d l j Z Yn Xy d d l m Z Wn" e k
r~ d d l m Z Yn Xy d d l
Z Wn" e k
r³ d d l m Z Yn Xy d d l
m Z Wn" e k
rì d d l m Z Yn Xd d l m Z d d l m Z d d l m Z d d l m Z d g Z e j e Z e j Z e j d
d d d
d g Z e j e e j d d
d Z e j! e d Gd d d e j" Z# d S)z7Handles all requests relating to Contego functionality.é N)Úlog)Ú messaging)Úcfg)Úbase)Úinstance)Úrpcz
live-snapshotÚ
contego_topicÚdefaultZ contego_1Úhelpz!the topic Contego nodes listen onÚcontegoz7Set a version cap for messages sent to contego servicesÚcontego_upgrade_levelsc
sr e Z d Z d Z d d d d d d d d d d i Z d f d d
Z d d Z d
d Z d d Z d d d Z d i d d d d Z
d d Z d d Z d d Z
d d Z d d Z d! d" Z d# d$ Z d% d& Z d' d( Z d) d* Z d+ d, Z d- d. Z d/ d0 Z d1 d2 Z d3 d4 Z d5 d6 Z d7 d8 Z d9 d: Z S);ÚAPIz`Client side of the contego RPC API
API version history:
* 1.0 - Initial version.
Zgrizzlyz1.0ZhavanaZicehouseZjunoZkiloNc s t t | j | t | _ t j d t j d d } | j j t j
j t j
j } t j
} t j | d | d | | _ d S)NZtopicÚversionz1.0Ú version_capÚ
serializer)Úsuperr
Ú__init__Ú CAPABILITIESr ZTargetÚCONFr ÚVERSION_ALIASESÚgetr r Ú objects_baseZNovaObjectSerializerr Z
get_clientÚclient)ÚselfZ
image_serviceÚkwargsÚtargetr r )Ú __class__© ú2/usr/lib/python3/dist-packages/contego/nova/api.pyr E s z API.__init__c K s. | j j d | d d } | j | | | S)NÚserverr z1.0)r ÚprepareÚcall)r ÚcontextÚmethodÚhostr Úcctxtr r r r! Q s zAPI.callc K s. | j j d | d d } | j | | | S)Nr r z1.0)r r Úcast)r r" r# r$ r r% r r r r& U s zAPI.castc C s
d | j i S)NZ capabilities)r )r r r r Úget_infoY s z API.get_infoFc C sJ | r t j j | | } | S| j j | | } t t | j S)z3Get a single instance with the given instance_uuid.)Ú instance_objZInstanceZ get_by_uuidZdbZinstance_get_by_uuidÚdictÚiterÚitems)r r" Ú
instance_uuidZ want_objectr Úrvr r r r \ s zAPI.getip c C s© | s | d } | j j d | d d d | } | d k rS | j | | d | S| r | j | | d | d d
| d | S| j | | d | d d
| d | Sd S) a Generic handler for RPC casts/calls to contego topic.
This only blocks for a response with is_call=True.
:param params: Optional dictionary of arguments to be passed to the
contego worker
:returns: None
r$ r r z1.0ÚtimeoutNÚparamsr, ÚuuidZ instance_ref)r r r! r& ) r r# r" r r$ r/ Úis_callr. r% r r r Ú_send_contego_messagef s
zAPI._send_contego_messagec
C sO | j | | } t j d t | j d | | d | d d | d d S)z.
Prepare to VAST the instance
z prepare to vast the instanceÚ vast_preparer$ r/ r1 T)r ÚLOGÚdebugÚlocalsr2 )r r" r, r/ r r r r r3 s
zAPI.vast_preparec
C sO | j | | } t j d t | j d | | d | d d | d d S)z%
Freeze the instance
zfreeze the instanceÚ vast_freezer$ r/ r1 T)r r4 r5 r6 r2 )r r" r, r/ r r r r r7 s
zAPI.vast_freezec
C sO | j | | } t j d t | j d | | d | d d | d d S)z#
Thaw the instance
zthaw the instanceÚ vast_thawr$ r/ r1 T)r r4 r5 r6 r2 )r r" r, r/ r r r r r8 s
z
API.vast_thawc C sU | j | | } t j d t | j d | | d | d d | d d d d S) z#
VAST the instance
zvast the instanceÚ
vast_instancer$ r/ r1 Tr. ip )r r4 r5 r6 r2 )r r" r, r/ r r r r r9 s zAPI.vast_instancec
C sO | j | | } t j d t | j d | | d | d d | d d S)z6
Get details of a VASTed the instance
z get details of vasted instanceÚ
vast_get_infor$ r/ r1 T)r r4 r5 r6 r2 )r r" r, r/ r r r r r: © s
zAPI.vast_get_infoc
C sO | j | | } t j d t | j d | | d | d d | d d S)z2
Get URL for the vast data server
z$Get the URL for the vast data serverÚ
vast_data_urlr$ r/ r1 T)r r4 r5 r6 r2 )r r" r, r/ r r r r r; ³ s
zAPI.vast_data_urlc C sU | j | | } t j d t | j d | | d | d d | d d d d S) z'
Initiate data tranfer
zinitiate data tranferÚvast_data_transferr$ r/ r1 Tr. ip )r r4 r5 r6 r2 )r r" r, r/ r r r r r< ½ s zAPI.vast_data_transferc C sU | j | | } t j d t | j d | | d | d d | d d d d S) z;
Verify the existence of previous snapshot
zVerifying previous snapshotÚvast_check_prev_snapshotr$ r/ r1 Tr. ip )r r4 r5 r6 r2 )r r" r, r/ r r r r r= È s z API.vast_check_prev_snapshotc C s d | d k r- | d d } d | i } n | j | | } | d } t j d t | j d | | d | d | d d d d
S) zB
Get data transfer job status for the given token
r$ Úmetadatar0 z0Get data transfer job status for the given tokenÚvast_async_task_statusr/ r1 Tr. ip )r r4 r5 r6 r2 )r r" r, r/ r$ r r r r r? Ó s
zAPI.vast_async_task_statusc C sU | j | | } t j d t | j d | | d | d d | d d d d S) z
Finalize VAST
z"finalize the vast for the instanceÚ
vast_finalizer$ r/ r1 Tr. ip )r r4 r5 r6 r2 )r r" r, r/ r r r r r@ ä s
zAPI.vast_finalizec
C s[ | j | j d d | } t j d t | j d | | d | d d | d d S) zS
Reset the instance so other openstack operations can be unblocked
Z read_deletedÚyeszvast reset the instanceÚ
vast_resetr$ r/ r1 T)r Zelevatedr4 r5 r6 r2 )r r" r, r/ r r r r rB î s zAPI.vast_resetc
C sO | j | | } t j d t | j d | | d | d d | d d S)z'
Commit snapshot image
zCommiting snapshot imageÚvast_commit_imager$ r/ r1 T)r r4 r5 r6 r2 )r r" r, r/ r r r r rC ù s
zAPI.vast_commit_imagec C sU | j | | } t j d t | j d | | d | d d | d d d d S) zY
Map snapshot files to file manager instance identified by instance_uuid
z map snapshot files to instanceÚmap_snapshot_filesr$ r/ r1 Tr. ip )r r4 r5 r6 r2 )r r" r, r/ r r r r rD s zAPI.map_snapshot_filesc C sU | j | | } t j d t | j d | | d | d d | d d d d S) z-
Copy backup image to volume
z:Copy backup image to volume that is mapped to the instanceÚcopy_backup_image_to_volumer$ r/ r1 Tr. ip )r r4 r5 r6 r2 )r r" r, r/ r r r r rE s z API.copy_backup_image_to_volumec C s5 | d } | j d | d d | d | d d d d S) zC
Backup OpenStack configuration for given services
r$ Úvast_config_backupNr/ r1 Tr. ip )r2 )r r" Z backup_idr/ r$ r r r rF s
zAPI.vast_config_backupc C sR | d } | j | } | d | d <| j d | d d | d | d d d d S)
z7
Validate trusted user and private key
r$ Úcontroller_nodesÚ validate_trusted_user_and_keyNr/ r1 Tr. ip )Úget_controller_nodesr2 )r r" r/ r$ rG r r r rH ( s
z!API.validate_trusted_user_and_keyc s d d d d } y¸ g } t j d } t t d rn t t d d k rn | t j } | j | d d
| D } t t | } d | k r¬ | j d f d d
| D } d
| i SWn< t k
r} z t
j | d
g i SWYd d } ~ Xn Xd S)z=
Return list of RabbitMQ hosts known to Nova
c S sE y t j | d SWn) t k
r@ } z | SWYd d } ~ Xn Xd S)Nr )ÚsocketÚ
gethostbyaddrÚ Exception)ÚaddressÚexr r r Ú
_get_hostname< s z/API.get_controller_nodes.<locals>._get_hostnamec S sV g } t j | } | j j d } x( | D] } | j | j d d q. W| S)Nú,ú@é )ÚurlparseÚnetlocÚsplitÚappend)ÚurlÚhostsÚ
parsed_urlZ parsed_hostsr$ r r r Ú _get_hosts_from_transport_urlB s
z?API.get_controller_nodes.<locals>._get_hosts_from_transport_urlZ rabbit_hostsÚ
transport_urlÚ Nc S s# g | ] } | j d d q S)ú:r )rU )Ú.0r$ r r r ú
<listcomp>W s z,API.get_controller_nodes.<locals>.<listcomp>Z localhostc s g | ] } | q Sr r )r^ r$ )rO r r r_ [ s rG )r\ N) r Zoslo_messaging_rabbitÚhasattrÚgetattrr[ ÚextendÚlistÚsetÚremoverL r4 Ú exception)r r" rZ rX Ztransport_hostsrN r )rO r rI 8 s0
zAPI.get_controller_nodesc C s5 | d } | j d | d d | d | d d d d S) z6
Validate given database credentials.
r$ Úvalidate_database_credsNr/ r1 Tr. ip )r2 )r r" r/ r$ r r r rg a s
zAPI.validate_database_creds) Ú__name__Ú
__module__Ú __qualname__Ú__doc__r r r! r& r' r r2 r3 r7 r8 r9 r: r; r< r= r? r@ rB rC rD rE rF rH rI rg r r )r r r
3 s>
)r
)$rk rJ rS Ú ImportErrorÚ urllib.parseÚparseZoslo_logr ÚloggingZnova.openstack.commonZoslo_messagingr ZosloZ oslo_configr Z oslo.configZnova.dbr Z nova.objectsr r( Únovar r r Ú getLoggerrh r4 r ZStrOptZcontego_api_optsZ
register_optsZrpcapi_cap_optZ register_optÚBaser
r r r r Ú<module> s@