Struct mz_dataflow_types::sinks::ProtoKafkaSinkConnection
source · [−]pub struct ProtoKafkaSinkConnection {
pub connection: Option<ProtoKafkaConnection>,
pub topic: String,
pub topic_prefix: String,
pub key_desc_and_indices: Option<ProtoKeyDescAndIndices>,
pub relation_key_indices: Option<ProtoRelationKeyIndicesVec>,
pub value_desc: Option<ProtoRelationDesc>,
pub published_schema_info: Option<ProtoPublishedSchemaInfo>,
pub consistency: Option<ProtoKafkaSinkConsistencyConnection>,
pub exactly_once: bool,
pub transitive_source_dependencies: Vec<ProtoGlobalId>,
pub fuel: u64,
pub options: HashMap<String, ProtoStringOrSecret>,
}
Fields
connection: Option<ProtoKafkaConnection>
topic: String
topic_prefix: String
key_desc_and_indices: Option<ProtoKeyDescAndIndices>
relation_key_indices: Option<ProtoRelationKeyIndicesVec>
value_desc: Option<ProtoRelationDesc>
published_schema_info: Option<ProtoPublishedSchemaInfo>
consistency: Option<ProtoKafkaSinkConsistencyConnection>
exactly_once: bool
transitive_source_dependencies: Vec<ProtoGlobalId>
fuel: u64
options: HashMap<String, ProtoStringOrSecret>
Trait Implementations
sourceimpl Clone for ProtoKafkaSinkConnection
impl Clone for ProtoKafkaSinkConnection
sourcefn clone(&self) -> ProtoKafkaSinkConnection
fn clone(&self) -> ProtoKafkaSinkConnection
Returns a copy of the value. Read more
1.0.0 · sourcefn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from source
. Read more
sourceimpl Debug for ProtoKafkaSinkConnection
impl Debug for ProtoKafkaSinkConnection
sourceimpl Default for ProtoKafkaSinkConnection
impl Default for ProtoKafkaSinkConnection
sourceimpl Message for ProtoKafkaSinkConnection
impl Message for ProtoKafkaSinkConnection
sourcefn encoded_len(&self) -> usize
fn encoded_len(&self) -> usize
Returns the encoded length of the message without a length delimiter.
sourcefn encode<B>(&self, buf: &mut B) -> Result<(), EncodeError> where
B: BufMut,
fn encode<B>(&self, buf: &mut B) -> Result<(), EncodeError> where
B: BufMut,
Encodes the message to a buffer. Read more
sourcefn encode_to_vec(&self) -> Vec<u8, Global>ⓘNotable traits for Vec<u8, A>impl<A> Write for Vec<u8, A> where
A: Allocator,
fn encode_to_vec(&self) -> Vec<u8, Global>ⓘNotable traits for Vec<u8, A>impl<A> Write for Vec<u8, A> where
A: Allocator,
A: Allocator,
Encodes the message to a newly allocated buffer.
sourcefn encode_length_delimited<B>(&self, buf: &mut B) -> Result<(), EncodeError> where
B: BufMut,
fn encode_length_delimited<B>(&self, buf: &mut B) -> Result<(), EncodeError> where
B: BufMut,
Encodes the message with a length-delimiter to a buffer. Read more
sourcefn encode_length_delimited_to_vec(&self) -> Vec<u8, Global>ⓘNotable traits for Vec<u8, A>impl<A> Write for Vec<u8, A> where
A: Allocator,
fn encode_length_delimited_to_vec(&self) -> Vec<u8, Global>ⓘNotable traits for Vec<u8, A>impl<A> Write for Vec<u8, A> where
A: Allocator,
A: Allocator,
Encodes the message with a length-delimiter to a newly allocated buffer.
sourcefn decode<B>(buf: B) -> Result<Self, DecodeError> where
B: Buf,
Self: Default,
fn decode<B>(buf: B) -> Result<Self, DecodeError> where
B: Buf,
Self: Default,
Decodes an instance of the message from a buffer. Read more
sourcefn decode_length_delimited<B>(buf: B) -> Result<Self, DecodeError> where
B: Buf,
Self: Default,
fn decode_length_delimited<B>(buf: B) -> Result<Self, DecodeError> where
B: Buf,
Self: Default,
Decodes a length-delimited instance of the message from the buffer.
sourcefn merge<B>(&mut self, buf: B) -> Result<(), DecodeError> where
B: Buf,
fn merge<B>(&mut self, buf: B) -> Result<(), DecodeError> where
B: Buf,
Decodes an instance of the message from a buffer, and merges it into self
. Read more
sourcefn merge_length_delimited<B>(&mut self, buf: B) -> Result<(), DecodeError> where
B: Buf,
fn merge_length_delimited<B>(&mut self, buf: B) -> Result<(), DecodeError> where
B: Buf,
Decodes a length-delimited instance of the message from buffer, and
merges it into self
. Read more
sourceimpl PartialEq<ProtoKafkaSinkConnection> for ProtoKafkaSinkConnection
impl PartialEq<ProtoKafkaSinkConnection> for ProtoKafkaSinkConnection
sourcefn eq(&self, other: &ProtoKafkaSinkConnection) -> bool
fn eq(&self, other: &ProtoKafkaSinkConnection) -> bool
This method tests for self
and other
values to be equal, and is used
by ==
. Read more
sourcefn ne(&self, other: &ProtoKafkaSinkConnection) -> bool
fn ne(&self, other: &ProtoKafkaSinkConnection) -> bool
This method tests for !=
.
sourceimpl RustType<ProtoKafkaSinkConnection> for KafkaSinkConnection
impl RustType<ProtoKafkaSinkConnection> for KafkaSinkConnection
sourcefn into_proto(&self) -> ProtoKafkaSinkConnection
fn into_proto(&self) -> ProtoKafkaSinkConnection
Convert a Self
into a Proto
value.
sourcefn from_proto(
proto: ProtoKafkaSinkConnection
) -> Result<Self, TryFromProtoError>
fn from_proto(
proto: ProtoKafkaSinkConnection
) -> Result<Self, TryFromProtoError>
Consume and convert a Proto
back into a Self
value. Read more
impl StructuralPartialEq for ProtoKafkaSinkConnection
Auto Trait Implementations
impl RefUnwindSafe for ProtoKafkaSinkConnection
impl Send for ProtoKafkaSinkConnection
impl Sync for ProtoKafkaSinkConnection
impl Unpin for ProtoKafkaSinkConnection
impl UnwindSafe for ProtoKafkaSinkConnection
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> FutureExt for T
impl<T> FutureExt for T
sourcefn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
sourcefn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
sourceimpl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
sourcefn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message T
in a tonic::Request
sourceimpl<T> ProgressEventTimestamp for T where
T: Data + Debug + Any,
impl<T> ProgressEventTimestamp for T where
T: Data + Debug + Any,
sourceimpl<P, R> ProtoType<R> for P where
R: RustType<P>,
impl<P, R> ProtoType<R> for P where
R: RustType<P>,
sourcefn into_rust(self) -> Result<R, TryFromProtoError>
fn into_rust(self) -> Result<R, TryFromProtoError>
See RustType::from_proto
.
sourcefn from_rust(rust: &R) -> P
fn from_rust(rust: &R) -> P
See RustType::into_proto
.
sourceimpl<T> ToOwned for T where
T: Clone,
impl<T> ToOwned for T where
T: Clone,
type Owned = T
type Owned = T
The resulting type after obtaining ownership.
sourcefn clone_into(&self, target: &mut T)
fn clone_into(&self, target: &mut T)
toowned_clone_into
)Uses borrowed data to replace owned data, usually by cloning. Read more
sourceimpl<T> WithSubscriber for T
impl<T> WithSubscriber for T
sourcefn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
sourcefn with_current_subscriber(self) -> WithDispatch<Self>
fn with_current_subscriber(self) -> WithDispatch<Self>
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more