Struct TakClient

Source

pub struct TakClient { /* private fields */ }

Expand description

TAK Protocol client for streaming connections to TAK servers

This client implements TAK Protocol Version 1 using Protocol Buffers. It handles the framing protocol for streaming connections and supports both plain TCP and TLS (including mTLS with client certificates).

§Example with mTLS

use takproto::{TakClient, TlsConfig, proto::CotEvent};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let tls_config = TlsConfig::new_with_client_cert(
        "ca.pem",
        "client.pem",
        "client-key.pem"
    )?;

    let mut client = TakClient::connect_tls(
        "takserver.example.com:8089",
        "takserver.example.com",
        tls_config
    ).await?;

    let event = CotEvent {
        r#type: "a-f-G-U-C".to_string(),
        uid: "RUST-1".to_string(),
        // ... other fields
        ..Default::default()
    };

    client.send_cot_event(event).await?;
    Ok(())
}

Implementations§

Source §

impl TakClient

Source

pub async fn connect(addr: impl ToSocketAddrs) -> Result<Self>

Connect to a TAK server at the specified address using plain TCP

Note: Most production TAK servers require TLS. Use connect_tls instead.

§Arguments

addr - The address of the TAK server (e.g., “127.0.0.1:8087”)

§Example

let client = TakClient::connect("127.0.0.1:8087").await?;

Source

pub async fn connect_tls( addr: impl ToSocketAddrs, server_name: &str, tls_config: TlsConfig, ) -> Result<Self>

Connect to a TAK server using TLS with optional client certificate authentication (mTLS)

§Arguments

addr - The address of the TAK server (e.g., “takserver.example.com:8089”)
server_name - The server name for SNI and certificate validation
tls_config - TLS configuration including optional client certificates

§Example

let tls_config = TlsConfig::new_with_client_cert(
    "ca.pem",
    "client.pem",
    "client-key.pem"
)?;

let client = TakClient::connect_tls(
    "takserver.example.com:8089",
    "takserver.example.com",
    tls_config
).await?;

Source

pub async fn send_cot_event(&mut self, event: CotEvent) -> Result<()>

Send a CoT event to the TAK server

This wraps the CotEvent in a TakMessage and sends it using the TAK Protocol streaming message format.

§Arguments

event - The CoT event to send

§Example

let event = CotEvent {
    r#type: "a-f-G-U-C".to_string(),
    uid: "RUST-1".to_string(),
    send_time: 1234567890000,
    start_time: 1234567890000,
    stale_time: 1234567950000,
    how: "m-g".to_string(),
    lat: 37.7749,
    lon: -122.4194,
    hae: 10.0,
    ce: 9.9,
    le: 9.9,
    ..Default::default()
};
client.send_cot_event(event).await?;