Struct async_nats::jetstream::stream::SourceInfo

pub struct SourceInfo {
    pub name: String,
    pub lag: u64,
    pub active: Option<Duration>,
    pub filter_subject: Option<String>,
    pub subject_transform_dest: Option<String>,
    pub subject_transforms: Vec<SubjectTransform>,
}

Fields

name: String

Source name.

lag: u64

Number of messages this source is lagging behind.

active: Option<Duration>

Last time the source was seen active.

filter_subject: Option<String>

Filtering for the source.

subject_transform_dest: Option<String>

Source destination subject.

subject_transforms: Vec<SubjectTransform>

List of transforms.

Trait Implementations

impl Clone for SourceInfo

fn clone(&self) -> SourceInfo

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for SourceInfo

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for SourceInfo

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.