Struct TempFileConsumer 

pub struct TempFileConsumer {
    pub path: PathBuf,
    pub config: ConsumerConfig<String>,
}

A consumer that writes items to a temporary file.

The temporary file is managed externally and will be cleaned up when dropped.

Fields

path: PathBuf

The temporary file path

config: ConsumerConfig<String>

Configuration for the consumer

Implementations

impl TempFileConsumer

pub fn new(path: PathBuf) -> Self

Creates a new TempFileConsumer from a temporary file path.

Arguments

• path - Path to the temporary file

pub fn with_error_strategy(self, strategy: ErrorStrategy<String>) -> Self

Sets the error handling strategy.

pub fn with_name(self, name: String) -> Self

Sets the name for this consumer.

Trait Implementations

impl Consumer for TempFileConsumer

type InputPorts = (String,)

The input port tuple type for this consumer.

fn consume<'life0, 'async_trait>( &'life0 mut self, stream: Self::InputStream, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Consumes a stream of items.

fn set_config_impl(&mut self, config: ConsumerConfig<String>)

Internal implementation for setting configuration.

fn get_config_impl(&self) -> &ConsumerConfig<String>

Internal implementation for getting configuration.

fn get_config_mut_impl(&mut self) -> &mut ConsumerConfig<String>

Internal implementation for getting mutable configuration.

fn handle_error(&self, error: &StreamError<String>) -> ErrorAction

Handles an error according to the consumer’s error strategy.

fn create_error_context(&self, item: Option<String>) -> ErrorContext<String>

Creates an error context for the given item.

fn component_info(&self) -> ComponentInfo

Returns information about this consumer component.

fn set_config(&mut self, config: ConsumerConfig<Self::Input>)

Sets the configuration for this consumer.

fn config(&self) -> &ConsumerConfig<Self::Input>

Returns a reference to the consumer’s configuration.

fn config_mut(&mut self) -> &mut ConsumerConfig<Self::Input>

Returns a mutable reference to the consumer’s configuration.

fn with_name(self, name: String) -> Self

where Self: Sized,

Sets the name for this consumer.

impl Input for TempFileConsumer

type Input = String

The type of items produced by this input stream.

type InputStream = Pin<Box<dyn Stream<Item = String> + Send>>

The input stream type that yields items of type Self::Input.