Struct SyncManager 

pub struct SyncManager { /* private fields */ }

Synchronization manager for handling real-time data sync operations

Implementations

impl SyncManager

pub fn from_database<S: AsRef<str>>( &self, connection_string: S, ) -> SyncFromDatabaseBuilder

Create a new sync configuration from a PostgreSQL database

Examples

use zero_trust_sdk::{ZeroTrustClient, Config};
use std::time::Duration;

#[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 sync_config = client.sync()
        .from_database("postgresql://localhost:5432/source")
        .to_database("target-db")
        .with_interval(Duration::from_secs(300))
        .create("postgres-sync")
        .await?;
     
    println!("Created sync: {}", sync_config.name);
    Ok(())
}

pub fn from_api<S: AsRef<str>>(&self, api_url: S) -> SyncFromApiBuilder

Create a new sync configuration from an API endpoint

Examples

use zero_trust_sdk::{ZeroTrustClient, Config};
use std::time::Duration;

#[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 sync_config = client.sync()
        .from_api("https://api.example.com/data")
        .to_database("target-db")
        .with_interval(Duration::from_secs(600))
        .with_headers([("Authorization", "Bearer token")])
        .create("api-sync")
        .await?;
     
    println!("Created sync: {}", sync_config.name);
    Ok(())
}

pub fn from_csv<S: AsRef<str>>(&self, file_path: S) -> SyncFromCsvBuilder

Create a new sync configuration from a CSV file

Examples

use zero_trust_sdk::{ZeroTrustClient, Config};
use std::time::Duration;

#[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 sync_config = client.sync()
        .from_csv("/path/to/data.csv")
        .to_database("target-db")
        .to_table("imported_data")
        .with_interval(Duration::from_secs(3600))
        .create("csv-sync")
        .await?;
     
    println!("Created sync: {}", sync_config.name);
    Ok(())
}

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

List all sync configurations

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 syncs = client.sync().list().await?;
    for sync in syncs {
        println!("Sync {}: {:?} (interval: {}s)", 
                 sync.name, sync.status, sync.interval);
    }
     
    Ok(())
}

pub async fn get<S: AsRef<str>>(&self, name: S) -> Result<SyncConfig>

Get sync configuration by name

Arguments

• name - Sync configuration name

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 sync = client.sync().get("my-sync").await?;
    println!("Sync status: {:?}", sync.status);
     
    Ok(())
}

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

Start a sync configuration

Arguments

• name - Sync configuration name

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.sync().start("my-sync").await?;
    println!("Sync started");
     
    Ok(())
}

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

Stop a sync configuration

Arguments

• name - Sync configuration name

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.sync().stop("my-sync").await?;
    println!("Sync stopped");
     
    Ok(())
}

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

Delete a sync configuration

Arguments

• name - Sync configuration name

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.sync().delete("old-sync").await?;
    println!("Sync deleted");
     
    Ok(())
}

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

Trigger a manual sync run

Arguments

• name - Sync configuration name

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.sync().trigger("my-sync").await?;
    println!("Manual sync triggered");
     
    Ok(())
}

Trait Implementations

impl Clone for SyncManager

fn clone(&self) -> SyncManager

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SyncManager

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

Formats the value using the given formatter.