Struct fruently::fluent::Fluent

pub struct Fluent<'a, A> where
    A: ToSocketAddrs,  { /* fields omitted */ }

Methods

impl<'a, A: ToSocketAddrs> Fluent<'a, A>

fn new<T>(addr: A, tag: T) -> Fluent<'a, A> where
    T: Into<Cow<'a, str>>, 

Create Fluent type.

Usage

use fruently::fluent::Fluent;
let fruently_with_str_tag = Fluent::new("127.0.0.1:24224", "test");
let fruently_with_string_tag = Fluent::new("127.0.0.1:24224", "test".to_string());

fn new_with_conf<T>(addr: A, tag: T, conf: RetryConf) -> Fluent<'a, A> where
    T: Into<Cow<'a, str>>, 

Trait Implementations

impl<'a, A: Debug> Debug for Fluent<'a, A> where
    A: ToSocketAddrs, 

fn fmt(&self, __arg_0: &mut Formatter) -> Result

Formats the value using the given formatter.

impl<'a, A: Clone> Clone for Fluent<'a, A> where
    A: ToSocketAddrs, 

fn clone(&self) -> Fluent<'a, A>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<'a, A: PartialEq> PartialEq for Fluent<'a, A> where
    A: ToSocketAddrs, 

fn eq(&self, __arg_0: &Fluent<'a, A>) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, __arg_0: &Fluent<'a, A>) -> bool

This method tests for !=.

impl<'a, A: ToSocketAddrs> JsonForwardable for Fluent<'a, A>

fn post<T>(self, record: T) -> Result<(), FluentError> where
    T: Serialize + Debug + Clone, 

Post record into Fluentd. Without time version.

fn post_with_time<T>(self, record: T, time: Tm) -> Result<(), FluentError> where
    T: Serialize + Debug + Clone, 

Post record into Fluentd. With time version.

impl<'a, A: ToSocketAddrs> MsgpackForwardable for Fluent<'a, A>

fn post<T>(self, record: T) -> Result<(), FluentError> where
    T: Serialize + Debug, 

Post record into Fluentd. Without time version.

fn post_with_time<T>(self, record: T, time: Tm) -> Result<(), FluentError> where
    T: Serialize + Debug, 

Post record into Fluentd. With time version.

impl<'a, A: ToSocketAddrs> Forwardable for Fluent<'a, A>

fn post<T>(self, entries: Vec<Entry<T>>) -> Result<(), FluentError> where
    T: Serialize + Debug, 

Post Vec<Entry<T>> into Fluentd.