Struct fluvio_stream_dispatcher::dispatcher::K8ClusterStateDispatcher [−][src]
pub struct K8ClusterStateDispatcher<S, C> where
S: K8ExtendedSpec,
<S as Spec>::Owner: K8ExtendedSpec,
S::Status: PartialEq,
S::IndexKey: Debug, { /* fields omitted */ }
Expand description
For each spec, process updates from Kubernetes metadata
Implementations
impl<S, C> K8ClusterStateDispatcher<S, C> where
S: K8ExtendedSpec + Sync + Send + 'static,
<S as Spec>::Owner: K8ExtendedSpec,
S::Status: Display + Sync + Send + 'static,
S::Status: Into<<<S as K8ExtendedSpec>::K8Spec as K8Spec>::Status>,
S::IndexKey: Display + Sync + Send + 'static,
S: K8ExtendedSpec + Into<<S as K8ExtendedSpec>::K8Spec>,
K8Watch<S::K8Spec>: DeserializeOwned,
K8List<S::K8Spec>: DeserializeOwned,
S::K8Spec: Sync + Send + 'static,
<S as K8ExtendedSpec>::K8Spec: DeserializeOwned + Serialize + Send + Sync,
C: MetadataClient + 'static,
S::IndexKey: Display,
impl<S, C> K8ClusterStateDispatcher<S, C> where
S: K8ExtendedSpec + Sync + Send + 'static,
<S as Spec>::Owner: K8ExtendedSpec,
S::Status: Display + Sync + Send + 'static,
S::Status: Into<<<S as K8ExtendedSpec>::K8Spec as K8Spec>::Status>,
S::IndexKey: Display + Sync + Send + 'static,
S: K8ExtendedSpec + Into<<S as K8ExtendedSpec>::K8Spec>,
K8Watch<S::K8Spec>: DeserializeOwned,
K8List<S::K8Spec>: DeserializeOwned,
S::K8Spec: Sync + Send + 'static,
<S as K8ExtendedSpec>::K8Spec: DeserializeOwned + Serialize + Send + Sync,
C: MetadataClient + 'static,
S::IndexKey: Display,
start dispatcher
Trait Implementations
Auto Trait Implementations
impl<S, C> !RefUnwindSafe for K8ClusterStateDispatcher<S, C>
impl<S, C> Send for K8ClusterStateDispatcher<S, C> where
C: Send + Sync,
S: Send + Sync,
<S as Spec>::IndexKey: Send + Sync,
<S as Spec>::Status: Send + Sync,
impl<S, C> Sync for K8ClusterStateDispatcher<S, C> where
C: Send + Sync,
S: Send + Sync,
<S as Spec>::IndexKey: Send + Sync,
<S as Spec>::Status: Send + Sync,
impl<S, C> Unpin for K8ClusterStateDispatcher<S, C> where
S: Unpin,
impl<S, C> !UnwindSafe for K8ClusterStateDispatcher<S, C>
Blanket Implementations
Mutably borrows from an owned value. Read more
Instruments this type with the provided Span
, returning an
Instrumented
wrapper. Read more
Instruments this type with the provided Span
, returning an
Instrumented
wrapper. Read more
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more