HdZddlmZddlmZddlmZddlmZddlmZddlm Z ddl m Z dd l mZdd lmZdd lmZGd d eZGddeZGddeZGddeZy)zUCommands for interacting with the Cloud NetApp Files Volume Replication API resource.)absolute_import)division)unicode_literals) list_pager) constants)util)waiter)base)log) resourcesceZdZdZej j fdZedZ edZ dZ dZ ddZ dd Zd Zd Zd Z dd ZdZdZdZdZ ddZdZdZy)ReplicationsClientzKWrapper for working with Replications in the Cloud NetApp Files API Client.cf|tjjk(rt|_y|tjj k(rt |_y|tjjk(rt|_ytdjtj|)Nz [{}] is not a valid API version.) r ReleaseTrackBETABetaReplicationsAdapter_adapterALPHAAlphaReplicationsAdapterGAReplicationsAdapter ValueErrorformatnetapp_api_util VERSION_MAP)self release_tracks @lib/googlecloudsdk/api_lib/netapp/volumes/replications/client.py__init__zReplicationsClient.__init__!s))...-/dm $++11 1.0dm $++.. .)+dm  , 3 3))-8  c.|jjSN)rclientrs rr#zReplicationsClient.client/s ==  r c.|jjSr")rmessagesr$s rr&zReplicationsClient.messages3s == ! !!r ctjtj|jj|dj |j S)aWait on the long-running operation until the done field is True. Args: operation_ref: the operation reference. Raises: waiter.OperationError: if the operation contains an error. Returns: the 'response' field of the Operation. zWaiting for [{0}] to finish)r WaitForCloudOperationPollerNoResourcesr#projects_locations_operationsrName)r operation_refs rWaitForOperationz#ReplicationsClient.WaitForOperation7sL >>.. KK 5 5  %,,]-?-?-AB  r c@|jj||j|}|jjj |}|r|St jj|jtj}|j|S)z*Creates a Cloud NetApp Volume Replication.)parent replicationId replication collection) r&7NetappProjectsLocationsVolumesReplicationsCreateRequestr+r#'projects_locations_volumes_replicationsCreater REGISTRYParseRelativeNamenamerOPERATIONS_COLLECTIONr-)rreplication_ref volume_refasync_configrequest create_opr,s rCreateReplicationz$ReplicationsClient.CreateReplicationKs MM)..0 N   CCJJI &&889#B#B9M   //r Nc|jj}||_||_||_||_|j j||||_|S)a?Parse the command line arguments for Create Replication into a config. Args: name: the name of the Replication. description: the description of the Replication. labels: the parsed labels value. replication_schedule: the schedule for Replication. destination_volume_parameters: the input parameters used for creating destination volume. cluster_location: location of the user cluster, optional Returns: the configuration that will be used as the request body for creating a Cloud NetApp Files Replication. ) r& Replicationr9 descriptionlabelsreplicationScheduler ParseDestinationVolumeParametersclusterLocation)rr9rDrEreplication_scheduledestination_volume_parameterscluster_locationr1s rParseReplicationConfigz)ReplicationsClient.ParseReplicationConfig^s^0--++-KK)KK&:K#MM222#3K r cf|jj|}|jjj |}|j D]&}t jdj|(tj|jj|tj|dS)a{List all active Cloud NetApp Volume Replications. Args: volume_ref: The parent Volume to list NetApp Volume Replications. limit: The number of Cloud NetApp Volume Replications to limit the results to. This limit is passed to the server and the server does the limiting. Returns: Generator that yields the Cloud NetApp Volume Replications. )r/zLocation {} may be unreachable.pageSize)fieldlimitbatch_size_attribute) r&5NetappProjectsLocationsVolumesReplicationsListRequestr#r5List unreachabler warningrr YieldFromListrREPLICATION_RESOURCE)rr<rPr?responselocations rListReplicationsz#ReplicationsClient.ListReplicationss KK L  {{BBGGPH(( kk3::8DE)  # # ;;,,'  r cz|jj|j}|j||S)z3Delete an existing Cloud NetApp Volume Replication.r9)r&7NetappProjectsLocationsVolumesReplicationsDeleteRequest RelativeName_DeleteReplication)rr;r=r?s rDeleteReplicationz$ReplicationsClient.DeleteReplicationsB MM --/ N   " "67 33r c|jjj|}|r|Stjj |j tj}|j|S)Nr2) r#r5Deleter r7r8r9rr:r-)rr=r? delete_opr,s rr_z%ReplicationsClient._DeleteReplicationsg CCJJI &&889#B#B9M   //r c|jj|j}|jjj |S)z5Get information of a Cloud NetApp Volume Replication.r\)r&4NetappProjectsLocationsVolumesReplicationsGetRequestr^r#r5Get)rr;r?s rGetReplicationz!ReplicationsClient.GetReplicationsJ JJ --/ K  ;; > > B B7 KKr cB|jj|||||S)aParse updates into a replication config. Args: replication_config: The replication config to update. description: The new description, if any. labels: LabelsValue message, the new labels value, if any. replication_schedule: The new schedule for Replication, if any. cluster_location: location of the user cluster, if any. Returns: The replication message. )rDrErIrK)rParseUpdatedReplicationConfigrreplication_configrDrErIrKs rriz0ReplicationsClient.ParseUpdatedReplicationConfigs- == 6 6 F1) 7 r c|jj|||}|r|Stjj |j t j}|j|S)aqUpdate a Cloud NetApp Volume Replication. Args: replication_ref: the reference to the Replication. replication_config: Replication config, the updated replication. update_mask: str, a comma-separated list of updated fields. async_: bool, if False, wait for the operation to complete. Returns: an Operation or Volume message. r2) rUpdateReplicationr r7r8r9rr:r-)rr;rk update_maskr= update_opr,s rrmz$ReplicationsClient.UpdateReplicationsh //+[I &&889#B#B9M   //r c|jj|}|r|Stjj |j t j}|j|S)zResume a Cloud NetApp Volume Replication. Args: replication_ref: the reference to the Replication. async_: bool, if False, wait for the operation to complete. Returns: an Operation or Volume message. r2) rResumeReplicationr r7r8r9rr:r-)rr;r= resume_opr,s rrqz$ReplicationsClient.ResumeReplications^ //@I &&889#B#B9M   //r c|jj|}|r|Stjj |j t j}|j|S)aYReverse the direction of a Cloud NetApp Volume Replication. Args: replication_ref: the reference to the Replication. async_: bool, if False, wait for the operation to complete. Returns: an Operation if async_ is set to true, or a Replication message if the ReverseReplicationDirectionRequest is successful. r2) rReverseReplicationr r7r8r9rr:r-)rr;r= reverse_opr,s rrtz%ReplicationsClient.ReverseReplications^11/BJ &&88I$C$C9M   //r c|jj||}|r|Stjj |j t j}|j|S)aBStop a Cloud NetApp Volume Replication. Args: replication_ref: the reference to the Replication. async_: bool, if False, wait for the operation to complete. force: bool, if True, call stop Replication with force parameter set to True. Returns: an Operation or Volume message. r2) rStopReplicationr r7r8r9rr:r-)rr;r=forcestop_opr,s rrwz"ReplicationsClient.StopReplications_mm++OUCG n&&88 !@!@9M   //r c>|jj||||S)aParse the command line arguments for Establish Peering into a config. Args: peer_cluster_name: the name of the peer cluster. peer_svm_name: the name of the peer svm. peer_volume_name: the name of the peer volume. peer_ip_addresses: the ip addresses of the peer cluster. Returns: the configuration that will be used as the request body for establishing peering for Hybrid Replication. )r"ParseEstablishPeeringRequestConfig)rpeer_cluster_name peer_svm_namepeer_volume_namepeer_ip_addressess rr{z5ReplicationsClient.ParseEstablishPeeringRequestConfig%s&& == ; ;=*:26,000(0*02 .000r rcReZdZdZdZdZdZ d dZdZdZ d Z d Z d Z d Z y)rz#>=)!$%=!>$?$  9@@EF: /9K+r c|jj||j|}|jjj |}|S)z=Send a Patch request for the Cloud NetApp Volume Replication.)r1r9 updateMask)r&6NetappProjectsLocationsVolumesReplicationsPatchRequestr^r#r5Patch)rr;rkrnupdate_requestros rrmz%ReplicationsAdapter.UpdateReplicationsZ LL* --/" M  CCIII r NcN|||_|||_|||_|||_|S)z=Parse update information into an updated Replication message.)rDrErFrHrjs rriz1ReplicationsAdapter.ParseUpdatedReplicationConfigsF '2$ "('/C,#+;( r c|jj|j}|jjj |S)z>Send a resume request for the Cloud NetApp Volume Replication.r\)r&7NetappProjectsLocationsVolumesReplicationsResumeRequestr^r#r5Resume)rr;resume_requests rrqz%ReplicationsAdapter.ResumeReplicationsO MM --/ N  ;; > > E E r c|jj|j}|jjj |S)z?Send a reverse request for the Cloud NetApp Volume Replication.r\)r&ANetappProjectsLocationsVolumesReplicationsReverseDirectionRequestr^r#r5ReverseDirection)rr;reverse_requests rrtz&ReplicationsAdapter.ReverseReplicationsO WW --/ X  ;; > > O O r c|jj|j|jj|}|jj j |S)z > C C r cL|jj||||r|ng}|S)zHParse establish peering request for the Cloud NetApp Volume Replication.)peerClusterName peerSvmNamepeerVolumeNamepeerIpAddresses)r&EstablishPeeringRequest)rr|r}r~restablish_peering_requests rr{z6ReplicationsAdapter.ParseEstablishPeeringRequestConfigs8!% E E)!'->)B !F! %$r c|jj|j|}|jjj |S)zISend a establish peering request for the Cloud NetApp Volume Replication.)r9establishPeeringRequest)r&ANetappProjectsLocationsVolumesReplicationsEstablishPeeringRequestr^r#r5r)rr;rrs rrz$ReplicationsAdapter.EstablishPeeringsR WW --/$D X  ;; > > O O! r c|jj|j}|jjj |S)z > C C r r)rrrrrrGrmrirqrtrwr{rrrr rrrgs@D 9D :>26    %  r rc"eZdZdZfdZxZS)rzAAdapter for the Beta Cloud NetApp Files API Replication resource.ctt| tjj |_tj|j |_ tj|j |_ yr) superrrr rrrrrr#rr&r __class__s rrz BetaReplicationsAdapter.__init__s] !413**//D!33((DK$55((DMr rrrrr __classcell__rs@rrrsIr rc"eZdZdZfdZxZS)rzBAdapter for the Alpha Cloud NetApp Files API Replication resource.ctt| tjj |_tj|j |_ tj|j |_ yr) rrrr rrrrrr#rr&rs rrz!AlphaReplicationsAdapter.__init__s] "D24**00D!33((DK$55((DMr rrs@rrr sJr rN)r __future__rrrapitools.base.pyrgooglecloudsdk.api_lib.netapprrrgooglecloudsdk.api_lib.utilr googlecloudsdk.callioper googlecloudsdk.corer r objectrrrrrr rrsa\&''3A.(#)F0F0R T&Tn 1  6 r