pub struct StoreManager { /* private fields */ }Expand description
Manages store operations, dispatching to the appropriate backend.
Implementations§
Source§impl StoreManager
impl StoreManager
Sourcepub fn new(async_db: Arc<AsyncDatabase>, data_dir: PathBuf) -> Self
pub fn new(async_db: Arc<AsyncDatabase>, data_dir: PathBuf) -> Self
Creates a store manager with built-in local and file backends.
Sourcepub async fn execute(
&self,
custom_resources: &HashMap<String, CustomResource>,
op: StoreOp,
) -> Result<StoreOpResult>
pub async fn execute( &self, custom_resources: &HashMap<String, CustomResource>, op: StoreOp, ) -> Result<StoreOpResult>
Execute a store operation, dispatching to the correct backend.
custom_resources is the CRD instance map from OrchestratorConfig.custom_resources.
Auto Trait Implementations§
impl Freeze for StoreManager
impl !RefUnwindSafe for StoreManager
impl Send for StoreManager
impl Sync for StoreManager
impl Unpin for StoreManager
impl UnsafeUnpin for StoreManager
impl !UnwindSafe for StoreManager
Blanket Implementations§
Source§impl<T> AnyExt for T
impl<T> AnyExt for T
Source§fn downcast_ref<T>(this: &Self) -> Option<&T>where
T: Any,
fn downcast_ref<T>(this: &Self) -> Option<&T>where
T: Any,
Attempts to downcast this to
T behind referenceSource§fn downcast_mut<T>(this: &mut Self) -> Option<&mut T>where
T: Any,
fn downcast_mut<T>(this: &mut Self) -> Option<&mut T>where
T: Any,
Attempts to downcast this to
T behind mutable referenceSource§fn downcast_rc<T>(this: Rc<Self>) -> Result<Rc<T>, Rc<Self>>where
T: Any,
fn downcast_rc<T>(this: Rc<Self>) -> Result<Rc<T>, Rc<Self>>where
T: Any,
Attempts to downcast this to
T behind Rc pointerSource§fn downcast_arc<T>(this: Arc<Self>) -> Result<Arc<T>, Arc<Self>>where
T: Any,
fn downcast_arc<T>(this: Arc<Self>) -> Result<Arc<T>, Arc<Self>>where
T: Any,
Attempts to downcast this to
T behind Arc pointerSource§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
Source§impl<T, X> CoerceTo<T> for Xwhere
T: CoerceFrom<X> + ?Sized,
impl<T, X> CoerceTo<T> for Xwhere
T: CoerceFrom<X> + ?Sized,
fn coerce_rc_to(self: Rc<X>) -> Rc<T>
fn coerce_box_to(self: Box<X>) -> Box<T>
fn coerce_ref_to(&self) -> &T
fn coerce_mut_to(&mut self) -> &mut T
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> 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