vim_rs 0.4.4

use std::sync::Arc;
use crate::core::client::{VimClient, Result};
/// Interface to manage storage inventory in VSLM service.
/// 
/// VSLM maintains inventory of VStorageObjects present on all the datastores
/// connected to VC. If there is a change in datastore membership in VC that has
/// to be updated in VSLM as well.
/// APIs in this class are called as callback functions when Datastore
/// membership in VC changes.
#[derive(Clone)]
pub struct VslmStorageLifecycleManager {
    client: Arc<dyn VimClient>,
    mo_id: String,
}
impl VslmStorageLifecycleManager {
    pub fn new(client: Arc<dyn VimClient>, mo_id: &str) -> Self {
        Self {
            client,
            mo_id: mo_id.to_string(),
        }
    }
    /// Query the mapping of *Datacenter* and *Datastore*
    /// for a specified datastore url.
    /// 
    /// ***Required privileges:*** System.View
    ///
    /// ## Parameters:
    ///
    /// ### datastore_url
    /// The datastore URL as specified in
    /// *DatastoreInfo.url*
    ///
    /// ## Returns:
    ///
    /// Returns array of *VslmQueryDatastoreInfoResult*
    /// representing the mapping between datastores and datacenters.
    ///
    /// ## Errors:
    ///
    /// ***NotFound***: If the specified datastoreUrl cannot be found.
    /// 
    /// ***VslmFault***: If a VSLM internal server error occurred.
    pub async fn vslm_query_datastore_info(&self, datastore_url: &str) -> Result<Option<Vec<crate::types::structs::VslmQueryDatastoreInfoResult>>> {
        let input = VslmQueryDatastoreInfoRequestType {datastore_url, };
        let bytes_opt = self.client.invoke_optional("vslm", "VslmStorageLifecycleManager", &self.mo_id, "VslmQueryDatastoreInfo", Some(&input)).await?;
        match bytes_opt {
            Some(ref b) => Ok(Some(crate::core::client::unmarshal_array(self.client.transport(), b)?)),
            None => Ok(None),
        }
    }
    /// Sync the FCD info on the passed in datastore.
    /// 
    /// ***Required privileges:*** System.View
    ///
    /// ## Parameters:
    ///
    /// ### datastore_url
    /// The datastore URL as specified in
    /// *DatastoreInfo.url*
    ///
    /// ### full_sync
    /// If this is set to true, all information for this datastore
    /// will be discarded from the catalog and reloaded from the
    /// datastore's catalog
    ///
    /// ### fcd_id
    /// If set, this call blocks until fcdId is persisited into db
    /// if this fcdId is not found in queue, assume persisted and return
    ///
    /// ## Errors:
    ///
    /// ***InvalidDatastore***: If the operation cannot be performed on the
    /// datastore.
    /// 
    /// ***NotFound***: If matching datastore could not be found for the given
    /// datastoreMoId.
    /// 
    /// ***VslmSyncFault***: If an exception occured during datastore sync.
    /// 
    /// ***VslmFault***: If a VSLM internal server error occurred.
    pub async fn vslm_sync_datastore(&self, datastore_url: &str, full_sync: bool, fcd_id: Option<&crate::types::structs::Id>) -> Result<()> {
        let input = VslmSyncDatastoreRequestType {datastore_url, full_sync, fcd_id, };
        self.client.invoke_void("vslm", "VslmStorageLifecycleManager", &self.mo_id, "VslmSyncDatastore", Some(&input)).await
    }
}
struct VslmQueryDatastoreInfoRequestType<'a> {
    datastore_url: &'a str,
}

impl<'a> miniserde::Serialize for VslmQueryDatastoreInfoRequestType<'a> {
    fn begin(&self) -> miniserde::ser::Fragment<'_> {
        miniserde::ser::Fragment::Map(Box::new(VslmQueryDatastoreInfoRequestTypeSer { data: self, seq: 0 }))
    }
}

struct VslmQueryDatastoreInfoRequestTypeSer<'b, 'a> {
    data: &'b VslmQueryDatastoreInfoRequestType<'a>,
    seq: usize,
}

impl<'b, 'a> miniserde::ser::Map for VslmQueryDatastoreInfoRequestTypeSer<'b, 'a> {
    fn next(&mut self) -> Option<(std::borrow::Cow<'_, str>, &dyn miniserde::Serialize)> {
        let seq = self.seq;
        self.seq += 1;
        match seq {
            0 => return Some((std::borrow::Cow::Borrowed("_typeName"), &"VslmQueryDatastoreInfoRequestType")),
            1 => return Some((std::borrow::Cow::Borrowed("datastoreUrl"), &self.data.datastore_url as &dyn miniserde::Serialize)),
            _ => return None,
        }
    }
}
struct VslmSyncDatastoreRequestType<'a> {
    datastore_url: &'a str,
    full_sync: bool,
    fcd_id: Option<&'a crate::types::structs::Id>,
}

impl<'a> miniserde::Serialize for VslmSyncDatastoreRequestType<'a> {
    fn begin(&self) -> miniserde::ser::Fragment<'_> {
        miniserde::ser::Fragment::Map(Box::new(VslmSyncDatastoreRequestTypeSer { data: self, seq: 0 }))
    }
}

struct VslmSyncDatastoreRequestTypeSer<'b, 'a> {
    data: &'b VslmSyncDatastoreRequestType<'a>,
    seq: usize,
}

impl<'b, 'a> miniserde::ser::Map for VslmSyncDatastoreRequestTypeSer<'b, 'a> {
    fn next(&mut self) -> Option<(std::borrow::Cow<'_, str>, &dyn miniserde::Serialize)> {
        loop {
            let seq = self.seq;
            self.seq += 1;
            match seq {
                0 => return Some((std::borrow::Cow::Borrowed("_typeName"), &"VslmSyncDatastoreRequestType")),
                1 => return Some((std::borrow::Cow::Borrowed("datastoreUrl"), &self.data.datastore_url as &dyn miniserde::Serialize)),
                2 => return Some((std::borrow::Cow::Borrowed("fullSync"), &self.data.full_sync as &dyn miniserde::Serialize)),
                3 => {
                    let Some(ref val) = self.data.fcd_id else { continue; };
                    return Some((std::borrow::Cow::Borrowed("fcdId"), val as &dyn miniserde::Serialize));
                }
                _ => return None,
            }
        }
    }
}