cortexflow_agent_api 0.1.2

CortexFlow agent API
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

use crate::agent::agent_client::AgentClient;
use anyhow::Error;
use std::result::Result::Ok;
use tonic::transport::Channel;
use tonic_reflection::pb::v1::server_reflection_client::ServerReflectionClient;

const AGENT_IP: &str = "http://127.0.0.1:9090";

#[cfg(feature = "client")]
pub async fn connect_to_client() -> Result<AgentClient<Channel>, Error> {
    //this methods force a HTTP/2 connection from a static string
    //FIXME: this will require an update to ensure a protected connection
    let channel = Channel::from_static(AGENT_IP).connect().await?;
    let client = AgentClient::new(channel);
    Ok(client)
}
#[cfg(feature = "client")]
pub async fn connect_to_server_reflection() -> Result<ServerReflectionClient<Channel>, Error> {
    //this methods force a HTTP/2 connection from a static string
    let channel = Channel::from_static(AGENT_IP).connect().await?;
    let client = ServerReflectionClient::new(channel);
    Ok(client)
}