Struct Output

pub struct Output { /* private fields */ }

Represents the output buffer for log data before it’s sent to S3. Manages buffering, naming, and partitioning of log files.

Implementations

impl Output

pub fn new(prefix: &str, postfix: &str) -> Self

Creates a new Output instance with the specified prefix and postfix.

Arguments

• prefix - The prefix for log file names
• postfix - The postfix/extension for log file names

Returns

A new Output instance with initialized buffer and metadata

pub fn bump_part(&mut self)

Increments the part number and updates the file name. Called when the current log file becomes too large and needs to be split.

pub fn gen_name(prefix: &str, part: u64, postfix: &str, nonce: &str) -> String

Generates a log file name based on the current date, part number, and configuration.

Arguments

• prefix - The file name prefix
• part - The part number for file splitting
• postfix - The file extension/postfix
• nonce - A unique identifier for this logging session

Returns

A formatted file name in the pattern: YYYY-MM-DD/part/prefix-nonce.postfix

pub async fn buffer_len(&self) -> u64

Returns the number of log entries currently in the buffer.

pub async fn flush_buffer(&self) -> String

Flushes the buffer and returns all buffered log entries as a single string. Clears the buffer and resets the size counter after flushing.

Returns

A newline-delimited string containing all buffered log entries

pub async fn append_to_buffer(&self, value: String)

Appends a log entry to the buffer and updates the size counter.

Arguments

• value - The log entry to append to the buffer

pub fn name(&self) -> String

Returns the current log file name.

pub fn size_in_bytes(&self) -> u64

Returns the current buffer size in bytes.

pub fn part(&self) -> u64

Returns the current part number.

pub fn update_size_in_bytes(&self, size_in_bytes: u64)

Updates the buffer size counter.

Arguments

• size_in_bytes - The new buffer size in bytes

pub fn update_name(&mut self, name: &str)

Updates the current log file name.

Arguments

• name - The new file name