Struct async_nats::jetstream::stream::Source
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>,
}
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>
Subject transforms for Stream.
Trait Implementations§
source§impl<'de> Deserialize<'de> for Source
impl<'de> Deserialize<'de> for Source
source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
impl Eq for Source
impl StructuralPartialEq for Source
Auto Trait Implementations§
impl Freeze for Source
impl RefUnwindSafe for Source
impl Send for Source
impl Sync for Source
impl Unpin for Source
impl UnwindSafe for Source
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
source§unsafe fn clone_to_uninit(&self, dst: *mut T)
unsafe fn clone_to_uninit(&self, dst: *mut T)
🔬This is a nightly-only experimental API. (
clone_to_uninit
)