photon-backend-fluvio 0.1.0

Fluvio storage adapter for Photon
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39

//! Fluvio client connection helpers.

use std::sync::Arc;

use fluvio::{Fluvio, FluvioClusterConfig};
use photon_backend::{PhotonError, Result};

use crate::config::FluvioConfig;

/// Shared Fluvio client handle.
pub type SharedClient = Arc<Fluvio>;

/// Connect to a Fluvio cluster via SC endpoint.
///
/// # Errors
///
/// Returns an error when connection fails.
pub async fn connect_fluvio(config: &FluvioConfig) -> Result<SharedClient> {
    validate_endpoint(&config.endpoint)?;
    let cluster_config = FluvioClusterConfig::new(config.endpoint.clone());
    let client = Fluvio::connect_with_config(&cluster_config)
        .await
        .map_err(|e| PhotonError::Internal(format!("fluvio connect {}: {e}", config.endpoint)))?;
    Ok(Arc::new(client))
}

/// Validate endpoint is non-empty.
///
/// # Errors
///
/// Returns an error when endpoint string is empty after parsing.
pub fn validate_endpoint(endpoint: &str) -> Result<()> {
    if endpoint.trim().is_empty() {
        return Err(PhotonError::Internal(
            "PHOTON_FLUVIO_ENDPOINT empty after parsing".into(),
        ));
    }
    Ok(())
}