Struct IntervalProducer 

pub struct IntervalProducer {
    pub interval: Duration,
    pub config: ProducerConfig<SystemTime>,
}

A producer that emits events at regular intervals.

This producer generates timestamp events at the specified interval duration.

Fields

interval: Duration

The interval duration between events

config: ProducerConfig<SystemTime>

Configuration for the producer

Implementations

impl IntervalProducer

pub fn new(interval: Duration) -> Self

Creates a new IntervalProducer with the given interval.

Arguments

• interval - The duration between emitted events

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

Sets the error handling strategy.

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

Sets the name for this producer.

Trait Implementations

impl Output for IntervalProducer

type Output = SystemTime

The type of items produced by this output stream.

type OutputStream = Pin<Box<dyn Stream<Item = SystemTime> + Send>>

The output stream type that yields items of type Self::Output.

impl Producer for IntervalProducer

type OutputPorts = (SystemTime,)

The output port tuple type for this producer.

fn produce(&mut self) -> Self::OutputStream

Produces a stream of items.

fn set_config_impl(&mut self, config: ProducerConfig<SystemTime>)

Sets the configuration implementation.

fn get_config_impl(&self) -> &ProducerConfig<SystemTime>

Returns a reference to the configuration implementation.

fn get_config_mut_impl(&mut self) -> &mut ProducerConfig<SystemTime>

Returns a mutable reference to the configuration implementation.

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

Handles an error that occurred during stream production.

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

Creates an error context for error reporting.

fn component_info(&self) -> ComponentInfo

Returns information about the component for error reporting.

fn set_config(&mut self, config: ProducerConfig<Self::Output>)

Sets the configuration for this producer.

fn config(&self) -> &ProducerConfig<Self::Output>

Returns a reference to the producer’s configuration.

fn config_mut(&mut self) -> &mut ProducerConfig<Self::Output>

Returns a mutable reference to the producer’s configuration.

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

where Self: Sized,

Sets the name for this producer.