Struct LogTailerConfig 

pub struct LogTailerConfig {
    pub directory: Utf8PathBuf,
    pub pattern: String,
    pub max_batch_size: usize,
    pub max_batch_latency: Duration,
    pub checkpoint_name: Option<String>,
    pub poll_watcher: Option<Duration>,
    pub tail: bool,
}

Configuration for constructing a single-consumer LogTailer.

Fields

directory: Utf8PathBuf

pattern: String

max_batch_size: usize

max_batch_latency: Duration

checkpoint_name: Option<String>

poll_watcher: Option<Duration>

tail: bool

Implementations

impl LogTailerConfig

pub fn new(directory: Utf8PathBuf) -> Self

pub fn pattern(self, pattern: impl Into<String>) -> Self

pub fn max_batch_size(self, size: usize) -> Self

pub fn max_batch_latency(self, latency: Duration) -> Self

pub fn checkpoint_name(self, name: impl Into<String>) -> Self

pub fn poll_watcher(self, interval: Duration) -> Self

pub fn tail(self, enable: bool) -> Self

pub async fn build(self) -> Result<LogTailer>

Build a single-consumer tailer.

pub async fn build_with_filter<F>(self, filter: Option<F>) -> Result<LogTailer>

where F: Fn(&Value) -> Result<bool> + Send + 'static,

Build a single-consumer tailer with an optional record filter.

Trait Implementations

impl<'de> Deserialize<'de> for LogTailerConfig

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for LogTailerConfig

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.