ó ½-'Nc@sŠddlZddlZddlmZddlmZddlmZdefd„ƒYZ defd„ƒYZ d „Z d „Z dS( iÿÿÿÿN(tsucceed(tgather_results(t ManagerPlugintEucalyptusInfocBsMeZdZd„Zd„Zd„Zd„Zd„Zd„Zd„Z RS(sDProvide utility methods to get information about a Eucalyptus cloud.cCs ||_dS(N(t_tools(tselfttools((s@/usr/lib/python2.7/dist-packages/landscape/manager/eucalyptus.pyt__init__ scCst|jjddgƒƒS(s Get information about the version of Eucalyptus in use. A string matching the following format is returned:: Eucalyptus version: 1.6.2 @return: A L{Deferred} firing with the string output of the C{--version} command. t euca_confs --version(RRt_runTool(R((s@/usr/lib/python2.7/dist-packages/landscape/manager/eucalyptus.pytget_version_infos cCst|jjddgƒƒS(s%Get information about the registered walruses (S3). A string matching the following format is returned:: registered walruses: walrus 10.0.1.113 @return: A L{Deferred} firing with the string output of the C{--list-walruses} command. Rs--list-walruses(RRR (R((s@/usr/lib/python2.7/dist-packages/landscape/manager/eucalyptus.pytget_walrus_infos cCst|jjddgƒƒS(s.Get information about the registered cluster controllers.. A string matching the following format is returned:: registered clusters: dynamite 10.0.1.113 @return: A L{Deferred} firing with the string output of the C{--list-clusters} command. Rs--list-clusters(RRR (R((s@/usr/lib/python2.7/dist-packages/landscape/manager/eucalyptus.pytget_cluster_controller_info)s cCst|jjddgƒƒS(s9Get information about the registered storage controllers (EBS). A string matching the following format is returned:: registered storage controllers: dynamite 10.0.1.113 @return: A L{Deferred} firing with the string output of the C{--list-scs} command. Rs --list-scs(RRR (R((s@/usr/lib/python2.7/dist-packages/landscape/manager/eucalyptus.pytget_storage_controller_info6s cCst|jjddgƒƒS(sÅGet information about the registered node controller. A string matching the following format is returned:: registered nodes: 10.1.1.71 canyonedge i-2DC5056F i-5DE5176D 10.1.1.72 canyonedge 10.1.1.73 canyonedge 10.1.1.74 canyonedge 10.1.1.75 canyonedge @return: A L{Deferred} firing with the string output of the C{--list-nodes} command. Rs --list-nodes(RRR (R((s@/usr/lib/python2.7/dist-packages/landscape/manager/eucalyptus.pytget_node_controller_infoCscCst|jjddgƒƒS(sÉGet information about the capacity of the cloud. A string matching the following format is returned:: AVAILABILITYZONE bruterobe 10.0.1.113 AVAILABILITYZONE |- vm types free / max cpu ram disk AVAILABILITYZONE |- m1.small 0008 / 0008 1 128 2 AVAILABILITYZONE |- c1.medium 0008 / 0008 1 256 5 AVAILABILITYZONE |- m1.large 0004 / 0004 2 512 10 AVAILABILITYZONE |- m1.xlarge 0004 / 0004 2 1024 20 AVAILABILITYZONE |- c1.xlarge 0002 / 0002 4 2048 20 @return: A L{Deferred} firing with the string output of the C{euca-describe-availability-zones verbose} command. s euca-describe-availability-zonestverbose(RRR (R((s@/usr/lib/python2.7/dist-packages/landscape/manager/eucalyptus.pytget_capacity_infoTs( t__name__t __module__t__doc__RR R R R RR(((s@/usr/lib/python2.7/dist-packages/landscape/manager/eucalyptus.pyR s  t EucalyptuscBsYeZdZdZdZdZd Zd d d„Zd„Z d„Z d „Z d „Z RS( s+A management plugin for a Eucalyptus cloud.seucalyptus-managerseucalyptus-infoseucalyptus-info-errorii<cCshtt|ƒjƒ||_|jdkr7t|_n||_|jdkr[t|_nt|_ dS(N( tsuperRRt_service_hub_factorytNonetstart_service_hubt_eucalyptus_info_factorytget_eucalyptus_infotTruetenabled(Rtservice_hub_factoryteucalyptus_info_factory((s@/usr/lib/python2.7/dist-packages/landscape/manager/eucalyptus.pyRps    cCs)|js dS|jjj|j|jƒS(s»Run the plugin. A C{ServiceHub} runs services that provide information about Eucalyptus. If a service hub can't be created the plugin assumes that Eucalyptus is not installed. In such cases a message is written to the log and the plugin is disabled. @return: A C{Deferred} that will fire when the plugin has finished running, unless it's disabled in which case None is returned. N(Rtregistrytbrokertcall_if_acceptedt message_typet send_message(R((s@/usr/lib/python2.7/dist-packages/landscape/manager/eucalyptus.pytrunzs  csÛ|jjj}y|j|ƒ‰Wn=tk ra}tj|ƒt|_tj d|j ƒnvXddl m }ˆj |dƒƒ}|j|jƒ|j|jƒ|j|jjjƒ|j‡fd†ƒ|SdS(Ns;Couldn't start service hub. '%s' plugin has been disabled.iÿÿÿÿ(t GetEucaInfotadmincs ˆjƒS(N(tstop(tignored(t service_hub(s@/usr/lib/python2.7/dist-packages/landscape/manager/eucalyptus.pytšs(Rtconfigt data_pathRt ExceptiontloggingtdebugtFalseRtinfoR"timagestore.eucaserviceR%taddTaskt addCallbackt _get_messaget addErrbackt_get_error_messageR R#taddBoth(RR,teR%tdeferred((R)s@/usr/lib/python2.7/dist-packages/landscape/manager/eucalyptus.pyR#Šs   csvg}ˆjˆƒ}|jƒ|jƒ|jƒ|jƒ|jƒ|jƒg}‡‡fd†}t|ƒj|ƒS(s#Create a message with information about a Eucalyptus cloud. @param credentials: A C{EucaInfo} instance containing credentials for the Eucalyptus cloud being managed. @return: A message with information about Eucalyptus to send to the server. c s³|\}}}}}}|jƒd}iˆjd6ˆjd6ˆjd6ˆjd6ˆjd6ˆjd6ˆjd6|d 6}iˆjd 6|d 6|d 6|d 6|d6|d6|d6S(Niÿÿÿÿt access_keyt secret_keytprivate_key_pathtcertificate_pathtcloud_certificate_patht url_for_s3t url_for_ec2teucalyptus_versionttypet basic_infot walrus_infotcluster_controller_infotstorage_controller_infotnode_controller_infot capacity_info( tsplitt accessKeyt secretKeytprivateKeyPathtcertificatePathtcloudCertificatePathturlForS3t urlForEC2R"( tresultt version_infoRERFRGRHRItversiontdata(Rt credentials(s@/usr/lib/python2.7/dist-packages/landscape/manager/eucalyptus.pytcreate_message¯s         ( RR R R R RRRR4(RRVt deferred_listR1RW((RRVs@/usr/lib/python2.7/dist-packages/landscape/manager/eucalyptus.pyR5s     cCsLddlm}|j|ƒr+t|_n|jƒ}i|jd6|d6S(sïCreate an error message. @param failure: A C{Failure} instance containing information about an error that occurred while trying to retrieve credentials. @return: An error message to send to the server. iÿÿÿÿ(tEucaToolsErrorRCterror(R2RYtcheckR0RtgetBriefTracebackterror_message_type(RtfailureRYRZ((s@/usr/lib/python2.7/dist-packages/landscape/manager/eucalyptus.pyR7Äs   i„N( RRRt plugin_nameR"R]t run_intervalRRR$R#R5R7(((s@/usr/lib/python2.7/dist-packages/landscape/manager/eucalyptus.pyRhs   'cCs”ddlm}ddlm}ddlm}tjj|dƒ}tjj |ƒsgtj |ƒn|ƒ}|j |||ƒƒ|j ƒ|S(súCreate and start a C{ServiceHub} to use when getting credentials. @param data_path: The path to Landscape's data directory. @return: A running C{ServiceHub} with a C{EucaService} service that can be used to retrieve credentials. iÿÿÿÿ(treactor(t ServiceHub(t EucaServicet eucalyptus( ttwisted.internetRatimagestore.lib.serviceRbR2Rctostpathtjointexiststmakedirst addServicetstart(R,RaRbRct base_pathR)((s@/usr/lib/python2.7/dist-packages/landscape/manager/eucalyptus.pyRÓs  cCs ddlm}t||ƒƒS(sCreate a L{EucalyptusInfo} instance. @param credentials: An C{imagestore.eucaservice.EucaInfo} instance. @return: A L{EucalyptusInfo} instance. iÿÿÿÿ(t EucaTools(R2RoR(RVRo((s@/usr/lib/python2.7/dist-packages/landscape/manager/eucalyptus.pyRçs( RgR.ttwisted.internet.deferRtlandscape.lib.twisted_utilRtlandscape.manager.pluginRtobjectRRRR(((s@/usr/lib/python2.7/dist-packages/landscape/manager/eucalyptus.pyts  ^k