Struct Source 

pub struct Source {
    pub name: String,
    pub start_sequence: Option<u64>,
    pub start_time: Option<OffsetDateTime>,
    pub filter_subject: Option<String>,
    pub external: Option<External>,
    pub domain: Option<String>,
    pub subject_transforms: Vec<SubjectTransform>,
    pub consumer: Option<StreamConsumerSource>,
}

Available on crate feature jetstream only.

Fields

name: String

Name of the stream source.

start_sequence: Option<u64>

Optional source start sequence.

start_time: Option<OffsetDateTime>

Optional source start time.

filter_subject: Option<String>

Optional additional filter subject.

external: Option<External>

Optional config for sourcing streams from another prefix, used for cross-account.

domain: Option<String>

Optional config to set a domain, if source is residing in different one.

subject_transforms: Vec<SubjectTransform>

Available on crate feature server_2_10 only.

Subject transforms for Stream.

consumer: Option<StreamConsumerSource>

Available on crate feature server_2_14 only.

Pre-created durable consumer to use for sourcing instead of the auto-managed ephemeral one. Required for full control over the consumer’s lifecycle (security, advanced delivery/replay options) when sourcing/mirroring from WorkQueue/Interest streams. Both name and deliver_subject must be non-empty and valid; the server rejects the config otherwise. See ADR-60.

Trait Implementations

impl Clone for Source

fn clone(&self) -> Source

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Source

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

Formats the value using the given formatter.

impl Default for Source

fn default() -> Source

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for Source

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for Source

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for Source

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Eq for Source

impl StructuralPartialEq for Source