Struct avassa_client::Client

pub struct Client { /* fields omitted */ }

The Client is used for all interaction with Control Tower or Edge Enforcer instances. Use one of the login functions to create an instance.

Implementations

impl Client

pub fn builder() -> ClientBuilder

Create a Client builder

pub async fn bearer_token(&self) -> String

Returns the login bearer token

pub async fn get_json<T: DeserializeOwned>(
    &self,
    path: &str,
    query_params: Option<&[(&str, &str)]>
) -> Result<T>

GET a json payload from the REST API.

pub async fn post_json(&self, path: &str, data: &Value) -> Result<Value>

POST arbitrary JSON to a path

pub async fn volga_open_producer(
    &self,
    producer_name: &str,
    topic: &str,
    options: Options
) -> Result<Producer>

Open a volga producer on a topic

pub async fn volga_open_nat_producer(
    &self,
    producer_name: &str,
    topic: &str,
    udc: &str,
    options: Options
) -> Result<Producer>

Open a volga NAT producer on a topic in a uDC

pub async fn volga_open_consumer(
    &self,
    consumer_name: &str,
    topic: &str,
    options: ConsumerOptions
) -> Result<Consumer>

Creates and opens a Volga consumer

pub async fn volga_open_nat_consumer(
    &self,
    consumer_name: &str,
    topic: &str,
    udc: &str,
    options: ConsumerOptions
) -> Result<Consumer>

Creates and opens a Volga NAT consumer

pub async fn volga_open_log_query(&self, query: &Query) -> Result<QueryStream>

Opens a query stream

Trait Implementations

impl Clone for Client

fn clone(&self) -> Client

Returns a copy of the value.

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

Performs copy-assignment from source.