Struct Client

pub struct Client {
    pub transport: TCPTransport,
}

Fields

transport: TCPTransport

Implementations

impl Client

pub fn connect<A: ToSocketAddrs + ?Sized>(addr: &A) -> Result<Self>

Connect to a Riemann server using raw TCP.

pub fn connect_tls( hostname: &str, port: u16, ca_file: &str, cert_file: &str, key_file: &str, ) -> Result<Self>

Connect to a Riemann server using mTLS over TCP.

pub fn set_timeout(&mut self, timeout: Option<Duration>) -> Result<()>

Set a read and write timeout for the underlying socket

pub fn events(&mut self, events: Vec<Event>) -> Result<()>

Send multiple events, discarding the response if it is not an error.

pub fn event(&mut self, event: Event) -> Result<()>

Wrapper around .events() for sending a single Event.

pub fn query<T: Into<Query>>(&mut self, query: T) -> Result<Vec<Event>>

Send a query and return a sorted list of events matching the query.

Trait Implementations

impl Debug for Client

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.