Struct StreamSource 

pub struct StreamSource {
    pub name: String,
    pub start_seq: Option<u64>,
    pub start_time: Option<OffsetDateTime>,
    pub filter_subject: Option<String>,
}

Stream source configuration.

Fields

name: String

The source stream name.

start_seq: Option<u64>

Optional starting sequence.

start_time: Option<OffsetDateTime>

Optional starting time.

filter_subject: Option<String>

Optional filter subject.

Implementations

impl StreamSource

pub fn new(name: impl Into<String>) -> Self

Create a new stream source.

pub fn start_seq(self, seq: u64) -> Self

Set the starting sequence.

pub fn start_time(self, time: OffsetDateTime) -> Self

Set the starting time.

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

Set the filter subject.

Trait Implementations

impl Clone for StreamSource

fn clone(&self) -> StreamSource

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamSource

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

Formats the value using the given formatter.

impl From<StreamSource> for Source

fn from(source: StreamSource) -> Self

Converts to this type from the input type.