dZddlmZddlmZddlmZddlmZddlmZddlm Z ddl m Z dd l m Z dd lmZdd lmZdd lmZej&Zej(ZGd deZGddeZGddeZGddeZy)zICommands for interacting with the Cloud NetApp Files Volume API resource.)absolute_import)division)unicode_literals) list_pager) constants)util)waiter)base)log) resources)netapp_v1beta1_messagesc >eZdZdZej j fdZedZ edZ dZ ddZ dZ dd Zd Zd Zd Zd ZdZ ddZdZ ddedededefdZdededefdZy) VolumesClientzFWrapper for working with volumes in the Cloud NetApp Files API Client.c||_|jtjjk(rt |_y|jtjj k(rt|_y|jtjjk(rt|_ytdjtj|)Nz [{}] is not a valid API version.) release_trackr ReleaseTrackALPHAAlphaVolumesAdapter_adapterBETABetaVolumesAdapterGAVolumesAdapter ValueErrorformatr VERSION_MAP)selfrs 3lib/googlecloudsdk/api_lib/netapp/volumes/client.py__init__zVolumesClient.__init__(s&D T..444)+dm  t0055 5(*dm  t0033 3$&dm  , 3 3}-  c.|jjSN)rclientrs rr#zVolumesClient.client7s ==  r c.|jjSr")rmessagesr$s rr&zVolumesClient.messages;s == ! !!r ctjtj|jj|dj |j S)aWaits 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 rWaitForOperationzVolumesClient.WaitForOperation?sL >>.. KK 5 5  %,,]-?-?-AB  r Ncf|jj|}|jjj |}|j D]&}t jdj|(tj|jj|tj|dS)acMake API calls to List active Cloud NetApp Volumes. Args: location_ref: The parsed location of the listed NetApp Volumes. limit: The number of Cloud NetApp Volumes 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 Volumes. )parentzLocation {} may be unreachable.pageSize)fieldlimitbatch_size_attribute) r&)NetappProjectsLocationsVolumesListRequestr#projects_locations_volumesList unreachabler warningrr YieldFromListrVOLUME_RESOURCE)r location_refr2requestresponselocations r ListVolumeszVolumesClient.ListVolumesSsmmEEFG{{55::7CH(( kk3::8DE)  # # ..'''  r cx|jj|jj|j |}|j j j|}|r|Stjj|jtj}|j|S)zCreate a Cloud NetApp Volume.)r/volumeIdvolume collection)r&+NetappProjectsLocationsVolumesCreateRequestParent RelativeNamer+r#r5Creater REGISTRYParseRelativeNamenamerOPERATIONS_COLLECTIONr-)r volume_refasync_configr< create_opr,s r CreateVolumezVolumesClient.CreateVolumemsmmGG  "//1"HG  66==gFI &&889#B#B9M   //r cl|jj||||||||| | | | | |||||||||||||S)zBParses the command line arguments for Create Volume into a config.)rKcapacity description storage_pool protocols share_name export_policyunix_permissions smb_settingssnapshot_policy snap_reservesnapshot_directorysecurity_styleenable_kerberossnapshotbackuprestricted_actions backup_configlarge_capacitymultiple_endpointstiering_policyhybrid_replication_parametersthroughput_mibpscache_parameterslabels block_devices)rParseVolumeConfig)rrKrSrTrUrVrWrXrYrZr[r\r]r^r_r`rarbrcrdrerfrgrhrirjrks rrlzVolumesClient.ParseVolumeConfig|sn< == * * !#)!'!-%'-#%-%&C))#5 + r c|jj|j}|jjj |S)z$Get Cloud NetApp Volume information.)rK)r&(NetappProjectsLocationsVolumesGetRequestrGr#r5Get)rrMr<s r GetVolumezVolumesClient.GetVolumesEmmDD  $ $ &EG ;; 1 1 5 5g >>r c||jj|j|}|j||S)z(Deletes an existing Cloud NetApp Volume.)rKforce)r&+NetappProjectsLocationsVolumesDeleteRequestrG _DeleteVolume)rrMrNrrr<s r DeleteVolumezVolumesClient.DeleteVolumes?mmGG  $ $ &eHG   fg ..r c|jjj|}|r|Stjj |j tj}|j|S)NrC) r#r5Deleter rIrJrKrrLr-)rrNr< delete_opr,s rrtzVolumesClient._DeleteVolumesb 66==gFI &&889#B#B9M   //r cr|jj|j|jj|}|jj j |}|r|Stjj|jtj}|j|S)z(Reverts an existing Cloud NetApp Volume.) snapshotId)rKrevertVolumeRequestrC)r&+NetappProjectsLocationsVolumesRevertRequestrGRevertVolumeRequestr#r5Revertr rIrJrKrrLr-)rrM snapshot_idrNr< revert_opr,s r RevertVolumezVolumesClient.RevertVolumesmmGG  $ $ & MM=="> HG  66==gFI &&889#B#B9M   //r cv|jj|j|jj|||}|jj j |}|r|Stjj|jtj}|j|S)z2Restores specific files from a backup to a volume.)rafileListrestoreDestinationPath)rKrestoreBackupFilesRequestrC)r&,NetappProjectsLocationsVolumesRestoreRequestrGRestoreBackupFilesRequestr#r5Restorer rIrJrKrrLr-) rrMra file_listrestore_destination_pathrNr< restore_opr,s r RestoreVolumezVolumesClient.RestoreVolumesmmHH  $ $ &"&--"I"I#;#J# IG77??HJ &&88I$C$C9M   //r cj|jj||||||||| | | | | ||||||||||||S)z$Parses updates into a volume config.)rTrjrUrVrWrXrSrYrZr[r\r]r^r_r`rarbrcrdrerfrirhrk)rParseUpdatedVolumeConfig)r volume_configrTrjrUrVrWrXrSrYrZr[r\r]r^r_r`rarbrcrdrerfrirhrks rrz&VolumesClient.ParseUpdatedVolumeConfigsk: == 1 1!#)!'!-%'-#%-%))#3 2 r c|jj|||}|r|Stjj |j t j}|j|S)aMUpdates a Cloud NetApp Volume. Args: volume_ref: the reference to the Volume. volume_config: Volume config, the updated volume. 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. rC) r UpdateVolumer rIrJrKrrLr-)rrMr update_maskrN update_opr,s rrzVolumesClient.UpdateVolume,sg **M;I &&889#B#B9M   //r peer_cluster_name peer_svm_namepeer_volume_namereturncR|jj||||r|SgS)afParses the command line arguments for EstablishPeering 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 list of peer IP addresses. Returns: An EstablishVolumePeeringRequest message. )peerClusterName peerSvmNamepeerVolumeNamepeerIpAddresses)r&EstablishVolumePeeringRequest)rrrrpeer_ip_addressess r(ParseEstablishVolumePeeringRequestConfigz6VolumesClient.ParseEstablishVolumePeeringRequestConfigBsE$ == 6 6)!'->) 7 EG 7 r rM'establish_volume_peering_request_configrNc>|jj|j|}|jjj |}|r|St jj|jtj}|j|S)aEstablish peering between GCNV volume and an onprem ONTAP volume. Args: volume_ref: The reference to the volume. establish_volume_peering_request_config: The config for the peering request. async_: If true, the call will return immediately, otherwise wait for operation to complete. Returns: An EstablishVolumePeering operation. )rKestablishVolumePeeringRequestrC) r&5NetappProjectsLocationsVolumesEstablishPeeringRequestrGr#r5EstablishPeeringr rIrJrKrrLr-)rrMrrNr<establish_peering_opr,s rrzVolumesClient.EstablishPeering[s$mmQQ  $ $ &&MRG ..??H !!&&88!!i.M.M9M   //r r"NNNNNNNNNNNNNNNNNNNNNNNNNN)NNNNNNNNNNNNNNNNNNNNNNNN)__name__ __module__ __qualname____doc__r rrrpropertyr#r&r-r?rQrlrprurtrrrrstrrrVolumeboolrr rrr%sfN#'#4#4#:#:      " "(4 0"  $( 79v?/00 00  57r06   % 2000M0 0r rceZdZdZdZdZdZdZdZdZ dd Z dd Z d Z d Z d Zej j"fdZdZy)rz7Adapter for the Cloud NetApp Files API Volume resource.ctjj|_t j |j|_t j|j|_yN)r) r rrrrGetClientInstancer#GetMessagesModuler&r$s rrzVolumesAdapter.__init__sF**--D((t7I7IJDK**9K9KLDMr c\|sy|jj}|D]}|jj}|jD]\}}|dk(r||_|dk(r4|jjj j ||_|dk(r||_|dk(r||_ |dk(r||_ |dk(r||_ |dk(r||_ |d k(r||_ |d k(r||_|d k(r||_|d k(s||_|j"j%|||_y) zParses Export Policy for Volume into a config. Args: volume: The Cloud NetApp Volume message object export_policy: the Export Policy message object. Returns: Volume message populated with Export Policy values. Nzallowed-clientsz access-typezhas-root-accesszkerberos-5-read-onlyzkerberos-5-read-writezkerberos-5i-read-onlyzkerberos-5i-read-writezkerberos-5p-read-onlyzkerberos-5p-read-writenfsv3nfsv4)r& ExportPolicySimpleExportPolicyRuleitemsallowedClientsAccessTypeValueValuesEnumlookup_by_name accessType hasRootAccesskerberos5ReadOnlykerberos5ReadWritekerberos5iReadOnlykerberos5iReadWritekerberos5pReadOnlykerberos5pReadWriterrrulesappend exportPolicy)rrBrXexport_policy_configpolicysimple_export_policy_rulekeyvals rParseExportPolicyz VolumesAdapter.ParseExportPolicysP  ==557"&--"F"F"Hlln(#s # #58 # 2 - 151U1U1o1o1~1~2 # . # #47 # 1 ( (8; # 5 ) )9< # 6 ) )9< # 6 * *:= # 7 ) )9< # 6 * *:= # 7 '>,/ # ) '>,/ # )1%2  ''(AB7 8/Fr cHg|_|y|D]}|jj}d|vr |d|_|j dgD]}|j j |d|vr |d|_d|vr |d|_|jj |y)z.Parses Block Devices for Volume into a config.NrKz host-groupszos-typezsize-gib) blockDevicesr& BlockDevicerKget hostGroupsrosTypesizeGib)rrBrkblock_device_argsblock_device_message host_groups rParseBlockDevicesz VolumesAdapter.ParseBlockDevicessF *!]]668 $ $$5f$=!)--mR@*''..z:A ' '&7 &B# ( ('8'D$   !56+r cFg}|D]}|j|||_y)zParses Protocols from a list of Protocol Enums into the given volume. Args: volume: The Cloud NetApp Volume message object protocols: A list of protocol enums Returns: Volume message populated with protocol values. N)rrV)rrBrVprotocols_configprotocols rParseProtocolszVolumesAdapter.ParseProtocolss*h''Fr cx|sy|jj|_d|j_|j D]\}}|dk(rY|jj }|j d|_|j dd|_||j_ e|dk(rp|jj}|j d|_|j dd|_|j dd|_ ||j_ |d k(r|jj}|j d|_|j dd|_|j dd|_ |j d d |_||j_g|d k(sn|jj!}|j d|_|j dd|_|j dd|_ |j d d |_||j_y)a"Parses Snapshot Policy from a list of snapshot schedules into a given Volume. Args: volume: The Cloud NetApp Volume message object snapshot_policy: A list of snapshot policies (schedules) to parse Returns: Volume messages populated with snapshotPolicy field NThourly_snapshotzsnapshots-to-keepminuterdaily_snapshothourweekly_snapshotdaySundayzmonthly-snapshot)r&SnapshotPolicysnapshotPolicyenabledrHourlySchedulersnapshotsToKeeprhourlySchedule DailyScheduler dailyScheduleWeeklySchedulerweeklyScheduleMonthlySchedulemonthlySchedule)rrBr[rKsnapshot_scheduleschedules rParseSnapshotPolicyz"VolumesAdapter.ParseSnapshotPolicys   MM88:F$(F!#2#8#8#: " "==//1#4#8#89L#M +//!</7, # #==..0#4#8#89L#M +//!<)--fa8 .6+ $ $==//1#4#8#89L#M +//!<)--fa8 (,,UH= /7, % %==002#4#8#89L#M +//!<)--fa8 (,,UA6 08-3$;r c|jj||j|}|jjj |}|S)z1Send a Patch request for the Cloud NetApp Volume.)rBrK updateMask)r&*NetappProjectsLocationsVolumesPatchRequestrGr#r5Patch)rrMrrupdate_requestrs rrzVolumesAdapter.UpdateVolumesP]]MM  $ $ &NN  66<<^LI r Ncz|jj}||_||_||_||_||_||_|j|||j||||_ | |_ |j|| | |_ | |_| |_||_|jj#}|||_|||_||d}||_||_||_||j/|||||_|||_||j5||||j7|||j8|j8t:j<j>k(s'|j8t:j<j@k(r||jC||||jE|||S)aParses the command line arguments for Create Volume into a config. Args: name: the name of the Volume capacity: the storage capacity of the Volume. description: the description of the Volume. storage_pool: the Storage Pool the Volume is attached to. protocols: the type of fileshare protocol of the Volume. share_name: the share name or mount point of the Volume. export_policy: the export policy of the Volume if NFS. unix_permissions: the Unix permissions for the Volume. smb_settings: the SMB settings for the Volume. snapshot_policy: the Snapshot Policy for the Volume snap_reserve: the snap reserve (double) for the Volume snapshot_directory: Bool on whether to use snapshot directory for Volume security_style: the security style of the Volume enable_kerberos: Bool on whether to use kerberos for Volume snapshot: the snapshot name to create Volume from backup: the backup to create the Volume from. restricted_actions: the actions to be restricted on a Volume backup_config: the Backup Config attached to the Volume large_capacity: Bool on whether to use large capacity for Volume multiple_endpoints: Bool on whether to use multiple endpoints for Volume tiering_policy: the tiering policy for the volume. hybrid_replication_parameters: the hybrid replication parameters for the volume. throughput_mibps: throughput of the Volume (in MiB/s). cache_parameters: the cache parameters for the volume. labels: the parsed labels value. block_devices: the block devices for the volume. Returns: the configuration that will be used as the request body for creating a Cloud NetApp Files Volume. N)#r&rrK capacityGibrTrj storagePool shareNamerrunixPermissions smbSettingsr snapReservesnapshotDirectory securityStylekerberosEnabledRestoreParameterssourceSnapshot sourceBackuprestoreParametersrestrictedActionsthroughputMibpsParseBackupConfig largeCapacitymultipleEndpointsParseTieringPolicy ParseHybridReplicationParametersrr rrrrParseCacheParameters)rrKrSrTrUrVrWrXrYrZr[r\r]r^r_r`rarbrcrdrerfrgrhrirjrkrBrestore_parameterss rrlz VolumesAdapter.ParseVolumeConfigs@]] ! ! #FFK!F$FFM%F!F6=1 *-F%FV_5%F1F)F,F88:*2' (.% ~(*1F1F-F  V]3!+f%!3f! fn5$0 ++ /1C1C d//555   !2!2!7!7 7  " v}5# (89 Mr c|||_|||_|||_|||_||j |||||_||j ||| | |_| | |_| |j|| | | |_ | | |_ |||_ |||_ |||_|||j||||||_||j#|||||_|||_||j)||||j+|||||_|R|j.t0j2j4t0j2j6fvr|j9|||S)z8Parse update information into an updated Volume message.)rTrjrrrrrrrrrrrractiveDirectoryParseRestoreParametersr r r r rrr rr rrrr)rrrTrjrUrVrWrXrSrYrZr[r\r]r^r_active_directoryr`rarbrcrdrerfrirhrks rrz'VolumesAdapter.ParseUpdatedVolumeConfigss<"-m #m"*m".m -3 *m  ]M:#&6m#".m" }o>".m%(:m%!$2m!"&5m##&6m#v1 !!-6B%(:m%  ]M:!$2m!%(:m%! m^<#  /?@#&6m# T%7%7  <& ]M: r c|jj}|jdgD]}|jj ||jdd|_|jdd|_||_y)zParses Backup Config for Volume into a config. Args: volume: The Cloud NetApp Volume message object. backup_config: the Backup Config message object. Returns: Volume message populated with Backup Config values. zbackup-policiesz backup-vaultzenable-scheduled-backupsN)r& BackupConfigrbackupPoliciesr backupVaultscheduledBackupEnabled backupConfig)rrBrcbackup_config_message backup_policys rr z VolumesAdapter.ParseBackupConfigs}!MM668&**+*9 &))/:*5477R ,;;BB:N &))*<=*9 &))-8*548==3\3\3h3h #@"C"C"#  # MM 5 5 A A T T"((-a0$**3/2 U #  4i 4)0 &))*@A*= &))*CD*? &))*JK*E*OF&) sAF8c |jj}|jd|_|jd|_|jd|_|jdgD]}|j j||jd|_|jj}|jdgD]"}d|vs|djdk(|_ $||_ ||_ y ) zParses Cache Parameters for Volume into a config. Args: volume: The Cloud NetApp Volume message object. cache_parameters: The cache params message object. Returns: Volume message populated with Cache Parameters r)r*r+r,zenable-global-file-lockz cache-configzcifs-change-notify-enabledtrueN)r&CacheParametersrrrrrrenableGlobalFileLock CacheConfiglowercifsChangeNotifyEnabled cacheConfigcacheParameters)rrBricache_parameters_messager:cache_config_messagerOs rrz#VolumesAdapter.ParseCacheParameters=s  $}}<<>.>.B.B/+0@/C/C0,,<+?+?+P(&**+>C ..55jAD4D4H4H!51 ==446"&&~r: & / / 0 6 6 8F B 4;,@(5Fr r)NNNNNNNNNNNNNNNNNNNNNNNNN)rrrrrrrrrrrlrr rrr rrrrrr rrr|s?M )/V7$ ('9R  $( 7nf  7Qf0(228%%(( @OD(6r rc"eZdZdZfdZxZS)rzrYsP&''3..(#)X99 ! ' 'T0FT0n i6Vi6XMMM,Mr