Struct MigrationManager 

pub struct MigrationManager { /* private fields */ }

Migration manager for handling data import/export operations

Implementations

impl MigrationManager

pub fn import_csv<P: AsRef<Path>>(&self, file_path: P) -> CsvImportBuilder

Import data from a CSV file

Examples

use zero_trust_sdk::{ZeroTrustClient, Config};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let config = Config::new("https://api.zerotrust.com")?
        .with_token("your-jwt-token");
    let client = ZeroTrustClient::new(config).await?;
     
    let migration = client.migration()
        .import_csv("data.csv")
        .to_database("my-app-db")
        .to_table("users")
        .with_delimiter(',')
        .with_headers(true)
        .execute()
        .await?;
     
    println!("Migration ID: {}", migration.id);
    Ok(())
}

pub fn import_json<P: AsRef<Path>>(&self, file_path: P) -> JsonImportBuilder

Import data from a JSON file

Examples

use zero_trust_sdk::{ZeroTrustClient, Config};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let config = Config::new("https://api.zerotrust.com")?
        .with_token("your-jwt-token");
    let client = ZeroTrustClient::new(config).await?;
     
    let migration = client.migration()
        .import_json("data.json")
        .to_database("my-app-db")
        .to_table("products")
        .execute()
        .await?;
     
    println!("Migration ID: {}", migration.id);
    Ok(())
}

pub fn export_csv<P: AsRef<Path>>(&self, file_path: P) -> CsvExportBuilder

Export data to a CSV file

Examples

use zero_trust_sdk::{ZeroTrustClient, Config};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let config = Config::new("https://api.zerotrust.com")?
        .with_token("your-jwt-token");
    let client = ZeroTrustClient::new(config).await?;
     
    let migration = client.migration()
        .export_csv("users.csv")
        .from_database("my-app-db")
        .from_table("users")
        .with_delimiter(',')
        .with_headers(true)
        .execute()
        .await?;
     
    println!("Export completed: {}", migration.id);
    Ok(())
}

pub fn export_json<P: AsRef<Path>>(&self, file_path: P) -> JsonExportBuilder

Export data to a JSON file

Examples

use zero_trust_sdk::{ZeroTrustClient, Config};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let config = Config::new("https://api.zerotrust.com")?
        .with_token("your-jwt-token");
    let client = ZeroTrustClient::new(config).await?;
     
    let migration = client.migration()
        .export_json("products.json")
        .from_database("my-app-db")
        .from_table("products")
        .execute()
        .await?;
     
    println!("Export completed: {}", migration.id);
    Ok(())
}

pub async fn status<S: AsRef<str>>( &self, migration_id: S, ) -> Result<MigrationStatus>

Get migration status

Arguments

• migration_id - Migration ID

Examples

use zero_trust_sdk::{ZeroTrustClient, Config};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let config = Config::new("https://api.zerotrust.com")?
        .with_token("your-jwt-token");
    let client = ZeroTrustClient::new(config).await?;
     
    let status = client.migration().status("migration-123").await?;
    println!("Migration status: {:?}", status.status);
    println!("Progress: {}/{}", status.records_processed, status.total_records.unwrap_or(0));
     
    Ok(())
}

pub async fn list(&self) -> Result<Vec<MigrationStatus>>

List all migrations

Examples

use zero_trust_sdk::{ZeroTrustClient, Config};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let config = Config::new("https://api.zerotrust.com")?
        .with_token("your-jwt-token");
    let client = ZeroTrustClient::new(config).await?;
     
    let migrations = client.migration().list().await?;
    for migration in migrations {
        println!("Migration {}: {:?}", migration.id, migration.status);
    }
     
    Ok(())
}

pub async fn cancel<S: AsRef<str>>(&self, migration_id: S) -> Result<()>

Cancel a running migration

Arguments

• migration_id - Migration ID

Examples

use zero_trust_sdk::{ZeroTrustClient, Config};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let config = Config::new("https://api.zerotrust.com")?
        .with_token("your-jwt-token");
    let client = ZeroTrustClient::new(config).await?;
     
    client.migration().cancel("migration-123").await?;
    println!("Migration cancelled");
     
    Ok(())
}

Trait Implementations

impl Clone for MigrationManager

fn clone(&self) -> MigrationManager

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for MigrationManager

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.