Struct RuntimeBundle

Source

pub struct RuntimeBundle {
    pub runtime: KubericRuntime,
    pub replicator_control_rx: Receiver<ReplicatorControlEvent>,
    pub replicator_data_rx: Receiver<ReplicateRequest>,
    pub lifecycle_rx: Receiver<LifecycleEvent>,
    pub partition: Arc<PartitionHandle>,
    pub replicator_handle: StateReplicatorHandle,
    pub state: Arc<PartitionState>,
}

Expand description

Everything produced by the builder. The caller spawns the replicator actor with replicator_control_rx + replicator_data_rx, and runs the user service event loop with lifecycle_rx.

Fields§

§runtime: KubericRuntime§replicator_control_rx: Receiver<ReplicatorControlEvent>§replicator_data_rx: Receiver<ReplicateRequest>§lifecycle_rx: Receiver<LifecycleEvent>§partition: Arc<PartitionHandle>§replicator_handle: StateReplicatorHandle§state: Arc<PartitionState>

Auto Trait Implementations§

§

RuntimeBundle

Struct RuntimeBundle Copy item path

Fields§

Auto Trait Implementations§

impl Freeze for RuntimeBundle

impl RefUnwindSafe for RuntimeBundle

impl Send for RuntimeBundle

impl Sync for RuntimeBundle

impl Unpin for RuntimeBundle

impl UnsafeUnpin for RuntimeBundle

impl UnwindSafe for RuntimeBundle

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> From<T> for T

fn from(t: T) -> T

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<L> LayerExt<L> for L

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where L: Layer<S>,

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<T> WithSubscriber for T

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

fn with_current_subscriber(self) -> WithDispatch<Self>

Struct RuntimeBundle

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

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

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

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

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>
where L: Layer<S>,

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

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

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