Struct Client

pub struct Client { /* private fields */ }

The base kRPC client type.

Connecting to the kRPC server

Call new to establish a connection with the kRPC server.

use krpc_client::Client;
let client = Client::new("Test KRPC", "127.0.0.1", 50000, 50001);

Using RPC services

Pass or clone the client instance returned by Client::new to any RPC service in krpc_client::services::*.

use krpc_client::{services::space_center::SpaceCenter, Client};
let space_center = SpaceCenter::new(client);
// Then call procedures with the created service.
println!("Hello, {}!", space_center.get_active_vessel()?.get_name()?);

Implementations

impl Client

pub fn new( name: &str, ip_addr: &str, rpc_port: u16, stream_port: u16, ) -> Result<Arc<Self>, RpcError>

Constructs a new Client.

Examples

use krpc_client::Client;
let client = Client::new("Test KRPC", "127.0.0.1", 50000, 50001);

Examples found in repository

examples/streams.rs (line 8)

fn main() -> Result<(), Box<dyn Error>> {
    let client = Client::new("kRPC TEST", "127.0.0.1", 50000, 50001)?;

    let space_center = SpaceCenter::new(client.clone());

    // Set up a stream.
    let ut_stream = space_center.get_ut_stream()?;
    ut_stream.set_rate(1f32)?;

    // Wait for updates, and print the current value.
    for _ in 0..10 {
        ut_stream.wait();
        println!("It's {} o'clock", ut_stream.get()?);
    }

    Ok(())
}

examples/client.rs (line 8)

fn main() -> Result<(), Box<dyn Error>> {
    let client = Client::new("kRPC TEST", "127.0.0.1", 50000, 50001).unwrap();

    let sc = SpaceCenter::new(client.clone());

    // Check out our vessel.
    let ship = sc.get_active_vessel()?;

    // Greet the crew.
    match ship.get_crew()?.first() {
        Some(kerbal) => println!(
            "Hello, {}. Welcome to {}",
            kerbal.get_name()?,
            ship.get_name()?
        ),
        None => println!("{} is unkerbaled!", ship.get_name()?),
    };

    Ok(())
}