Struct crypto_auditing::event_broker::Client

pub struct Client { /* private fields */ }

A client to the event broker service

Examples

use crypto_auditing::event_broker::Client;
use futures::stream::StreamExt;

#[tokio::main]
async fn main() -> anyhow::Result<()> {
    let client = Client::new().scopes(&vec!["tcp".to_string()]);

    let (_handle, mut reader) = client.start().await?;

    tokio::spawn(async move {
        while let Some(event) = reader.next().await {
            println!("{:?}", &event);
        }
    });

    tokio::signal::ctrl_c().await?;

    Ok(())
}

Implementations

impl Client

pub fn new() -> Self

Returns a new Client

pub fn address(self, address: impl AsRef<Path>) -> Self

Sets the Unix domain address of event broker

pub fn scopes(self, scopes: &Vec<String>) -> Self

Sets the scopes to restrict matches of events

pub async fn start( self ) -> Result<(ClientHandle, impl Stream<Item = EventGroup>)>

Starts driving the client connection.

This returns a tuple consisting a ClientHandle and a [Stream] which generates a sequence of event groups.