Struct FlightClient 

pub struct FlightClient { /* private fields */ }

Flight client for fetching geospatial data.

Implementations

impl FlightClient

pub async fn new(address: String) -> Result<Self>

Create a new Flight client.

pub async fn handshake(&mut self) -> Result<()>

Perform handshake with the server.

pub async fn get_data(&mut self, ticket: String) -> Result<Vec<RecordBatch>>

Fetch data from the server using a ticket.

pub async fn put_data(&mut self, batches: Vec<RecordBatch>) -> Result<()>

Send data to the server.

pub async fn do_action( &mut self, action_type: String, body: Bytes, ) -> Result<Vec<Bytes>>

Execute an action on the server.

pub async fn list_tickets(&mut self) -> Result<Vec<String>>

List all available tickets.

pub async fn remove_ticket(&mut self, ticket: String) -> Result<()>

Remove a ticket from the server.

pub fn address(&self) -> &str

Get the server address.

pub async fn health_check(&mut self) -> Result<bool>

Check if the client is connected.