pub struct BusHandles {
pub pubsub: Arc<dyn Pubsub>,
pub kv: Arc<dyn KvStore>,
pub request_reply: Arc<dyn RequestReply>,
pub jobs: Arc<dyn JobQueue>,
}Expand description
Re-exports every public item from klieo-core.
Resolved bundle of bus handles ready to drop into an
crate::agent::AgentContext or an App.
Impl crates (klieo-bus-memory, klieo-bus-nats) provide From
conversions; downstream code typically writes
BusHandles::from(MemoryBus::new()) and never destructures the
four sub-handles by name.
Fields§
§pubsub: Arc<dyn Pubsub>Pub/sub.
kv: Arc<dyn KvStore>KV store.
request_reply: Arc<dyn RequestReply>Synchronous request/reply.
jobs: Arc<dyn JobQueue>Durable job queue.
Implementations§
Source§impl BusHandles
impl BusHandles
Trait Implementations§
Source§impl Clone for BusHandles
impl Clone for BusHandles
Source§fn clone(&self) -> BusHandles
fn clone(&self) -> BusHandles
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl From<MemoryBus> for BusHandles
impl From<MemoryBus> for BusHandles
Source§fn from(value: MemoryBus) -> BusHandles
fn from(value: MemoryBus) -> BusHandles
Converts to this type from the input type.
Source§impl From<NatsBus> for BusHandles
impl From<NatsBus> for BusHandles
Source§fn from(value: NatsBus) -> BusHandles
fn from(value: NatsBus) -> BusHandles
Converts to this type from the input type.
Auto Trait Implementations§
impl !RefUnwindSafe for BusHandles
impl !UnwindSafe for BusHandles
impl Freeze for BusHandles
impl Send for BusHandles
impl Sync for BusHandles
impl Unpin for BusHandles
impl UnsafeUnpin for BusHandles
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
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
Source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
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> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§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