#[non_exhaustive]pub enum Source {
AwsKinesis(Box<AwsKinesis>),
CloudStorage(Box<CloudStorage>),
AzureEventHubs(Box<AzureEventHubs>),
AwsMsk(Box<AwsMsk>),
ConfluentCloud(Box<ConfluentCloud>),
}Expand description
Only one source type can have settings set.
Variants (Non-exhaustive)§
This enum is marked as non-exhaustive
Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.
AwsKinesis(Box<AwsKinesis>)
Optional. Amazon Kinesis Data Streams.
CloudStorage(Box<CloudStorage>)
Optional. Cloud Storage.
AzureEventHubs(Box<AzureEventHubs>)
Optional. Azure Event Hubs.
AwsMsk(Box<AwsMsk>)
Optional. Amazon MSK.
ConfluentCloud(Box<ConfluentCloud>)
Optional. Confluent Cloud.
Trait Implementations§
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§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request