Struct CloseOutcome 

pub(crate) struct CloseOutcome {
    pub(crate) closed: usize,
    pub(crate) failed: usize,
}

Files closed while handling one payload.

The writer task uses it to decide whether pending messages can be acked (a file closed) or must be left for redelivery (a close failed).

Fields

closed: usize

Files closed and published successfully.

failed: usize

Files whose close failed.

Implementations

impl CloseOutcome

pub(crate) fn record( &mut self, result: Result<PathBuf, Box<dyn Error + Send + Sync>>, channel: u8, file_index: usize, )

Counts and logs the result of one ParquetLogger::close call.

Arguments

• result - Result returned by the close.
• channel - Channel of the file, for the log message.
• file_index - Part index of the file, for the log message.

Trait Implementations

impl Clone for CloseOutcome

fn clone(&self) -> CloseOutcome

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for CloseOutcome

impl Debug for CloseOutcome

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

Formats the value using the given formatter.

impl Default for CloseOutcome

fn default() -> CloseOutcome

Returns the “default value” for a type.

impl Eq for CloseOutcome

impl PartialEq for CloseOutcome

fn eq(&self, other: &CloseOutcome) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for CloseOutcome