Enum mz_storage_client::types::sinks::StorageSinkConnectionBuilder

source ·

pub enum StorageSinkConnectionBuilder {
    Kafka(KafkaSinkConnectionBuilder),
}

Variants§

§

Kafka(KafkaSinkConnectionBuilder)

Implementations§

source §

impl StorageSinkConnectionBuilder

source

pub fn connection_id(&self) -> Option<GlobalId>

returns an option to not constrain ourselves in the future

source

pub fn name(&self) -> &'static str

Returns the name of the sink connection.

Trait Implementations§

source §

impl Clone for StorageSinkConnectionBuilder

source §

fn clone(&self) -> StorageSinkConnectionBuilder

Returns a copy of the value. Read more

1.0.0 · source§

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

Performs copy-assignment from source. Read more

source §

impl Debug for StorageSinkConnectionBuilder

source §

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

Formats the value using the given formatter. Read more

source §

impl<'de> Deserialize<'de> for StorageSinkConnectionBuilder

source §

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

Deserialize this value from the given Serde deserializer. Read more

source §

impl PartialEq<StorageSinkConnectionBuilder> for StorageSinkConnectionBuilder

source §

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

This method tests for self and other values to be equal, and is used by ==.

1.0.0 · source§

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

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

source §

impl Serialize for StorageSinkConnectionBuilder

source §

fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>where
S: Serializer,

Serialize this value into the given Serde serializer. Read more

source §

impl Eq for StorageSinkConnectionBuilder

source §

impl StructuralEq for StorageSinkConnectionBuilder

source §

impl StructuralPartialEq for StorageSinkConnectionBuilder

Auto Trait Implementations§

§

impl UnwindSafe for StorageSinkConnectionBuilder

Blanket Implementations§

source §

impl<T> Any for Twhere
T: 'static + ?Sized,

source §

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

source §

impl<T> Borrow<T> for Twhere
T: ?Sized,

const: unstable · source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

source §

impl<T> BorrowMut<T> for Twhere
T: ?Sized,

const: unstable · source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

source §

impl<T> DynClone for Twhere
T: Clone,

source §

fn __clone_box(&self, _: Private) -> *mut ()

source §

impl<Q, K> Equivalent<K> for Qwhere
Q: Eq + ?Sized,
K: Borrow<Q> + ?Sized,

source §

fn equivalent(&self, key: &K) -> bool

Compare self to key and return true if they are equal.

source §

impl<T> From<T> for T

const: unstable · source§

fn from(t: T) -> T

Returns the argument unchanged.

source §

impl<T> FromRef<T> for Twhere
T: Clone,

source §

fn from_ref(input: &T) -> T

Converts to this type from a reference to the input type.

source §

impl<T> FutureExt for T

source §

fn with_context(self, otel_cx: Context) -> WithContext<Self>

Attaches the provided Context to this type, returning a WithContext wrapper. Read more

source §

fn with_current_context(self) -> WithContext<Self>

Attaches the current Context to this type, returning a WithContext wrapper. Read more

source §

impl<T> Instrument for T

source §

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more

source §

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

source §

impl<T, U> Into for Twhere
U: From<T>,

const: unstable · source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source §

impl<T> IntoRequest<T> for T

source §

fn into_request(self) -> Request<T>

Wrap the input message T in a tonic::Request

source §

impl<T> Pointable for T

source §

const ALIGN: usize = mem::align_of::<T>()

The alignment of pointer.

§

type Init = T

The type for initializers.

source §

unsafe fn init(init: <T as Pointable>::Init) -> usize

Initializes a with the given initializer. Read more

source §

unsafe fn deref<'a>(ptr: usize) -> &'a T

Dereferences the given pointer. Read more

source §

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

Mutably dereferences the given pointer. Read more

source §

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more

source §

impl<T> ProgressEventTimestamp for Twhere
T: Data + Debug + Any,

source §

fn as_any(&self) -> &(dyn Any + 'static)

Upcasts this ProgressEventTimestamp to Any. Read more

source §

fn type_name(&self) -> &'static str

Returns the name of the concrete type of this object. Read more

source §

impl<P, R> ProtoType<R> for Pwhere
R: RustType,

source §

fn into_rust(self) -> Result<R, TryFromProtoError>

See RustType::from_proto.

source §

fn from_rust(rust: &R) -> P

See RustType::into_proto.

source §

impl<T> Same<T> for T

§

type Output = T

Should always be Self

source §

impl<T> ToOwned for Twhere
T: Clone,

§

type Owned = T

The resulting type after obtaining ownership.

source §

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more

source §

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more

source §

impl<T, U> TryFrom for Twhere
U: Into<T>,

§

type Error = Infallible

The type returned in the event of a conversion error.

const: unstable · source§

fn try_from(value: U) -> Result<T, <T as TryFrom>::Error>

Performs the conversion.

source §

impl<T, U> TryInto for Twhere
U: TryFrom<T>,

§

type Error = >::Error

The type returned in the event of a conversion error.

const: unstable · source§

fn try_into(self) -> Result<U, >::Error>

Performs the conversion.

source §

impl<V, T> VZip<V> for Twhere
V: MultiLane<T>,

source §

fn vzip(self) -> V

source §

impl<T> WithSubscriber for T

source §

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

source §

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more

source §

impl<T> Data for Twhere
T: 'static + Clone,

source §

impl<T> Data for Twhere
T: 'static + Send + Sync + Any + Serialize + for<'a> Deserialize<'a>,

source §

impl<T> DeserializeOwned for Twhere
T: for<'de> Deserialize<'de>,

source §

Enum mz_storage_client::types::sinks::StorageSinkConnectionBuilder

Variants§

Kafka(KafkaSinkConnectionBuilder)

Implementations§

impl StorageSinkConnectionBuilder

pub fn connection_id(&self) -> Option<GlobalId>

pub fn name(&self) -> &'static str

Trait Implementations§

impl Clone for StorageSinkConnectionBuilder

fn clone(&self) -> StorageSinkConnectionBuilder

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

impl Debug for StorageSinkConnectionBuilder

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

impl<'de> Deserialize<'de> for StorageSinkConnectionBuilder

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

impl PartialEq<StorageSinkConnectionBuilder> for StorageSinkConnectionBuilder

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

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

impl Serialize for StorageSinkConnectionBuilder

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

impl Eq for StorageSinkConnectionBuilder

impl StructuralEq for StorageSinkConnectionBuilder

impl StructuralPartialEq for StorageSinkConnectionBuilder

Auto Trait Implementations§

impl RefUnwindSafe for StorageSinkConnectionBuilder

impl Send for StorageSinkConnectionBuilder

impl Sync for StorageSinkConnectionBuilder

impl Unpin for StorageSinkConnectionBuilder

impl UnwindSafe for StorageSinkConnectionBuilder

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> DynClone for Twhere T: Clone,

fn __clone_box(&self, _: Private) -> *mut ()

impl<Q, K> Equivalent<K> for Qwhere Q: Eq + ?Sized, K: Borrow<Q> + ?Sized,

fn equivalent(&self, key: &K) -> bool

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> FromRef<T> for Twhere T: Clone,

fn from_ref(input: &T) -> T

impl<T> FutureExt for T

fn with_context(self, otel_cx: Context) -> WithContext<Self>

fn with_current_context(self) -> WithContext<Self>

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> IntoRequest<T> for T

fn into_request(self) -> Request<T>

impl<T> Pointable for T

const ALIGN: usize = mem::align_of::<T>()

type Init = T

unsafe fn init(init: <T as Pointable>::Init) -> usize

unsafe fn deref<'a>(ptr: usize) -> &'a T

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

unsafe fn drop(ptr: usize)

impl<T> ProgressEventTimestamp for Twhere T: Data + Debug + Any,

fn as_any(&self) -> &(dyn Any + 'static)

fn type_name(&self) -> &'static str

impl<P, R> ProtoType<R> for Pwhere R: RustType<P>,

fn into_rust(self) -> Result<R, TryFromProtoError>

fn from_rust(rust: &R) -> P

impl<T> Same<T> for T

type Output = T

impl<T> ToOwned for Twhere T: Clone,

type Owned = T

fn to_owned(&self) -> T

fn clone_into(&self, target: &mut T)

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<V, T> VZip<V> for Twhere V: MultiLane<T>,

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

fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>where
S: Serializer,

impl<T> Any for Twhere
T: 'static + ?Sized,

impl<T> Borrow<T> for Twhere
T: ?Sized,

impl<T> BorrowMut<T> for Twhere
T: ?Sized,

impl<T> DynClone for Twhere
T: Clone,

impl<Q, K> Equivalent<K> for Qwhere
Q: Eq + ?Sized,
K: Borrow<Q> + ?Sized,

impl<T> FromRef<T> for Twhere
T: Clone,

impl<T, U> Into<U> for Twhere
U: From<T>,

impl<T> ProgressEventTimestamp for Twhere
T: Data + Debug + Any,

impl<P, R> ProtoType<R> for Pwhere
R: RustType<P>,

impl<T> ToOwned for Twhere
T: Clone,

impl<T, U> TryFrom<U> for Twhere
U: Into<T>,

impl<T, U> TryInto<U> for Twhere
U: TryFrom<T>,

impl<V, T> VZip<V> for Twhere
V: MultiLane<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where
S: Into<Dispatch>,

impl<T> Data for Twhere
T: 'static + Clone,

impl<T> Data for Twhere
T: 'static + Send + Sync + Any + Serialize + for<'a> Deserialize<'a>,

impl<T> DeserializeOwned for Twhere
T: for<'de> Deserialize<'de>,

impl<T> ExchangeData for Twhere
T: Data + Data,