Struct ClientConfig 

pub struct ClientConfig {
    pub endpoint: String,
    pub grpc_endpoint: Option<String>,
    pub http_endpoint: Option<String>,
    pub transport: TransportMode,
    pub api_key: Option<String>,
    pub token: Option<String>,
    pub run_id: Option<String>,
    pub timeout_ms: u64,
}

Fields

endpoint: String

grpc_endpoint: Option<String>

http_endpoint: Option<String>

transport: TransportMode

api_key: Option<String>

token: Option<String>

run_id: Option<String>

timeout_ms: u64

Implementations

impl ClientConfig

pub fn new(endpoint: impl Into<String>) -> Self

Examples found in repository

examples/support/utils.rs (line 73)

pub async fn create_client() -> Result<Client, Box<dyn Error>> {
    let endpoint =
        env::var("MUBIT_ENDPOINT").unwrap_or_else(|_| "http://127.0.0.1:3000".to_string());
    let grpc_endpoint =
        env::var("MUBIT_GRPC_ENDPOINT").unwrap_or_else(|_| "127.0.0.1:50051".to_string());
    let timeout_ms = env::var("MUBIT_TIMEOUT_MS")
        .ok()
        .and_then(|raw| raw.parse::<u64>().ok())
        .unwrap_or(30_000);

    let api_key =
        env::var("MUBIT_API_KEY").map_err(|_| boxed_error("MUBIT_API_KEY must be set"))?;

    let mut cfg = ClientConfig::new(endpoint).transport("http");
    cfg.grpc_endpoint = Some(grpc_endpoint);
    cfg.timeout_ms = timeout_ms;
    cfg.api_key = Some(api_key.clone());

    let client = Client::new(cfg)?;
    client.set_transport(TransportMode::Http);
    client.set_api_key(Some(api_key));

    let _ = client.auth.health().await?;

    Ok(client)
}

pub fn transport(self, transport: impl AsRef<str>) -> Self

Examples found in repository

examples/support/utils.rs (line 73)

pub async fn create_client() -> Result<Client, Box<dyn Error>> {
    let endpoint =
        env::var("MUBIT_ENDPOINT").unwrap_or_else(|_| "http://127.0.0.1:3000".to_string());
    let grpc_endpoint =
        env::var("MUBIT_GRPC_ENDPOINT").unwrap_or_else(|_| "127.0.0.1:50051".to_string());
    let timeout_ms = env::var("MUBIT_TIMEOUT_MS")
        .ok()
        .and_then(|raw| raw.parse::<u64>().ok())
        .unwrap_or(30_000);

    let api_key =
        env::var("MUBIT_API_KEY").map_err(|_| boxed_error("MUBIT_API_KEY must be set"))?;

    let mut cfg = ClientConfig::new(endpoint).transport("http");
    cfg.grpc_endpoint = Some(grpc_endpoint);
    cfg.timeout_ms = timeout_ms;
    cfg.api_key = Some(api_key.clone());

    let client = Client::new(cfg)?;
    client.set_transport(TransportMode::Http);
    client.set_api_key(Some(api_key));

    let _ = client.auth.health().await?;

    Ok(client)
}

pub fn api_key(self, api_key: impl Into<String>) -> Self

pub fn token(self, token: impl Into<String>) -> Self

pub fn run_id(self, run_id: impl Into<String>) -> Self

pub fn from_env() -> Self

Trait Implementations

impl Clone for ClientConfig

fn clone(&self) -> ClientConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ClientConfig

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

Formats the value using the given formatter.

impl Default for ClientConfig

fn default() -> Self

Returns the “default value” for a type.