Struct Client 

pub struct Client { /* private fields */ }

A fluentd client.

Implementations

impl Client

pub async fn new_tcp(addr: SocketAddr, config: &Config) -> AnyhowResult<Client>

Connect to the fluentd server using TCP and create a worker with tokio::spawn.

pub async fn new_unix<P: AsRef<Path> + Send>( path: P, config: &Config, ) -> AnyhowResult<Client>

Connect to the fluentd server using unix domain socket and create a worker with tokio::spawn.

Trait Implementations

impl Clone for Client

fn clone(&self) -> Client

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Client

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

Formats the value using the given formatter.

impl Drop for Client

The worker is terminated when client is dropped.

fn drop(&mut self)

Executes the destructor for this type.

impl FluentClient for Client

fn send(&self, tag: &str, record: Map) -> Result<(), SendError>

Send a fluent record to the fluentd server.

Params:

tag - Event category of a record to send.

record - Map object to send as a fluent record.

fn stop(self) -> Result<(), SendError>

Stop the worker.