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.