Struct riemann_client::client::Client
[−]
[src]
pub struct Client {
pub transport: TCPTransport,
}Fields
transport: TCPTransport
Methods
impl Client[src]
fn connect<A: ToSocketAddrs + ?Sized>(addr: &A) -> Result<Self>[src]
Connect to a Riemann server using over TCP.
fn set_timeout(&mut self, timeout: Option<Duration>) -> Result<()>[src]
Set a read and write timeout for the underlying socket
fn events(&mut self, events: Vec<Event>) -> Result<()>[src]
Send multiple events, discarding the response if it is not an error.
fn event(&mut self, event: Event) -> Result<()>[src]
Wrapper around .events() for sending a single Event.
fn query<T: Into<Query>>(&mut self, query: T) -> Result<Vec<Event>>[src]
Send a query and return a sorted list of events matching the query.